C:\develop\Java\jdk1.8.0_202\bin\java.exe "-javaagent:C:\develop\JetBrains\IntelliJ IDEA 2021.2.1\lib\idea_rt.jar=11149:C:\develop\JetBrains\IntelliJ IDEA 2021.2.1\bin" -Dfile.encoding=UTF-8 -classpath C:\develop\Java\jdk1.8.0_202\jre\lib\charsets.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\deploy.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\access-bridge-64.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\cldrdata.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\dnsns.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\jaccess.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\jfxrt.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\localedata.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\mysql-connector-java-5.1.47.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\nashorn.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\sunec.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\sunjce_provider.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\sunmscapi.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\sunpkcs11.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\ext\zipfs.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\javaws.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\jce.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\jfr.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\jfxswt.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\jsse.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\management-agent.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\plugin.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\resources.jar;C:\develop\Java\jdk1.8.0_202\jre\lib\rt.jar;F:\Project\oceanbase1\target\classes;C:\develop\Maven\repository\org\apache\flink\flink-streaming-java\1.16.1\flink-streaming-java-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-core\1.16.1\flink-core-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-annotations\1.16.1\flink-annotations-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-metrics-core\1.16.1\flink-metrics-core-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-shaded-asm-9\9.2-15.0\flink-shaded-asm-9-9.2-15.0.jar;C:\develop\Maven\repository\org\apache\commons\commons-lang3\3.3.2\commons-lang3-3.3.2.jar;C:\develop\Maven\repository\com\esotericsoftware\kryo\kryo\2.24.0\kryo-2.24.0.jar;C:\develop\Maven\repository\com\esotericsoftware\minlog\minlog\1.2\minlog-1.2.jar;C:\develop\Maven\repository\org\objenesis\objenesis\2.1\objenesis-2.1.jar;C:\develop\Maven\repository\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;C:\develop\Maven\repository\org\apache\commons\commons-compress\1.21\commons-compress-1.21.jar;C:\develop\Maven\repository\org\apache\flink\flink-file-sink-common\1.16.1\flink-file-sink-common-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-runtime\1.16.1\flink-runtime-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-rpc-core\1.16.1\flink-rpc-core-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-rpc-akka-loader\1.16.1\flink-rpc-akka-loader-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-queryable-state-client-java\1.16.1\flink-queryable-state-client-java-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-hadoop-fs\1.16.1\flink-hadoop-fs-1.16.1.jar;C:\develop\Maven\repository\commons-io\commons-io\2.11.0\commons-io-2.11.0.jar;C:\develop\Maven\repository\org\apache\flink\flink-shaded-zookeeper-3\3.5.9-15.0\flink-shaded-zookeeper-3-3.5.9-15.0.jar;C:\develop\Maven\repository\org\javassist\javassist\3.24.0-GA\javassist-3.24.0-GA.jar;C:\develop\Maven\repository\org\xerial\snappy\snappy-java\1.1.8.3\snappy-java-1.1.8.3.jar;C:\develop\Maven\repository\org\lz4\lz4-java\1.8.0\lz4-java-1.8.0.jar;C:\develop\Maven\repository\org\apache\flink\flink-java\1.16.1\flink-java-1.16.1.jar;C:\develop\Maven\repository\com\twitter\chill-java\0.7.6\chill-java-0.7.6.jar;C:\develop\Maven\repository\org\apache\flink\flink-shaded-guava\30.1.1-jre-15.0\flink-shaded-guava-30.1.1-jre-15.0.jar;C:\develop\Maven\repository\org\apache\commons\commons-math3\3.6.1\commons-math3-3.6.1.jar;C:\develop\Maven\repository\org\slf4j\slf4j-api\1.7.32\slf4j-api-1.7.32.jar;C:\develop\Maven\repository\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;C:\develop\Maven\repository\org\apache\flink\flink-shaded-force-shading\15.0\flink-shaded-force-shading-15.0.jar;C:\develop\Maven\repository\org\apache\flink\flink-clients\1.16.1\flink-clients-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-optimizer\1.16.1\flink-optimizer-1.16.1.jar;C:\develop\Maven\repository\commons-cli\commons-cli\1.5.0\commons-cli-1.5.0.jar;C:\develop\Maven\repository\org\apache\flink\flink-runtime-web\1.16.1\flink-runtime-web-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-shaded-netty\4.1.70.Final-15.0\flink-shaded-netty-4.1.70.Final-15.0.jar;C:\develop\Maven\repository\org\apache\flink\flink-shaded-jackson\2.12.4-15.0\flink-shaded-jackson-2.12.4-15.0.jar;C:\develop\Maven\repository\org\slf4j\slf4j-log4j12\1.7.25\slf4j-log4j12-1.7.25.jar;C:\develop\Maven\repository\log4j\log4j\1.2.17\log4j-1.2.17.jar;C:\develop\Maven\repository\org\apache\flink\flink-connector-files\1.16.1\flink-connector-files-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-statebackend-rocksdb\1.16.1\flink-statebackend-rocksdb-1.16.1.jar;C:\develop\Maven\repository\com\ververica\frocksdbjni\6.20.3-ververica-1.0\frocksdbjni-6.20.3-ververica-1.0.jar;C:\develop\Maven\repository\org\apache\flink\flink-table-api-java-bridge\1.16.1\flink-table-api-java-bridge-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-table-api-java\1.16.1\flink-table-api-java-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-table-api-bridge-base\1.16.1\flink-table-api-bridge-base-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-table-planner-loader\1.16.1\flink-table-planner-loader-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-table-runtime\1.16.1\flink-table-runtime-1.16.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-table-common\1.16.1\flink-table-common-1.16.1.jar;C:\develop\Maven\repository\com\ibm\icu\icu4j\67.1\icu4j-67.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-cep\1.16.1\flink-cep-1.16.1.jar;C:\develop\Maven\repository\com\oceanbase\oblogclient-logproxy\1.1.0\oblogclient-logproxy-1.1.0.jar;C:\develop\Maven\repository\com\oceanbase\oblogclient-common\1.1.0\oblogclient-common-1.1.0.jar;C:\develop\Maven\repository\commons-codec\commons-codec\1.15\commons-codec-1.15.jar;C:\develop\Maven\repository\io\netty\netty-all\4.1.77.Final\netty-all-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-buffer\4.1.77.Final\netty-buffer-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec\4.1.77.Final\netty-codec-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-dns\4.1.77.Final\netty-codec-dns-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-haproxy\4.1.77.Final\netty-codec-haproxy-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-http\4.1.77.Final\netty-codec-http-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-http2\4.1.77.Final\netty-codec-http2-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-memcache\4.1.77.Final\netty-codec-memcache-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-mqtt\4.1.77.Final\netty-codec-mqtt-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-redis\4.1.77.Final\netty-codec-redis-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-smtp\4.1.77.Final\netty-codec-smtp-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-socks\4.1.77.Final\netty-codec-socks-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-stomp\4.1.77.Final\netty-codec-stomp-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-codec-xml\4.1.77.Final\netty-codec-xml-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-common\4.1.77.Final\netty-common-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-handler\4.1.77.Final\netty-handler-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-handler-proxy\4.1.77.Final\netty-handler-proxy-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-resolver\4.1.77.Final\netty-resolver-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-resolver-dns\4.1.77.Final\netty-resolver-dns-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-transport\4.1.77.Final\netty-transport-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-transport-rxtx\4.1.77.Final\netty-transport-rxtx-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-transport-sctp\4.1.77.Final\netty-transport-sctp-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-transport-udt\4.1.77.Final\netty-transport-udt-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-transport-classes-epoll\4.1.77.Final\netty-transport-classes-epoll-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-transport-native-unix-common\4.1.77.Final\netty-transport-native-unix-common-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-transport-classes-kqueue\4.1.77.Final\netty-transport-classes-kqueue-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-resolver-dns-classes-macos\4.1.77.Final\netty-resolver-dns-classes-macos-4.1.77.Final.jar;C:\develop\Maven\repository\io\netty\netty-transport-native-epoll\4.1.77.Final\netty-transport-native-epoll-4.1.77.Final-linux-x86_64.jar;C:\develop\Maven\repository\io\netty\netty-transport-native-epoll\4.1.77.Final\netty-transport-native-epoll-4.1.77.Final-linux-aarch_64.jar;C:\develop\Maven\repository\io\netty\netty-transport-native-kqueue\4.1.77.Final\netty-transport-native-kqueue-4.1.77.Final-osx-x86_64.jar;C:\develop\Maven\repository\io\netty\netty-transport-native-kqueue\4.1.77.Final\netty-transport-native-kqueue-4.1.77.Final-osx-aarch_64.jar;C:\develop\Maven\repository\io\netty\netty-resolver-dns-native-macos\4.1.77.Final\netty-resolver-dns-native-macos-4.1.77.Final-osx-x86_64.jar;C:\develop\Maven\repository\io\netty\netty-resolver-dns-native-macos\4.1.77.Final\netty-resolver-dns-native-macos-4.1.77.Final-osx-aarch_64.jar;C:\develop\Maven\repository\com\google\protobuf\protobuf-java\3.19.6\protobuf-java-3.19.6.jar;C:\develop\Maven\repository\com\starrocks\flink-connector-starrocks\1.2.7_flink-1.15\flink-connector-starrocks-1.2.7_flink-1.15.jar;C:\develop\Maven\repository\com\github\jsqlparser\jsqlparser\4.0\jsqlparser-4.0.jar;C:\develop\Maven\repository\com\ververica\flink-connector-oceanbase-cdc\2.3.0\flink-connector-oceanbase-cdc-2.3.0.jar;C:\develop\Maven\repository\com\ververica\flink-connector-debezium\2.3.0\flink-connector-debezium-2.3.0.jar;C:\develop\Maven\repository\io\debezium\debezium-api\1.6.4.Final\debezium-api-1.6.4.Final.jar;C:\develop\Maven\repository\io\debezium\debezium-embedded\1.6.4.Final\debezium-embedded-1.6.4.Final.jar;C:\develop\Maven\repository\io\debezium\debezium-core\1.6.4.Final\debezium-core-1.6.4.Final.jar;C:\develop\Maven\repository\com\fasterxml\jackson\core\jackson-core\2.10.5\jackson-core-2.10.5.jar;C:\develop\Maven\repository\com\fasterxml\jackson\core\jackson-databind\2.10.5.1\jackson-databind-2.10.5.1.jar;C:\develop\Maven\repository\com\fasterxml\jackson\core\jackson-annotations\2.10.5\jackson-annotations-2.10.5.jar;C:\develop\Maven\repository\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.10.5\jackson-datatype-jsr310-2.10.5.jar;C:\develop\Maven\repository\com\google\guava\guava\30.0-jre\guava-30.0-jre.jar;C:\develop\Maven\repository\com\google\guava\failureaccess\1.0.1\failureaccess-1.0.1.jar;C:\develop\Maven\repository\com\google\guava\listenablefuture\9999.0-empty-to-avoid-conflict-with-guava\listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar;C:\develop\Maven\repository\org\apache\kafka\connect-api\2.7.1\connect-api-2.7.1.jar;C:\develop\Maven\repository\org\apache\kafka\kafka-clients\2.7.1\kafka-clients-2.7.1.jar;C:\develop\Maven\repository\com\github\luben\zstd-jni\1.4.5-6\zstd-jni-1.4.5-6.jar;C:\develop\Maven\repository\javax\ws\rs\javax.ws.rs-api\2.1.1\javax.ws.rs-api-2.1.1.jar;C:\develop\Maven\repository\org\apache\kafka\connect-runtime\2.7.1\connect-runtime-2.7.1.jar;C:\develop\Maven\repository\org\apache\kafka\kafka-tools\2.7.1\kafka-tools-2.7.1.jar;C:\develop\Maven\repository\net\sourceforge\argparse4j\argparse4j\0.7.0\argparse4j-0.7.0.jar;C:\develop\Maven\repository\org\apache\kafka\connect-transforms\2.7.1\connect-transforms-2.7.1.jar;C:\develop\Maven\repository\com\fasterxml\jackson\jaxrs\jackson-jaxrs-json-provider\2.10.5\jackson-jaxrs-json-provider-2.10.5.jar;C:\develop\Maven\repository\com\fasterxml\jackson\jaxrs\jackson-jaxrs-base\2.10.5\jackson-jaxrs-base-2.10.5.jar;C:\develop\Maven\repository\com\fasterxml\jackson\module\jackson-module-jaxb-annotations\2.10.5\jackson-module-jaxb-annotations-2.10.5.jar;C:\develop\Maven\repository\jakarta\xml\bind\jakarta.xml.bind-api\2.3.2\jakarta.xml.bind-api-2.3.2.jar;C:\develop\Maven\repository\jakarta\activation\jakarta.activation-api\1.2.1\jakarta.activation-api-1.2.1.jar;C:\develop\Maven\repository\org\glassfish\jersey\containers\jersey-container-servlet\2.31\jersey-container-servlet-2.31.jar;C:\develop\Maven\repository\org\glassfish\jersey\containers\jersey-container-servlet-core\2.31\jersey-container-servlet-core-2.31.jar;C:\develop\Maven\repository\org\glassfish\hk2\external\jakarta.inject\2.6.1\jakarta.inject-2.6.1.jar;C:\develop\Maven\repository\jakarta\ws\rs\jakarta.ws.rs-api\2.1.6\jakarta.ws.rs-api-2.1.6.jar;C:\develop\Maven\repository\org\glassfish\jersey\inject\jersey-hk2\2.31\jersey-hk2-2.31.jar;C:\develop\Maven\repository\org\glassfish\hk2\hk2-locator\2.6.1\hk2-locator-2.6.1.jar;C:\develop\Maven\repository\org\glassfish\hk2\external\aopalliance-repackaged\2.6.1\aopalliance-repackaged-2.6.1.jar;C:\develop\Maven\repository\org\glassfish\hk2\hk2-api\2.6.1\hk2-api-2.6.1.jar;C:\develop\Maven\repository\org\glassfish\hk2\hk2-utils\2.6.1\hk2-utils-2.6.1.jar;C:\develop\Maven\repository\javax\xml\bind\jaxb-api\2.3.0\jaxb-api-2.3.0.jar;C:\develop\Maven\repository\javax\activation\activation\1.1.1\activation-1.1.1.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-server\9.4.38.v20210224\jetty-server-9.4.38.v20210224.jar;C:\develop\Maven\repository\javax\servlet\javax.servlet-api\3.1.0\javax.servlet-api-3.1.0.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-http\9.4.38.v20210224\jetty-http-9.4.38.v20210224.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-io\9.4.38.v20210224\jetty-io-9.4.38.v20210224.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-servlet\9.4.38.v20210224\jetty-servlet-9.4.38.v20210224.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-security\9.4.38.v20210224\jetty-security-9.4.38.v20210224.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-util-ajax\9.4.38.v20210224\jetty-util-ajax-9.4.38.v20210224.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-servlets\9.4.38.v20210224\jetty-servlets-9.4.38.v20210224.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-continuation\9.4.38.v20210224\jetty-continuation-9.4.38.v20210224.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-util\9.4.38.v20210224\jetty-util-9.4.38.v20210224.jar;C:\develop\Maven\repository\org\eclipse\jetty\jetty-client\9.4.38.v20210224\jetty-client-9.4.38.v20210224.jar;C:\develop\Maven\repository\org\reflections\reflections\0.9.12\reflections-0.9.12.jar;C:\develop\Maven\repository\org\apache\maven\maven-artifact\3.6.3\maven-artifact-3.6.3.jar;C:\develop\Maven\repository\org\codehaus\plexus\plexus-utils\3.2.1\plexus-utils-3.2.1.jar;C:\develop\Maven\repository\org\apache\kafka\connect-json\2.7.1\connect-json-2.7.1.jar;C:\develop\Maven\repository\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.10.5\jackson-datatype-jdk8-2.10.5.jar;C:\develop\Maven\repository\org\apache\kafka\connect-file\2.7.1\connect-file-2.7.1.jar;C:\develop\Maven\repository\com\oceanbase\logclient\logproxy-client\1.0.6\logproxy-client-1.0.6.jar;C:\develop\Maven\repository\com\oceanbase\logclient\common\1.0.6\common-1.0.6.jar;C:\develop\Maven\repository\org\awaitility\awaitility\4.0.1\awaitility-4.0.1.jar;C:\develop\Maven\repository\org\hamcrest\hamcrest\2.1\hamcrest-2.1.jar;C:\develop\Maven\repository\org\apache\flink\flink-connector-jdbc\1.16.1\flink-connector-jdbc-1.16.1.jar;C:\develop\Maven\repository\mysql\mysql-connector-java\5.1.47\mysql-connector-java-5.1.47.jar;C:\develop\Maven\repository\org\apache\logging\log4j\log4j-to-slf4j\2.14.0\log4j-to-slf4j-2.14.0.jar;C:\develop\Maven\repository\org\apache\logging\log4j\log4j-api\2.14.0\log4j-api-2.14.0.jar;C:\develop\Maven\repository\org\projectlombok\lombok\1.18.20\lombok-1.18.20.jar;C:\develop\Maven\repository\com\alibaba\druid\1.1.16\druid-1.1.16.jar com.wxt.app.ods.CdcToStarRocks 2023-07-27 13:59:42,830 INFO com.starrocks.connector.flink.manager.StarRocksQueryVisitor - StarRocks version: [3.0.0 48f4d81]. 2023-07-27 13:59:42,863 INFO com.starrocks.data.load.stream.StarRocksVersion - Successful to parse starrocks version 3.0.0 48f4d81, StarRocksVersion{major=3, minor=0, patch=0} 2023-07-27 13:59:42,881 INFO com.starrocks.connector.flink.manager.FlushAndCommitStrategy - FlushAndCommitStrategy{expectDelayTime=1000, scanFrequency=50, ageThreshold=20, maxCacheBytes=67108864, enableAutoCommit=true, numAgeTriggerFlush=0, numForceTriggerFlush=0} 2023-07-27 13:59:48,962 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils$LogFileLocation - Log file environment variable 'log.file' is not set. 2023-07-27 13:59:48,963 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils$LogFileLocation - JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'web.log.path'. 2023-07-27 13:59:52,977 INFO com.starrocks.connector.flink.manager.StarRocksSinkManagerV2 - manager running, scanningFrequency : 50 2023-07-27 13:59:52,977 INFO com.starrocks.connector.flink.manager.StarRocksSinkManagerV2 - Flink-StarRocks-Sink-Manager start, enableAutoCommit: true, streamLoader: com.starrocks.data.load.stream.DefaultStreamLoader 2023-07-27 13:59:53,250 INFO com.starrocks.data.load.stream.DefaultStreamLoader - Default Stream Loader start, properties : {"connectTimeout":5000,"defaultTableProperties":{"chunkLimit":3221225472,"dataFormat":{},"database":"","enableUpsertDelete":false,"properties":{"db":"","table":""},"table":"","uniqueKey":"-"},"enableTransaction":false,"expectDelayTime":1000,"headers":{"format":"json","strip_outer_array":"true"},"ioThreadCount":2,"jdbcUrl":"jdbc:mysql://192.168.21.105:9030,192.168.21.106:9030,192.168.21.107:9030","loadUrls":["http://192.168.21.105:8030","http://192.168.21.106:8030","http://192.168.21.107:8030"],"maxCacheBytes":67108864,"oldThreshold":0.9,"opAutoProjectionInJson":true,"regionBufferRatio":0.6,"scanningFrequency":50,"socketTimeout":0,"starRocksVersion":{"major":3,"minor":0,"patch":0},"tablePropertiesMap":{},"username":"root","version":"3.0.0 48f4d81","waitForContinueTimeoutMs":10000,"writingThreshold":50,"youngThreshold":0.1}, defaultHeaders : [{"elements":[{"name":"json","parameterCount":0,"parameters":[]}],"name":"format","value":"json"},{"elements":[{"name":"Basic cm9vdDoxMjM0NTY","parameterCount":0,"parameters":[],"value":""}],"name":"Authorization","value":"Basic cm9vdDoxMjM0NTY="},{"elements":[{"name":"true","parameterCount":0,"parameters":[]}],"name":"strip_outer_array","value":"true"},{"elements":[{"name":"100-continue","parameterCount":0,"parameters":[]}],"name":"Expect","value":"100-continue"},{"elements":[{"name":"600","parameterCount":0,"parameters":[]}],"name":"timeout","value":"600"}] 2023-07-27 13:59:53,258 INFO com.starrocks.connector.flink.table.sink.StarRocksDynamicSinkFunctionV2 - Open sink function v2. GitInformation{gitBuildTime='2023-05-10T10:14:18+0800', gitCommitId='195d1d5f2c31bdb496f270daa797c193744f600c', gitCommitIdAbbrev='195d1d5', gitCommitTime='2023-05-05T11:42:03+0800'} 2023-07-27 13:59:53,580 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - initialize checkpoint 2023-07-27 13:59:53,615 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - Start to initial table whitelist 2023-07-27 13:59:54,843 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - Start readChangeRecords process 2023-07-27 13:59:54,855 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - LogProxyClient started 2023-07-27 13:59:54,855 INFO com.oceanbase.clogproxy.client.connection.ClientStream - Try to reconnect 2023-07-27 13:59:57,020 INFO com.oceanbase.clogproxy.client.connection.ClientStream - Reconnect successfully 2023-07-27 13:59:57,022 INFO com.oceanbase.clogproxy.client.connection.ClientHandler - ClientId: 10.0.28.113_17640_1690437580_1_test: rootserver_list=192.168.20.164:2882:2881, cluster_id=, cluster_user=root@test, cluster_password=******, , sys_user=, sys_password=******, tb_white_list=test.qnm_test1.test1|test.qnm_test.test1|test.qnm_test.test, tb_black_list=|, start_timestamp=0, start_timestamp_us=0, timezone=+00:00, working_mode=storage connecting LogProxy: 192.168.20.164:2983 2023-07-27 13:59:58,583 INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Connected to LogProxyServer, ip:192.168.20.164, version:2023-04-18_12:00:47 2023-07-27 14:09:10,663 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - LogProxyClient packet processing started 2023-07-27 14:09:10,665 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - Start to read snapshot from `qnm_test1`.`test1` oceanBaseDS >>>>>>> {"database":"qnm_test1","ts_sec":"-1","initial":{"score":22.000,"id":1},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} oceanBaseDS >>>>>>> {"database":"qnm_test1","ts_sec":"-1","initial":{"score":88.000,"id":2},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} 2023-07-27 14:09:10,976 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - Read snapshot from `qnm_test1`.`test1` finished 2023-07-27 14:09:10,976 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - Start to read snapshot from `qnm_test`.`test1` oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"score":22.000,"id":1},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"1","score":"22.000","description":"null","__op":"0"},"table":"test1"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"score":88.000,"id":2},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"2","score":"88.000","description":"null","__op":"0"},"table":"test1"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"score":222.000,"id":3},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"3","score":"222.000","description":"null","__op":"0"},"table":"test1"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"score":23.000,"id":4},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"4","score":"23.000","description":"null","__op":"0"},"table":"test1"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"score":45.000,"id":5},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"5","score":"45.000","description":"null","__op":"0"},"table":"test1"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"score":32434.000,"id":6},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"6","score":"32434.000","description":"null","__op":"0"},"table":"test1"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"score":2323.000,"id":7},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"7","score":"2323.000","description":"null","__op":"0"},"table":"test1"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"score":34.000,"id":8},"before":{},"after":{},"tenant":"test","table":"test1","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"8","score":"34.000","description":"null","__op":"0"},"table":"test1"} 2023-07-27 14:09:11,724 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - Read snapshot from `qnm_test`.`test1` finished 2023-07-27 14:09:11,724 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - Start to read snapshot from `qnm_test`.`test` oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"hanns","description":"ahhd","weight":11.000,"id":1},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"1","name":"hanns","description":"ahhd","weight":"11.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"hanns","description":"ahhd","weight":11.000,"id":2},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"2","name":"hanns","description":"ahhd","weight":"11.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"da","description":"handnan","weight":1.000,"id":6},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"6","name":"da","description":"handnan","weight":"1.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"ll","description":"xbasb","weight":1.000,"id":9},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"9","name":"ll","description":"xbasb","weight":"1.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"pp","description":"as","weight":2.000,"id":10},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"10","name":"pp","description":"as","weight":"2.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"hasnll","description":"xbasb","weight":1.000,"id":12},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"12","name":"hasnll","description":"xbasb","weight":"1.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"hasnll","description":"xbasb","weight":1.000,"id":14},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"14","name":"hasnll","description":"xbasb","weight":"1.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"hasnll","description":"xbasb","weight":1.000,"id":16},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"16","name":"hasnll","description":"xbasb","weight":"1.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"存储","description":"cc","weight":2.000,"id":17},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"17","name":"存储","description":"cc","weight":"2.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"dd","description":"dd","weight":12.000,"id":18},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"18","name":"dd","description":"dd","weight":"12.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"hanns","description":"ahhd","weight":11.000,"id":22},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"22","name":"hanns","description":"ahhd","weight":"11.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"eerre","description":"rre","weight":44.000,"id":23},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"23","name":"eerre","description":"rre","weight":"44.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"243","description":"3","weight":34.000,"id":24},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"24","name":"243","description":"3","weight":"34.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"dsf","description":"sdfsd","weight":43.000,"id":25},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"25","name":"dsf","description":"sdfsd","weight":"43.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"4343","description":"434","weight":3.000,"id":34},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"34","name":"4343","description":"434","weight":"3.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"ds","description":"sfs","weight":23.000,"id":35},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"35","name":"ds","description":"sfs","weight":"23.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"f","description":"f","weight":34.000,"id":41},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"41","name":"f","description":"f","weight":"34.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"33","description":"vv","weight":44.000,"id":42},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"42","name":"33","description":"vv","weight":"44.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"3","description":"df","weight":3.000,"id":44},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"44","name":"3","description":"df","weight":"3.000","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"ggggg","description":"aaaaaaaa","weight":11.222,"id":101},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"101","name":"ggggg","description":"aaaaaaaa","weight":"11.222","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"ggggg","description":"aaaaaaaa","weight":11.222,"id":102},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"102","name":"ggggg","description":"aaaaaaaa","weight":"11.222","__op":"0"},"table":"test"} oceanBaseDS >>>>>>> {"database":"qnm_test","ts_sec":"-1","initial":{"name":"12","description":"21","weight":12.000,"id":103},"before":{},"after":{},"tenant":"test","table":"test","operator_type":"ini"} tableProcessDS >>>>>>>>>>>> {"database":"qnm_test","data":{"id":"103","name":"12","description":"21","weight":"12.000","__op":"0"},"table":"test"} 2023-07-27 14:09:11,869 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - Read snapshot from `qnm_test`.`test` finished 2023-07-27 14:09:11,874 INFO io.debezium.jdbc.JdbcConnection - Connection gracefully closed 2023-07-27 14:09:11,874 INFO com.ververica.cdc.connectors.oceanbase.source.OceanBaseRichSourceFunction - Snapshot reading finished 2023-07-27 14:09:12,804 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Flush uniqueKey : qnm_test-test1, label : null, bytes : 478 2023-07-27 14:09:12,804 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Generate entity meta, db: qnm_test, table: test1, total rows : 8, entity rows : 8, entity bytes : 487 2023-07-27 14:09:12,994 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Flush uniqueKey : qnm_test-test, label : null, bytes : 1627 2023-07-27 14:09:12,994 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Generate entity meta, db: qnm_test, table: test, total rows : 22, entity rows : 22, entity bytes : 1650 2023-07-27 14:09:12,997 INFO com.starrocks.data.load.stream.DefaultStreamLoader - Stream loading, label : 6de9d0f6-1a9d-484c-ab90-1c614edfdf45, region : qnm_test-test1, request : PUT http://192.168.21.105:8030/api/qnm_test/test1/_stream_load HTTP/1.1 2023-07-27 14:09:14,613 INFO com.starrocks.data.load.stream.http.StreamLoadEntity - Entity write end, contentLength : 487, total : 487 2023-07-27 14:09:14,758 INFO com.starrocks.data.load.stream.DefaultStreamLoader - Stream load completed, label : 6de9d0f6-1a9d-484c-ab90-1c614edfdf45, database : qnm_test, table : test1, body : { "TxnId": 657000, "Label": "6de9d0f6-1a9d-484c-ab90-1c614edfdf45", "Status": "Success", "Message": "OK", "NumberTotalRows": 8, "NumberLoadedRows": 8, "NumberFilteredRows": 0, "NumberUnselectedRows": 0, "LoadBytes": 487, "LoadTimeMs": 321, "BeginTxnTimeMs": 76, "StreamLoadPlanTimeMs": 75, "ReadDataTimeMs": 0, "WriteDataTimeMs": 131, "CommitAndPublishTimeMs": 37 } 2023-07-27 14:09:14,785 INFO com.starrocks.connector.flink.manager.StarRocksSinkManagerV2 - Receive load response, cacheByteBeforeFlush: 2105, currentCacheBytes: 1627, totalFlushRows : 8 2023-07-27 14:09:14,785 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Stream load flushed, db: qnm_test, table: test1, label : 6de9d0f6-1a9d-484c-ab90-1c614edfdf45 2023-07-27 14:09:14,788 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Stream load completed, db: qnm_test, table: test1, label : 6de9d0f6-1a9d-484c-ab90-1c614edfdf45 2023-07-27 14:09:14,819 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Success to commit transaction: Transaction{database='qnm_test', table='test1', label='6de9d0f6-1a9d-484c-ab90-1c614edfdf45', finish=false}, duration: 3097 ms 2023-07-27 14:09:15,193 WARN com.starrocks.data.load.stream.DefaultStreamLoader - Failed to connect to address:http://192.168.21.106:8030 java.net.ConnectException: Connection refused: connect at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method) at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.net.Socket.connect(Socket.java:589) at sun.net.NetworkClient.doConnect(NetworkClient.java:175) at sun.net.www.http.HttpClient.openServer(HttpClient.java:463) at sun.net.www.http.HttpClient.openServer(HttpClient.java:558) at sun.net.www.http.HttpClient.(HttpClient.java:242) at sun.net.www.http.HttpClient.New(HttpClient.java:339) at sun.net.www.http.HttpClient.New(HttpClient.java:357) at sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1220) at sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1156) at sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1050) at sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:984) at com.starrocks.data.load.stream.DefaultStreamLoader.testHttpConnection(DefaultStreamLoader.java:328) at com.starrocks.data.load.stream.DefaultStreamLoader.getAvailableHost(DefaultStreamLoader.java:314) at com.starrocks.data.load.stream.DefaultStreamLoader.send(DefaultStreamLoader.java:232) at com.starrocks.data.load.stream.DefaultStreamLoader.lambda$send$2(DefaultStreamLoader.java:120) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 2023-07-27 14:09:15,230 INFO com.starrocks.data.load.stream.DefaultStreamLoader - Stream loading, label : 160f9f6e-b1f9-41da-bfc6-831588400dcc, region : qnm_test-test, request : PUT http://192.168.21.107:8030/api/qnm_test/test/_stream_load HTTP/1.1 2023-07-27 14:09:15,466 INFO com.starrocks.data.load.stream.http.StreamLoadEntity - Entity write end, contentLength : 1650, total : 1650 2023-07-27 14:09:15,590 INFO com.starrocks.data.load.stream.DefaultStreamLoader - Stream load completed, label : 160f9f6e-b1f9-41da-bfc6-831588400dcc, database : qnm_test, table : test, body : { "TxnId": 657001, "Label": "160f9f6e-b1f9-41da-bfc6-831588400dcc", "Status": "Success", "Message": "OK", "NumberTotalRows": 22, "NumberLoadedRows": 22, "NumberFilteredRows": 0, "NumberUnselectedRows": 0, "LoadBytes": 1650, "LoadTimeMs": 158, "BeginTxnTimeMs": 1, "StreamLoadPlanTimeMs": 3, "ReadDataTimeMs": 0, "WriteDataTimeMs": 120, "CommitAndPublishTimeMs": 32 } 2023-07-27 14:09:15,592 INFO com.starrocks.connector.flink.manager.StarRocksSinkManagerV2 - Receive load response, cacheByteBeforeFlush: 1627, currentCacheBytes: 0, totalFlushRows : 30 2023-07-27 14:09:15,592 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Stream load flushed, db: qnm_test, table: test, label : 160f9f6e-b1f9-41da-bfc6-831588400dcc 2023-07-27 14:09:15,592 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Stream load completed, db: qnm_test, table: test, label : 160f9f6e-b1f9-41da-bfc6-831588400dcc 2023-07-27 14:09:15,600 INFO com.starrocks.connector.flink.manager.TransactionTableRegion - Success to commit transaction: Transaction{database='qnm_test', table='test', label='160f9f6e-b1f9-41da-bfc6-831588400dcc', finish=false}, duration: 3743 ms oceanBaseDS >>>>>>> {"database":"oms_cm","ts_sec":"1690437598","initial":{},"before":{"gmt_create":"2023-07-26 10:02:30","full_check_book":"0","resource_group_id":"1","gmt_modified":"2023-07-27 13:59:21","store_usage":"0","jdbc_writer_book":"0","metaq_writer_limit":"-1","congo_book":"0","store_limit":"-1","cpu_limit":"-1","id":"1000001","ip":"192.168.21.108","full_check_limit":"-1","store_book":"0","congo_usage":"0","version":"2","host_status":"ONLINE","jdbc_writer_limit":"-1","metaq_writer_usage":"0","jdbc_writer_usage":"0","metaq_writer_book":"0","full_check_usage":"1","congo_limit":"-1","cpu_usage":"0","cpu_book":"0"},"after":{"gmt_create":"2023-07-26 10:02:30","full_check_book":"0","resource_group_id":"1","gmt_modified":"2023-07-27 13:59:56","store_usage":"0","jdbc_writer_book":"0","metaq_writer_limit":"-1","congo_book":"0","store_limit":"-1","cpu_limit":"-1","id":"1000001","ip":"192.168.21.108","full_check_limit":"-1","store_book":"0","congo_usage":"0","version":"2","host_status":"ONLINE","jdbc_writer_limit":"-1","metaq_writer_usage":"0","jdbc_writer_usage":"0","metaq_writer_book":"0","full_check_usage":"1","congo_limit":"-1","cpu_usage":"0","cpu_book":"0"},"tenant":"test","table":"host","operator_type":"u"} oceanBaseDS >>>>>>> {"database":"oms_cm_heartbeat","ts_sec":"1690437598","initial":{},"before":{},"after":{"id":"8010259","gmt_modified":"2023-07-27 14:00:00","gmt_created":"2023-07-27 14:00:00"},"tenant":"test","table":"heatbeat_sequence","operator_type":"c"} oceanBaseDS >>>>>>> {"database":"oms_cm_heartbeat","ts_sec":"1690437598","initial":{},"before":{},"after":{"id":"8010260","gmt_modified":"2023-07-27 14:00:01","gmt_created":"2023-07-27 14:00:01"},"tenant":"test","table":"heatbeat_sequence","operator_type":"c"} oceanBaseDS >>>>>>> {"database":"oms_cm_heartbeat","ts_sec":"1690437598","initial":{},"before":{},"after":{"id":"8010261","gmt_modified":"2023-07-27 14:00:11","gmt_created":"2023-07-27 14:00:11"},"tenant":"test","table":"heatbeat_sequence","operator_type":"c"} oceanBaseDS >>>>>>> {"database":"oms_cm_heartbeat","ts_sec":"1690437598","initial":{},"before":{},"after":{"id":"8010262","gmt_modified":"2023-07-27 14:00:11","gmt_created":"2023-07-27 14:00:11"},"tenant":"test","table":"heatbeat_sequence","operator_type":"c"}