Skipping 2,587 KB..
Full LogTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTestTest
PASS
coverage: 2.4% of statements in github.com/pingcap/tiflow/...
+ set +x
[Thu May 16 18:36:56 CST 2024] <<<<<< START kafka consumer in multi_source case >>>>>>
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03e817280014 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:40937, start at 2024-05-16 18:37:00.280496848 +0800 CST m=+5.306162511 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:39:00.287 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:37:00.285 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:27:00.285 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
[2024/05/16 18:37:01.346 +08:00] [INFO] [main.go:86] ["running ddl test: 0 createDropSchemaDDL"]
[2024/05/16 18:37:01.876 +08:00] [INFO] [main.go:220] ["0 insert success: 100"]
[2024/05/16 18:37:02.662 +08:00] [INFO] [main.go:220] ["0 insert success: 200"]
[2024/05/16 18:37:02.665 +08:00] [INFO] [main.go:234] ["0 delete success: 100"]
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03e817280014 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:40937, start at 2024-05-16 18:37:00.280496848 +0800 CST m=+5.306162511 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:39:00.287 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:37:00.285 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:27:00.285 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
Verifying Downstream TiDB is started...
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03e818d00011 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:41018, start at 2024-05-16 18:37:00.361157916 +0800 CST m=+5.333478362 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:39:00.369 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:37:00.340 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:27:00.340 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
Starting Upstream TiFlash...
TiFlash
Release Version: v8.2.0-alpha-28-g961f9dded
Edition: Community
Git Commit Hash: 961f9dded38b814bb41b33c691ab58f3f090a0d9
Git Branch: HEAD
UTC Build Time: 2024-05-15 03:49:49
Enable Features: jemalloc sm4(GmSSL) avx2 avx512 unwind thinlto
Profile: RELWITHDEBINFO
Compiler: clang++ 13.0.0
Raft Proxy
Git Commit Hash: 7dc50b4eb06124e31f03adb06c20ff7ab61c5f79
Git Commit Branch: HEAD
UTC Build Time: 2024-05-15 03:53:57
Rust Version: rustc 1.67.0-nightly (96ddd32c4 2022-11-14)
Storage Engine: tiflash
Prometheus Prefix: tiflash_proxy_
Profile: release
Enable Features: external-jemalloc portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine cloud-aws cloud-gcp cloud-azure openssl-vendored portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine cloud-aws cloud-gcp cloud-azure openssl-vendored
Verifying Upstream TiFlash is started...
Logging trace to /tmp/tidb_cdc_test/open_protocol_handle_key_only/tiflash/log/server.log
Logging errors to /tmp/tidb_cdc_test/open_protocol_handle_key_only/tiflash/log/error.log
arg matches is ArgMatches { args: {"engine-addr": MatchedArg { occurs: 1, indices: [2], vals: ["127.0.0.1:9500"] }, "config": MatchedArg { occurs: 1, indices: [8], vals: ["/tmp/tidb_cdc_test/open_protocol_handle_key_only/tiflash-proxy.toml"] }, "addr": MatchedArg { occurs: 1, indices: [20], vals: ["127.0.0.1:9000"] }, "advertise-addr": MatchedArg { occurs: 1, indices: [4], vals: ["127.0.0.1:9000"] }, "pd-endpoints": MatchedArg { occurs: 1, indices: [16], vals: ["127.0.0.1:2379"] }, "engine-label": MatchedArg { occurs: 1, indices: [14], vals: ["tiflash"] }, "engine-git-hash": MatchedArg { occurs: 1, indices: [10], vals: ["961f9dded38b814bb41b33c691ab58f3f090a0d9"] }, "log-file": MatchedArg { occurs: 1, indices: [18], vals: ["/tmp/tidb_cdc_test/open_protocol_handle_key_only/tiflash/log/proxy.log"] }, "data-dir": MatchedArg { occurs: 1, indices: [6], vals: ["/tmp/tidb_cdc_test/open_protocol_handle_key_only/tiflash/db/proxy"] }, "engine-version": MatchedArg { occurs: 1, indices: [12], vals: ["v8.2.0-alpha-28-g961f9dded"] }}, subcommand: None, usage: Some("USAGE:\n TiFlash Proxy [FLAGS] [OPTIONS] --engine-git-hash <engine-git-hash> --engine-label <engine-label> --engine-version <engine-version>") }
[2024/05/16 18:37:03.446 +08:00] [INFO] [main.go:220] ["0 insert success: 300"]
[2024/05/16 18:37:03.926 +08:00] [INFO] [main.go:220] ["0 insert success: 400"]
[2024/05/16 18:37:03.932 +08:00] [INFO] [main.go:234] ["0 delete success: 200"]
[2024/05/16 18:37:04.682 +08:00] [INFO] [main.go:220] ["0 insert success: 500"]
[2024/05/16 18:37:05.158 +08:00] [INFO] [main.go:220] ["0 insert success: 600"]
[2024/05/16 18:37:05.161 +08:00] [INFO] [main.go:234] ["0 delete success: 300"]
+ pd_host=127.0.0.1
+ pd_port=2379
+ is_tls=false
+ '[' false == true ']'
++ run_cdc_cli tso query --pd=http://127.0.0.1:2379
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.open_protocol_handle_key_only.cli.42348.out cli tso query --pd=http://127.0.0.1:2379
[2024/05/16 18:37:05.935 +08:00] [INFO] [main.go:220] ["0 insert success: 700"]
+ set +x
+ tso='449801309541892097
PASS
coverage: 1.8% of statements in github.com/pingcap/tiflow/...'
+ echo 449801309541892097 PASS coverage: 1.8% of statements in github.com/pingcap/tiflow/...
+ awk -F ' ' '{print $1}'
+ set +x
[Thu May 16 18:37:07 CST 2024] <<<<<< START cdc server in open_protocol_handle_key_only case >>>>>>
+ [[ '' == \t\r\u\e ]]
+ set +e
+ get_info_fail_msg='failed to get info:'
+ etcd_info_msg='etcd info'
+ '[' -z '' ']'
+ curl_status_cmd='curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL'
+ GO_FAILPOINTS=
+ [[ no != \n\o ]]
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.open_protocol_handle_key_only.4238242384.out server --log-file /tmp/tidb_cdc_test/open_protocol_handle_key_only/cdc.log --log-level debug --data-dir /tmp/tidb_cdc_test/open_protocol_handle_key_only/cdc_data --cluster-id default
+ (( i = 0 ))
+ (( i <= 50 ))
++ curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL
* About to connect() to 127.0.0.1 port 8300 (#0)
* Trying 127.0.0.1...
* Connection refused
* Failed connect to 127.0.0.1:8300; Connection refused
* Closing connection 0
+ res=
+ echo ''
+ grep -q 'failed to get info:'
+ echo ''
+ grep -q 'etcd info'
+ '[' 0 -eq 50 ']'
+ sleep 3
+ (( i++ ))
+ (( i <= 50 ))
++ curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL
* About to connect() to 127.0.0.1 port 8300 (#0)
* Trying 127.0.0.1...
* Connected to 127.0.0.1 (127.0.0.1) port 8300 (#0)
* Server auth using Basic with user 'ticdc'
> GET /debug/info HTTP/1.1
> Authorization: Basic dGljZGM6dGljZGNfc2VjcmV0
> User-Agent: curl/7.29.0
> Host: 127.0.0.1:8300
> Accept: */*
>
< HTTP/1.1 200 OK
< Date: Thu, 16 May 2024 10:37:10 GMT
< Content-Length: 815
< Content-Type: text/plain; charset=utf-8
<
{ [data not shown]
* Connection #0 to host 127.0.0.1 left intact
+ res='
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/1dc1c4f4-fb09-4852-92f5-a0e23a290675
{"id":"1dc1c4f4-fb09-4852-92f5-a0e23a290675","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855827}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80f9d971d5
1dc1c4f4-fb09-4852-92f5-a0e23a290675
/tidb/cdc/default/default/upstream/7369544595134613801
{"id":7369544595134613801,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ echo '
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/1dc1c4f4-fb09-4852-92f5-a0e23a290675
{"id":"1dc1c4f4-fb09-4852-92f5-a0e23a290675","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855827}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80f9d971d5
1dc1c4f4-fb09-4852-92f5-a0e23a290675
/tidb/cdc/default/default/upstream/7369544595134613801
{"id":7369544595134613801,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ grep -q 'failed to get info:'
+ echo '
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/1dc1c4f4-fb09-4852-92f5-a0e23a290675
{"id":"1dc1c4f4-fb09-4852-92f5-a0e23a290675","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855827}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80f9d971d5
1dc1c4f4-fb09-4852-92f5-a0e23a290675
/tidb/cdc/default/default/upstream/7369544595134613801
{"id":7369544595134613801,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ grep -q 'etcd info'
+ break
+ set +x
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.open_protocol_handle_key_only.cli.42450.out cli changefeed create --start-ts=449801309541892097 '--sink-uri=kafka://127.0.0.1:9092/open-protocol-handle-key-only?protocol=open-protocol&max-message-bytes=800&kafka-version=2.4.1' --config=/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/open_protocol_handle_key_only/conf/changefeed.toml
Create changefeed successfully!
ID: 48f77f41-7dad-4b57-a29a-6c6c68bdc19f
Info: {"upstream_id":7369544595134613801,"namespace":"default","id":"48f77f41-7dad-4b57-a29a-6c6c68bdc19f","sink_uri":"kafka://127.0.0.1:9092/open-protocol-handle-key-only?protocol=open-protocol\u0026max-message-bytes=800\u0026kafka-version=2.4.1","create_time":"2024-05-16T18:37:10.628691899+08:00","start_ts":449801309541892097,"config":{"memory_quota":1073741824,"case_sensitive":false,"force_replicate":false,"ignore_ineligible_table":false,"check_gc_safe_point":true,"enable_sync_point":false,"enable_table_monitor":false,"bdr_mode":false,"sync_point_interval":600000000000,"sync_point_retention":86400000000000,"filter":{"rules":["*.*"]},"mounter":{"worker_num":16},"sink":{"protocol":"open-protocol","csv":{"delimiter":",","quote":"\"","null":"\\N","include_commit_ts":false,"binary_encoding_method":"base64","output_old_value":false,"output_handle_key":false},"encoder_concurrency":32,"terminator":"\r\n","date_separator":"day","enable_partition_separator":true,"enable_kafka_sink_v2":false,"only_output_updated_columns":false,"delete_only_output_handle_key_columns":false,"content_compatible":false,"kafka_config":{"large_message_handle":{"large_message_handle_option":"handle-key-only","large_message_handle_compression":"lz4","claim_check_storage_uri":""}},"advance_timeout":150,"send_bootstrap_interval_in_sec":120,"send_bootstrap_in_msg_count":10000,"send_bootstrap_to_all_partition":true,"debezium_disable_schema":false,"debezium":{"output_old_value":true},"open":{"output_old_value":true}},"consistent":{"level":"none","max_log_size":64,"flush_interval":2000,"meta_flush_interval":200,"encoding_worker_num":16,"flush_worker_num":8,"use_file_backend":false,"memory_usage":{"memory_quota_percentage":50}},"scheduler":{"enable_table_across_nodes":false,"region_threshold":100000,"write_key_threshold":0},"integrity":{"integrity_check_level":"none","corruption_handle_level":"warn"},"changefeed_error_stuck_duration":1800000000000,"synced_status":{"synced_check_interval":300,"checkpoint_interval":15}},"state":"normal","creator_version":"v8.2.0-alpha-46-g6ee8257c6","resolved_ts":449801309541892097,"checkpoint_ts":449801309541892097,"checkpoint_time":"2024-05-16 18:37:05.584"}
PASS
coverage: 2.5% of statements in github.com/pingcap/tiflow/...
+ set +x
table test.finish_mark not exists for 1-th check, retry later
[2024/05/16 18:37:11.432 +08:00] [INFO] [main.go:86] ["running ddl test: 1 truncateDDL"]
[2024/05/16 18:37:11.673 +08:00] [INFO] [main.go:220] ["0 insert success: 100"]
[2024/05/16 18:37:11.685 +08:00] [INFO] [main.go:220] ["1 insert success: 100"]
[2024/05/16 18:37:12.553 +08:00] [INFO] [main.go:220] ["1 insert success: 200"]
[2024/05/16 18:37:12.555 +08:00] [INFO] [main.go:234] ["1 delete success: 100"]
[2024/05/16 18:37:12.564 +08:00] [INFO] [main.go:220] ["0 insert success: 200"]
[2024/05/16 18:37:12.566 +08:00] [INFO] [main.go:234] ["0 delete success: 100"]
[2024/05/16 18:37:12.724 +08:00] [INFO] [main.go:220] ["1 insert success: 300"]
[2024/05/16 18:37:12.758 +08:00] [INFO] [main.go:220] ["0 insert success: 300"]
[2024/05/16 18:37:12.902 +08:00] [INFO] [main.go:220] ["1 insert success: 400"]
[2024/05/16 18:37:12.904 +08:00] [INFO] [main.go:234] ["1 delete success: 200"]
[2024/05/16 18:37:12.955 +08:00] [INFO] [main.go:220] ["0 insert success: 400"]
[2024/05/16 18:37:12.957 +08:00] [INFO] [main.go:234] ["0 delete success: 200"]
[2024/05/16 18:37:13.080 +08:00] [INFO] [main.go:220] ["1 insert success: 500"]
[2024/05/16 18:37:13.164 +08:00] [INFO] [main.go:220] ["0 insert success: 500"]
[2024/05/16 18:37:13.263 +08:00] [INFO] [main.go:220] ["1 insert success: 600"]
[2024/05/16 18:37:13.264 +08:00] [INFO] [main.go:234] ["1 delete success: 300"]
[2024/05/16 18:37:13.415 +08:00] [INFO] [main.go:220] ["0 insert success: 600"]
[2024/05/16 18:37:13.421 +08:00] [INFO] [main.go:234] ["0 delete success: 300"]
[2024/05/16 18:37:13.487 +08:00] [INFO] [main.go:220] ["1 insert success: 700"]
[2024/05/16 18:37:13.606 +08:00] [INFO] [main.go:220] ["0 insert success: 700"]
[2024/05/16 18:37:13.730 +08:00] [INFO] [main.go:220] ["1 insert success: 800"]
[2024/05/16 18:37:13.732 +08:00] [INFO] [main.go:234] ["1 delete success: 400"]
[2024/05/16 18:37:13.808 +08:00] [INFO] [main.go:220] ["0 insert success: 800"]
[2024/05/16 18:37:13.819 +08:00] [INFO] [main.go:234] ["0 delete success: 400"]
table test.finish_mark not exists for 2-th check, retry later
[2024/05/16 18:37:13.925 +08:00] [INFO] [main.go:220] ["1 insert success: 900"]
[2024/05/16 18:37:14.003 +08:00] [INFO] [main.go:220] ["0 insert success: 900"]
[2024/05/16 18:37:14.114 +08:00] [INFO] [main.go:220] ["1 insert success: 1000"]
[2024/05/16 18:37:14.116 +08:00] [INFO] [main.go:234] ["1 delete success: 500"]
[2024/05/16 18:37:14.191 +08:00] [INFO] [main.go:220] ["0 insert success: 1000"]
[2024/05/16 18:37:14.203 +08:00] [INFO] [main.go:234] ["0 delete success: 500"]
[2024/05/16 18:37:14.305 +08:00] [INFO] [main.go:220] ["1 insert success: 1100"]
[2024/05/16 18:37:14.397 +08:00] [INFO] [main.go:220] ["0 insert success: 1100"]
[2024/05/16 18:37:14.500 +08:00] [INFO] [main.go:220] ["1 insert success: 1200"]
[2024/05/16 18:37:14.502 +08:00] [INFO] [main.go:234] ["1 delete success: 600"]
[2024/05/16 18:37:14.590 +08:00] [INFO] [main.go:220] ["0 insert success: 1200"]
[2024/05/16 18:37:14.599 +08:00] [INFO] [main.go:234] ["0 delete success: 600"]
[2024/05/16 18:37:14.694 +08:00] [INFO] [main.go:220] ["1 insert success: 1300"]
[2024/05/16 18:37:14.789 +08:00] [INFO] [main.go:220] ["0 insert success: 1300"]
[2024/05/16 18:37:14.879 +08:00] [INFO] [main.go:220] ["1 insert success: 1400"]
[2024/05/16 18:37:14.881 +08:00] [INFO] [main.go:234] ["1 delete success: 700"]
[2024/05/16 18:37:14.994 +08:00] [INFO] [main.go:220] ["0 insert success: 1400"]
[2024/05/16 18:37:15.004 +08:00] [INFO] [main.go:234] ["0 delete success: 700"]
[2024/05/16 18:37:15.081 +08:00] [INFO] [main.go:220] ["1 insert success: 1500"]
[2024/05/16 18:37:15.202 +08:00] [INFO] [main.go:220] ["0 insert success: 1500"]
[2024/05/16 18:37:15.277 +08:00] [INFO] [main.go:220] ["1 insert success: 1600"]
[2024/05/16 18:37:15.279 +08:00] [INFO] [main.go:234] ["1 delete success: 800"]
[2024/05/16 18:37:15.404 +08:00] [INFO] [main.go:220] ["0 insert success: 1600"]
[2024/05/16 18:37:15.415 +08:00] [INFO] [main.go:234] ["0 delete success: 800"]
[2024/05/16 18:37:15.472 +08:00] [INFO] [main.go:220] ["1 insert success: 1700"]
[2024/05/16 18:37:15.601 +08:00] [INFO] [main.go:220] ["0 insert success: 1700"]
[2024/05/16 18:37:15.671 +08:00] [INFO] [main.go:220] ["1 insert success: 1800"]
[2024/05/16 18:37:15.677 +08:00] [INFO] [main.go:234] ["1 delete success: 900"]
[2024/05/16 18:37:15.805 +08:00] [INFO] [main.go:220] ["0 insert success: 1800"]
[2024/05/16 18:37:15.816 +08:00] [INFO] [main.go:234] ["0 delete success: 900"]
[2024/05/16 18:37:15.879 +08:00] [INFO] [main.go:220] ["1 insert success: 1900"]
table test.finish_mark exists
check diff successfully
[2024/05/16 18:37:16.002 +08:00] [INFO] [main.go:220] ["0 insert success: 1900"]
[2024/05/16 18:37:16.073 +08:00] [INFO] [main.go:220] ["1 insert success: 2000"]
[2024/05/16 18:37:16.084 +08:00] [INFO] [main.go:234] ["1 delete success: 1000"]
[2024/05/16 18:37:16.193 +08:00] [INFO] [main.go:220] ["0 insert success: 2000"]
[2024/05/16 18:37:16.202 +08:00] [INFO] [main.go:234] ["0 delete success: 1000"]
wait process cdc.test exit for 1-th time...
[2024/05/16 18:37:16.276 +08:00] [INFO] [main.go:220] ["1 insert success: 2100"]
[2024/05/16 18:37:16.389 +08:00] [INFO] [main.go:220] ["0 insert success: 2100"]
wait process cdc.test exit for 2-th time...
++ curl -X GET http://127.0.0.1:8300/api/v2/changefeeds/test-1/synced
% Total % Received % Xferd Average Speed Time Time Time Current
Dload Upload Total Spent Left Speed
0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0
100 723 100 723 0 0 8113 0 --:--:-- --:--:-- --:--:-- 8123
+ synced_status='{"synced":false,"sink_checkpoint_ts":"2024-05-16 18:36:48.208","puller_resolved_ts":"1970-01-01 08:00:00.000","last_synced_ts":"1970-01-01 08:00:00.000","now_ts":"2024-05-16 18:37:14.000","info":"Please check whether PD is online and TiKV Regions are all available. If PD is offline or some TiKV regions are not available, it means that the data syncing process is complete. To check whether TiKV regions are all available, you can view '\''TiKV-Details'\'' \u003e '\''Resolved-Ts'\'' \u003e '\''Max Leader Resolved TS gap'\'' on Grafana. If the gap is large, such as a few minutes, it means that some regions in TiKV are unavailable. Otherwise, if the gap is small and PD is online, it means the data syncing is incomplete, so please wait"}'
++ echo '{"synced":false,"sink_checkpoint_ts":"2024-05-16' '18:36:48.208","puller_resolved_ts":"1970-01-01' '08:00:00.000","last_synced_ts":"1970-01-01' '08:00:00.000","now_ts":"2024-05-16' '18:37:14.000","info":"Please' check whether PD is online and TiKV Regions are all available. If PD is offline or some TiKV regions are not available, it means that the data syncing process is complete. To check whether TiKV regions are all available, you can view ''\''TiKV-Details'\''' '\u003e' ''\''Resolved-Ts'\''' '\u003e' ''\''Max' Leader Resolved TS 'gap'\''' on Grafana. If the gap is large, such as a few minutes, it means that some regions in TiKV are unavailable. Otherwise, if the gap is small and PD is online, it means the data syncing is incomplete, so please 'wait"}'
++ jq .synced
+ status=false
+ '[' false '!=' false ']'
++ echo '{"synced":false,"sink_checkpoint_ts":"2024-05-16' '18:36:48.208","puller_resolved_ts":"1970-01-01' '08:00:00.000","last_synced_ts":"1970-01-01' '08:00:00.000","now_ts":"2024-05-16' '18:37:14.000","info":"Please' check whether PD is online and TiKV Regions are all available. If PD is offline or some TiKV regions are not available, it means that the data syncing process is complete. To check whether TiKV regions are all available, you can view ''\''TiKV-Details'\''' '\u003e' ''\''Resolved-Ts'\''' '\u003e' ''\''Max' Leader Resolved TS 'gap'\''' on Grafana. If the gap is large, such as a few minutes, it means that some regions in TiKV are unavailable. Otherwise, if the gap is small and PD is online, it means the data syncing is incomplete, so please 'wait"}'
++ jq -r .info
+ info='Please check whether PD is online and TiKV Regions are all available. If PD is offline or some TiKV regions are not available, it means that the data syncing process is complete. To check whether TiKV regions are all available, you can view '\''TiKV-Details'\'' > '\''Resolved-Ts'\'' > '\''Max Leader Resolved TS gap'\'' on Grafana. If the gap is large, such as a few minutes, it means that some regions in TiKV are unavailable. Otherwise, if the gap is small and PD is online, it means the data syncing is incomplete, so please wait'
+ target_message='Please check whether PD is online and TiKV Regions are all available. If PD is offline or some TiKV regions are not available, it means that the data syncing process is complete. To check whether TiKV regions are all available, you can view '\''TiKV-Details'\'' > '\''Resolved-Ts'\'' > '\''Max Leader Resolved TS gap'\'' on Grafana. If the gap is large, such as a few minutes, it means that some regions in TiKV are unavailable. Otherwise, if the gap is small and PD is online, it means the data syncing is incomplete, so please wait'
+ '[' 'Please check whether PD is online and TiKV Regions are all available. If PD is offline or some TiKV regions are not available, it means that the data syncing process is complete. To check whether TiKV regions are all available, you can view '\''TiKV-Details'\'' > '\''Resolved-Ts'\'' > '\''Max Leader Resolved TS gap'\'' on Grafana. If the gap is large, such as a few minutes, it means that some regions in TiKV are unavailable. Otherwise, if the gap is small and PD is online, it means the data syncing is incomplete, so please wait' '!=' 'Please check whether PD is online and TiKV Regions are all available. If PD is offline or some TiKV regions are not available, it means that the data syncing process is complete. To check whether TiKV regions are all available, you can view '\''TiKV-Details'\'' > '\''Resolved-Ts'\'' > '\''Max Leader Resolved TS gap'\'' on Grafana. If the gap is large, such as a few minutes, it means that some regions in TiKV are unavailable. Otherwise, if the gap is small and PD is online, it means the data syncing is incomplete, so please wait' ']'
+ export GO_FAILPOINTS=
+ GO_FAILPOINTS=
+ cleanup_process cdc.test
wait process cdc.test exit for 1-th time...
wait process cdc.test exit for 2-th time...
wait process cdc.test exit for 3-th time...
process cdc.test already exit
+ stop_tidb_cluster
[90m6:37PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/connector_test_ro.sql
cdc.test: no process found
wait process cdc.test exit for 3-th time...
process cdc.test already exit
[Thu May 16 18:37:17 CST 2024] <<<<<< run test case open_protocol_handle_key_only success! >>>>>>
[2024/05/16 18:37:21.627 +08:00] [INFO] [main.go:86] ["running ddl test: 2 addDropColumnDDL"]
[2024/05/16 18:37:21.868 +08:00] [INFO] [main.go:220] ["0 insert success: 100"]
[2024/05/16 18:37:21.900 +08:00] [INFO] [main.go:220] ["1 insert success: 100"]
[2024/05/16 18:37:22.094 +08:00] [INFO] [main.go:220] ["0 insert success: 200"]
[2024/05/16 18:37:22.096 +08:00] [INFO] [main.go:234] ["0 delete success: 100"]
[2024/05/16 18:37:22.121 +08:00] [INFO] [main.go:220] ["1 insert success: 200"]
[2024/05/16 18:37:22.124 +08:00] [INFO] [main.go:234] ["1 delete success: 100"]
[2024/05/16 18:37:22.305 +08:00] [INFO] [main.go:220] ["0 insert success: 300"]
[2024/05/16 18:37:22.342 +08:00] [INFO] [main.go:220] ["1 insert success: 300"]
[2024/05/16 18:37:22.527 +08:00] [INFO] [main.go:220] ["0 insert success: 400"]
[2024/05/16 18:37:22.529 +08:00] [INFO] [main.go:234] ["0 delete success: 200"]
[2024/05/16 18:37:22.564 +08:00] [INFO] [main.go:220] ["1 insert success: 400"]
[2024/05/16 18:37:22.566 +08:00] [INFO] [main.go:234] ["1 delete success: 200"]
[2024/05/16 18:37:22.733 +08:00] [INFO] [main.go:220] ["0 insert success: 500"]
[2024/05/16 18:37:22.790 +08:00] [INFO] [main.go:220] ["1 insert success: 500"]
[2024/05/16 18:37:22.983 +08:00] [INFO] [main.go:220] ["0 insert success: 600"]
[2024/05/16 18:37:22.986 +08:00] [INFO] [main.go:234] ["0 delete success: 300"]
[2024/05/16 18:37:23.047 +08:00] [INFO] [main.go:220] ["1 insert success: 600"]
[2024/05/16 18:37:23.050 +08:00] [INFO] [main.go:234] ["1 delete success: 300"]
[2024/05/16 18:37:23.229 +08:00] [INFO] [main.go:220] ["0 insert success: 700"]
[2024/05/16 18:37:23.301 +08:00] [INFO] [main.go:220] ["1 insert success: 700"]
[2024/05/16 18:37:23.473 +08:00] [INFO] [main.go:220] ["0 insert success: 800"]
[2024/05/16 18:37:23.475 +08:00] [INFO] [main.go:234] ["0 delete success: 400"]
[2024/05/16 18:37:23.536 +08:00] [INFO] [main.go:220] ["1 insert success: 800"]
[2024/05/16 18:37:23.538 +08:00] [INFO] [main.go:234] ["1 delete success: 400"]
[2024/05/16 18:37:23.703 +08:00] [INFO] [main.go:220] ["0 insert success: 900"]
[2024/05/16 18:37:23.754 +08:00] [INFO] [main.go:220] ["1 insert success: 900"]
[2024/05/16 18:37:23.923 +08:00] [INFO] [main.go:220] ["0 insert success: 1000"]
[2024/05/16 18:37:23.925 +08:00] [INFO] [main.go:234] ["0 delete success: 500"]
[2024/05/16 18:37:23.971 +08:00] [INFO] [main.go:220] ["1 insert success: 1000"]
[2024/05/16 18:37:23.974 +08:00] [INFO] [main.go:234] ["1 delete success: 500"]
[2024/05/16 18:37:24.142 +08:00] [INFO] [main.go:220] ["0 insert success: 1100"]
[2024/05/16 18:37:24.191 +08:00] [INFO] [main.go:220] ["1 insert success: 1100"]
[2024/05/16 18:37:24.357 +08:00] [INFO] [main.go:220] ["0 insert success: 1200"]
[2024/05/16 18:37:24.359 +08:00] [INFO] [main.go:234] ["0 delete success: 600"]
[2024/05/16 18:37:24.397 +08:00] [INFO] [main.go:220] ["1 insert success: 1200"]
[2024/05/16 18:37:24.400 +08:00] [INFO] [main.go:234] ["1 delete success: 600"]
[2024/05/16 18:37:24.564 +08:00] [INFO] [main.go:220] ["0 insert success: 1300"]
[2024/05/16 18:37:24.602 +08:00] [INFO] [main.go:220] ["1 insert success: 1300"]
[2024/05/16 18:37:24.777 +08:00] [INFO] [main.go:220] ["0 insert success: 1400"]
[2024/05/16 18:37:24.779 +08:00] [INFO] [main.go:234] ["0 delete success: 700"]
[2024/05/16 18:37:24.819 +08:00] [INFO] [main.go:220] ["1 insert success: 1400"]
[2024/05/16 18:37:24.821 +08:00] [INFO] [main.go:234] ["1 delete success: 700"]
[2024/05/16 18:37:24.982 +08:00] [INFO] [main.go:220] ["0 insert success: 1500"]
[2024/05/16 18:37:25.010 +08:00] [INFO] [main.go:220] ["1 insert success: 1500"]
[2024/05/16 18:37:25.197 +08:00] [INFO] [main.go:220] ["0 insert success: 1600"]
[2024/05/16 18:37:25.200 +08:00] [INFO] [main.go:234] ["0 delete success: 800"]
[2024/05/16 18:37:25.233 +08:00] [INFO] [main.go:220] ["1 insert success: 1600"]
[2024/05/16 18:37:25.235 +08:00] [INFO] [main.go:234] ["1 delete success: 800"]
[2024/05/16 18:37:25.413 +08:00] [INFO] [main.go:220] ["0 insert success: 1700"]
[2024/05/16 18:37:25.459 +08:00] [INFO] [main.go:220] ["1 insert success: 1700"]
[2024/05/16 18:37:25.621 +08:00] [INFO] [main.go:220] ["0 insert success: 1800"]
[2024/05/16 18:37:25.623 +08:00] [INFO] [main.go:234] ["0 delete success: 900"]
[2024/05/16 18:37:25.679 +08:00] [INFO] [main.go:220] ["1 insert success: 1800"]
[2024/05/16 18:37:25.681 +08:00] [INFO] [main.go:234] ["1 delete success: 900"]
[2024/05/16 18:37:25.808 +08:00] [INFO] [main.go:220] ["0 insert success: 1900"]
[2024/05/16 18:37:25.884 +08:00] [INFO] [main.go:220] ["1 insert success: 1900"]
[2024/05/16 18:37:25.980 +08:00] [INFO] [main.go:220] ["0 insert success: 2000"]
[2024/05/16 18:37:25.986 +08:00] [INFO] [main.go:234] ["0 delete success: 1000"]
[2024/05/16 18:37:26.091 +08:00] [INFO] [main.go:220] ["1 insert success: 2000"]
[2024/05/16 18:37:26.093 +08:00] [INFO] [main.go:234] ["1 delete success: 1000"]
[2024/05/16 18:37:26.178 +08:00] [INFO] [main.go:220] ["0 insert success: 2100"]
[2024/05/16 18:37:26.296 +08:00] [INFO] [main.go:220] ["1 insert success: 2100"]
[2024/05/16 18:37:26.366 +08:00] [INFO] [main.go:220] ["0 insert success: 2200"]
[2024/05/16 18:37:26.368 +08:00] [INFO] [main.go:234] ["0 delete success: 1100"]
[2024/05/16 18:37:26.477 +08:00] [INFO] [main.go:220] ["1 insert success: 2200"]
[2024/05/16 18:37:26.479 +08:00] [INFO] [main.go:234] ["1 delete success: 1100"]
[2024/05/16 18:37:26.556 +08:00] [INFO] [main.go:220] ["0 insert success: 2300"]
+ check_logs /tmp/tidb_cdc_test/synced_status
++ date
+ echo '[Thu May 16 18:37:26 CST 2024] <<<<<< run test case synced_status success! >>>>>>'
[Thu May 16 18:37:26 CST 2024] <<<<<< run test case synced_status success! >>>>>>
+ stop_tidb_cluster
/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/open_protocol_handle_key_only/run.sh: line 1: 42484 Killed cdc_kafka_consumer --upstream-uri $SINK_URI --downstream-uri="mysql://root@127.0.0.1:3306/?safe-mode=true&batch-dml-enable=false" --upstream-tidb-dsn="root@tcp(${UP_TIDB_HOST}:${UP_TIDB_PORT})/?" --config="$CUR/conf/changefeed.toml" 2>&1
=================>> Running test /home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/canal_json_claim_check/run.sh using Sink-Type: kafka... <<=================
The 1 times to try to start tidb cluster...
\033[0;36m<<< Run all test success >>>\033[0m
[Pipeline] }
Cache not saved (ws/jenkins-pingcap-tiflow-pull_cdc_integration_kafka_test-2008/tiflow-cdc already exists)
[Pipeline] // cache
[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // withCredentials
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[Pipeline] // container
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // podTemplate
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
start tidb cluster in /tmp/tidb_cdc_test/canal_json_claim_check
Starting Upstream PD...
Release Version: v8.2.0-alpha-31-g7e858178a
Edition: Community
Git Commit Hash: 7e858178a78b180f7dad83554053bbc3817e9f2e
Git Branch: master
UTC Build Time: 2024-05-16 09:50:16
Starting Downstream PD...
Release Version: v8.2.0-alpha-31-g7e858178a
Edition: Community
Git Commit Hash: 7e858178a78b180f7dad83554053bbc3817e9f2e
Git Branch: master
UTC Build Time: 2024-05-16 09:50:16
Verifying upstream PD is started...
[2024/05/16 18:37:31.947 +08:00] [INFO] [main.go:86] ["running ddl test: 3 addDropColumnDDL2"]
[2024/05/16 18:37:32.156 +08:00] [INFO] [main.go:220] ["0 insert success: 100"]
[2024/05/16 18:37:32.193 +08:00] [INFO] [main.go:220] ["1 insert success: 100"]
[2024/05/16 18:37:32.413 +08:00] [INFO] [main.go:234] ["0 delete success: 100"]
[2024/05/16 18:37:32.414 +08:00] [INFO] [main.go:220] ["0 insert success: 200"]
[2024/05/16 18:37:32.464 +08:00] [INFO] [main.go:234] ["1 delete success: 100"]
[2024/05/16 18:37:32.465 +08:00] [INFO] [main.go:220] ["1 insert success: 200"]
[2024/05/16 18:37:32.607 +08:00] [INFO] [main.go:220] ["0 insert success: 300"]
[2024/05/16 18:37:32.663 +08:00] [INFO] [main.go:220] ["1 insert success: 300"]
[2024/05/16 18:37:32.791 +08:00] [INFO] [main.go:234] ["0 delete success: 200"]
[2024/05/16 18:37:32.792 +08:00] [INFO] [main.go:220] ["0 insert success: 400"]
[2024/05/16 18:37:32.865 +08:00] [INFO] [main.go:234] ["1 delete success: 200"]
[2024/05/16 18:37:32.866 +08:00] [INFO] [main.go:220] ["1 insert success: 400"]
[2024/05/16 18:37:32.984 +08:00] [INFO] [main.go:220] ["0 insert success: 500"]
[2024/05/16 18:37:33.065 +08:00] [INFO] [main.go:220] ["1 insert success: 500"]
[2024/05/16 18:37:33.168 +08:00] [INFO] [main.go:234] ["0 delete success: 300"]
[2024/05/16 18:37:33.169 +08:00] [INFO] [main.go:220] ["0 insert success: 600"]
[2024/05/16 18:37:33.270 +08:00] [INFO] [main.go:234] ["1 delete success: 300"]
[2024/05/16 18:37:33.271 +08:00] [INFO] [main.go:220] ["1 insert success: 600"]
[2024/05/16 18:37:33.354 +08:00] [INFO] [main.go:220] ["0 insert success: 700"]
[2024/05/16 18:37:33.473 +08:00] [INFO] [main.go:220] ["1 insert success: 700"]
[2024/05/16 18:37:33.547 +08:00] [INFO] [main.go:234] ["0 delete success: 400"]
[2024/05/16 18:37:33.548 +08:00] [INFO] [main.go:220] ["0 insert success: 800"]
[2024/05/16 18:37:33.663 +08:00] [INFO] [main.go:234] ["1 delete success: 400"]
[2024/05/16 18:37:33.664 +08:00] [INFO] [main.go:220] ["1 insert success: 800"]
[2024/05/16 18:37:33.726 +08:00] [INFO] [main.go:220] ["0 insert success: 900"]
[2024/05/16 18:37:33.852 +08:00] [INFO] [main.go:220] ["1 insert success: 900"]
[2024/05/16 18:37:33.902 +08:00] [INFO] [main.go:234] ["0 delete success: 500"]
[2024/05/16 18:37:33.903 +08:00] [INFO] [main.go:220] ["0 insert success: 1000"]
[2024/05/16 18:37:34.043 +08:00] [INFO] [main.go:234] ["1 delete success: 500"]
[2024/05/16 18:37:34.043 +08:00] [INFO] [main.go:220] ["1 insert success: 1000"]
[2024/05/16 18:37:34.088 +08:00] [INFO] [main.go:220] ["0 insert success: 1100"]
[2024/05/16 18:37:34.233 +08:00] [INFO] [main.go:220] ["1 insert success: 1100"]
[2024/05/16 18:37:34.278 +08:00] [INFO] [main.go:234] ["0 delete success: 600"]
[2024/05/16 18:37:34.279 +08:00] [INFO] [main.go:220] ["0 insert success: 1200"]
[2024/05/16 18:37:34.422 +08:00] [INFO] [main.go:234] ["1 delete success: 600"]
[2024/05/16 18:37:34.423 +08:00] [INFO] [main.go:220] ["1 insert success: 1200"]
[2024/05/16 18:37:34.474 +08:00] [INFO] [main.go:220] ["0 insert success: 1300"]
[2024/05/16 18:37:34.612 +08:00] [INFO] [main.go:220] ["1 insert success: 1300"]
[2024/05/16 18:37:34.675 +08:00] [INFO] [main.go:234] ["0 delete success: 700"]
[2024/05/16 18:37:34.676 +08:00] [INFO] [main.go:220] ["0 insert success: 1400"]
[2024/05/16 18:37:34.811 +08:00] [INFO] [main.go:234] ["1 delete success: 700"]
[2024/05/16 18:37:34.812 +08:00] [INFO] [main.go:220] ["1 insert success: 1400"]
[2024/05/16 18:37:34.866 +08:00] [INFO] [main.go:220] ["0 insert success: 1500"]
[2024/05/16 18:37:35.013 +08:00] [INFO] [main.go:220] ["1 insert success: 1500"]
[2024/05/16 18:37:35.047 +08:00] [INFO] [main.go:234] ["0 delete success: 800"]
[2024/05/16 18:37:35.048 +08:00] [INFO] [main.go:220] ["0 insert success: 1600"]
[2024/05/16 18:37:35.213 +08:00] [INFO] [main.go:234] ["1 delete success: 800"]
[2024/05/16 18:37:35.214 +08:00] [INFO] [main.go:220] ["1 insert success: 1600"]
[2024/05/16 18:37:35.230 +08:00] [INFO] [main.go:220] ["0 insert success: 1700"]
[2024/05/16 18:37:35.404 +08:00] [INFO] [main.go:234] ["0 delete success: 900"]
[2024/05/16 18:37:35.405 +08:00] [INFO] [main.go:220] ["0 insert success: 1800"]
[2024/05/16 18:37:35.416 +08:00] [INFO] [main.go:220] ["1 insert success: 1700"]
[2024/05/16 18:37:35.584 +08:00] [INFO] [main.go:220] ["0 insert success: 1900"]
[2024/05/16 18:37:35.626 +08:00] [INFO] [main.go:234] ["1 delete success: 900"]
[2024/05/16 18:37:35.627 +08:00] [INFO] [main.go:220] ["1 insert success: 1800"]
[2024/05/16 18:37:35.787 +08:00] [INFO] [main.go:234] ["0 delete success: 1000"]
[2024/05/16 18:37:35.788 +08:00] [INFO] [main.go:220] ["0 insert success: 2000"]
[2024/05/16 18:37:35.836 +08:00] [INFO] [main.go:220] ["1 insert success: 1900"]
[2024/05/16 18:37:35.980 +08:00] [INFO] [main.go:220] ["0 insert success: 2100"]
[2024/05/16 18:37:36.039 +08:00] [INFO] [main.go:234] ["1 delete success: 1000"]
[2024/05/16 18:37:36.040 +08:00] [INFO] [main.go:220] ["1 insert success: 2000"]
[2024/05/16 18:37:36.170 +08:00] [INFO] [main.go:234] ["0 delete success: 1100"]
[2024/05/16 18:37:36.171 +08:00] [INFO] [main.go:220] ["0 insert success: 2200"]
[2024/05/16 18:37:36.246 +08:00] [INFO] [main.go:220] ["1 insert success: 2100"]
[2024/05/16 18:37:36.361 +08:00] [INFO] [main.go:220] ["0 insert success: 2300"]
[2024/05/16 18:37:36.451 +08:00] [INFO] [main.go:234] ["1 delete success: 1100"]
[2024/05/16 18:37:36.452 +08:00] [INFO] [main.go:220] ["1 insert success: 2200"]
[2024/05/16 18:37:36.554 +08:00] [INFO] [main.go:234] ["0 delete success: 1200"]
[2024/05/16 18:37:36.555 +08:00] [INFO] [main.go:220] ["0 insert success: 2400"]
[2024/05/16 18:37:36.658 +08:00] [INFO] [main.go:220] ["1 insert success: 2300"]
[2024/05/16 18:37:36.747 +08:00] [INFO] [main.go:220] ["0 insert success: 2500"]
[2024/05/16 18:37:36.865 +08:00] [INFO] [main.go:234] ["1 delete success: 1200"]
[2024/05/16 18:37:36.867 +08:00] [INFO] [main.go:220] ["1 insert success: 2400"]
Verifying downstream PD is started...
Starting Upstream TiKV...
TiKV
Release Version: 8.2.0-alpha
Edition: Community
Git Commit Hash: 3c2cbcf24e326ea917736538b05605c8143b6e1d
Git Commit Branch: master
UTC Build Time: 2024-05-16 09:05:19
Rust Version: rustc 1.77.0-nightly (89e2160c4 2023-12-27)
Enable Features: memory-engine pprof-fp jemalloc mem-profiling portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine trace-async-tasks openssl-vendored
Profile: dist_release
Starting Downstream TiKV...
TiKV
Release Version: 8.2.0-alpha
Edition: Community
Git Commit Hash: 3c2cbcf24e326ea917736538b05605c8143b6e1d
Git Commit Branch: master
UTC Build Time: 2024-05-16 09:05:19
Rust Version: rustc 1.77.0-nightly (89e2160c4 2023-12-27)
Enable Features: memory-engine pprof-fp jemalloc mem-profiling portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine trace-async-tasks openssl-vendored
Profile: dist_release
[2024/05/16 18:37:36.946 +08:00] [INFO] [main.go:234] ["0 delete success: 1300"]
[2024/05/16 18:37:36.947 +08:00] [INFO] [main.go:220] ["0 insert success: 2600"]
Starting Upstream TiDB...
Release Version: v8.2.0-alpha-176-g0875abde25
Edition: Community
Git Commit Hash: 0875abde25467897e4e81ae6c18c5e8792ca28a9
Git Branch: master
UTC Build Time: 2024-05-16 09:43:15
GoVersion: go1.21.6
Race Enabled: false
Check Table Before Drop: false
Store: unistore
Starting Downstream TiDB...
Release Version: v8.2.0-alpha-176-g0875abde25
Edition: Community
Git Commit Hash: 0875abde25467897e4e81ae6c18c5e8792ca28a9
Git Branch: master
UTC Build Time: 2024-05-16 09:43:15
GoVersion: go1.21.6
Race Enabled: false
Check Table Before Drop: false
Store: unistore
Verifying Upstream TiDB is started...
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
[2024/05/16 18:37:42.185 +08:00] [INFO] [main.go:86] ["running ddl test: 4 modifyColumnDDL"]
[2024/05/16 18:37:42.385 +08:00] [INFO] [main.go:220] ["0 insert success: 100"]
[2024/05/16 18:37:42.419 +08:00] [INFO] [main.go:220] ["1 insert success: 100"]
[2024/05/16 18:37:42.565 +08:00] [INFO] [main.go:220] ["0 insert success: 200"]
[2024/05/16 18:37:42.567 +08:00] [INFO] [main.go:234] ["0 delete success: 100"]
[2024/05/16 18:37:42.618 +08:00] [INFO] [main.go:220] ["1 insert success: 200"]
[2024/05/16 18:37:42.620 +08:00] [INFO] [main.go:234] ["1 delete success: 100"]
[2024/05/16 18:37:42.757 +08:00] [INFO] [main.go:220] ["0 insert success: 300"]
[2024/05/16 18:37:42.819 +08:00] [INFO] [main.go:220] ["1 insert success: 300"]
[2024/05/16 18:37:42.950 +08:00] [INFO] [main.go:220] ["0 insert success: 400"]
[2024/05/16 18:37:42.952 +08:00] [INFO] [main.go:234] ["0 delete success: 200"]
[2024/05/16 18:37:43.011 +08:00] [INFO] [main.go:220] ["1 insert success: 400"]
[2024/05/16 18:37:43.014 +08:00] [INFO] [main.go:234] ["1 delete success: 200"]
[2024/05/16 18:37:43.133 +08:00] [INFO] [main.go:220] ["0 insert success: 500"]
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
[2024/05/16 18:37:43.220 +08:00] [INFO] [main.go:220] ["1 insert success: 500"]
[2024/05/16 18:37:43.336 +08:00] [INFO] [main.go:220] ["0 insert success: 600"]
[2024/05/16 18:37:43.338 +08:00] [INFO] [main.go:234] ["0 delete success: 300"]
[2024/05/16 18:37:43.421 +08:00] [INFO] [main.go:220] ["1 insert success: 600"]
[2024/05/16 18:37:43.423 +08:00] [INFO] [main.go:234] ["1 delete success: 300"]
[2024/05/16 18:37:43.536 +08:00] [INFO] [main.go:220] ["0 insert success: 700"]
[2024/05/16 18:37:43.619 +08:00] [INFO] [main.go:220] ["1 insert success: 700"]
[2024/05/16 18:37:43.725 +08:00] [INFO] [main.go:220] ["0 insert success: 800"]
[2024/05/16 18:37:43.727 +08:00] [INFO] [main.go:234] ["0 delete success: 400"]
[2024/05/16 18:37:43.809 +08:00] [INFO] [main.go:220] ["1 insert success: 800"]
[2024/05/16 18:37:43.811 +08:00] [INFO] [main.go:234] ["1 delete success: 400"]
[2024/05/16 18:37:43.913 +08:00] [INFO] [main.go:220] ["0 insert success: 900"]
[2024/05/16 18:37:43.996 +08:00] [INFO] [main.go:220] ["1 insert success: 900"]
[2024/05/16 18:37:44.103 +08:00] [INFO] [main.go:220] ["0 insert success: 1000"]
[2024/05/16 18:37:44.106 +08:00] [INFO] [main.go:234] ["0 delete success: 500"]
[2024/05/16 18:37:44.185 +08:00] [INFO] [main.go:220] ["1 insert success: 1000"]
[2024/05/16 18:37:44.187 +08:00] [INFO] [main.go:234] ["1 delete success: 500"]
[2024/05/16 18:37:44.288 +08:00] [INFO] [main.go:220] ["0 insert success: 1100"]
[2024/05/16 18:37:44.382 +08:00] [INFO] [main.go:220] ["1 insert success: 1100"]
[2024/05/16 18:37:44.464 +08:00] [INFO] [main.go:220] ["0 insert success: 1200"]
[2024/05/16 18:37:44.466 +08:00] [INFO] [main.go:234] ["0 delete success: 600"]
[2024/05/16 18:37:44.580 +08:00] [INFO] [main.go:220] ["1 insert success: 1200"]
[2024/05/16 18:37:44.582 +08:00] [INFO] [main.go:234] ["1 delete success: 600"]
[2024/05/16 18:37:44.642 +08:00] [INFO] [main.go:220] ["0 insert success: 1300"]
[2024/05/16 18:37:44.775 +08:00] [INFO] [main.go:220] ["1 insert success: 1300"]
[2024/05/16 18:37:44.822 +08:00] [INFO] [main.go:220] ["0 insert success: 1400"]
[2024/05/16 18:37:44.823 +08:00] [INFO] [main.go:234] ["0 delete success: 700"]
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
[2024/05/16 18:37:44.971 +08:00] [INFO] [main.go:220] ["1 insert success: 1400"]
[2024/05/16 18:37:44.973 +08:00] [INFO] [main.go:234] ["1 delete success: 700"]
[2024/05/16 18:37:45.013 +08:00] [INFO] [main.go:220] ["0 insert success: 1500"]
[2024/05/16 18:37:45.165 +08:00] [INFO] [main.go:220] ["1 insert success: 1500"]
[2024/05/16 18:37:45.209 +08:00] [INFO] [main.go:220] ["0 insert success: 1600"]
[2024/05/16 18:37:45.211 +08:00] [INFO] [main.go:234] ["0 delete success: 800"]
[2024/05/16 18:37:45.355 +08:00] [INFO] [main.go:220] ["1 insert success: 1600"]
[2024/05/16 18:37:45.357 +08:00] [INFO] [main.go:234] ["1 delete success: 800"]
[2024/05/16 18:37:45.399 +08:00] [INFO] [main.go:220] ["0 insert success: 1700"]
[2024/05/16 18:37:45.542 +08:00] [INFO] [main.go:220] ["1 insert success: 1700"]
[2024/05/16 18:37:45.572 +08:00] [INFO] [main.go:220] ["0 insert success: 1800"]
[2024/05/16 18:37:45.574 +08:00] [INFO] [main.go:234] ["0 delete success: 900"]
[2024/05/16 18:37:45.739 +08:00] [INFO] [main.go:220] ["1 insert success: 1800"]
[2024/05/16 18:37:45.742 +08:00] [INFO] [main.go:234] ["1 delete success: 900"]
[2024/05/16 18:37:45.765 +08:00] [INFO] [main.go:220] ["0 insert success: 1900"]
[2024/05/16 18:37:45.935 +08:00] [INFO] [main.go:220] ["1 insert success: 1900"]
[2024/05/16 18:37:45.960 +08:00] [INFO] [main.go:220] ["0 insert success: 2000"]
[2024/05/16 18:37:45.962 +08:00] [INFO] [main.go:234] ["0 delete success: 1000"]
[2024/05/16 18:37:46.133 +08:00] [INFO] [main.go:220] ["1 insert success: 2000"]
[2024/05/16 18:37:46.135 +08:00] [INFO] [main.go:234] ["1 delete success: 1000"]
[2024/05/16 18:37:46.153 +08:00] [INFO] [main.go:220] ["0 insert success: 2100"]
[2024/05/16 18:37:46.332 +08:00] [INFO] [main.go:220] ["1 insert success: 2100"]
[2024/05/16 18:37:46.347 +08:00] [INFO] [main.go:220] ["0 insert success: 2200"]
[2024/05/16 18:37:46.349 +08:00] [INFO] [main.go:234] ["0 delete success: 1100"]
[2024/05/16 18:37:46.534 +08:00] [INFO] [main.go:220] ["0 insert success: 2300"]
[2024/05/16 18:37:46.534 +08:00] [INFO] [main.go:220] ["1 insert success: 2200"]
[2024/05/16 18:37:46.536 +08:00] [INFO] [main.go:234] ["1 delete success: 1100"]
[2024/05/16 18:37:46.716 +08:00] [INFO] [main.go:220] ["0 insert success: 2400"]
[2024/05/16 18:37:46.717 +08:00] [INFO] [main.go:234] ["0 delete success: 1200"]
[2024/05/16 18:37:46.728 +08:00] [INFO] [main.go:220] ["1 insert success: 2300"]
[2024/05/16 18:37:46.910 +08:00] [INFO] [main.go:220] ["0 insert success: 2500"]
[2024/05/16 18:37:46.925 +08:00] [INFO] [main.go:220] ["1 insert success: 2400"]
[2024/05/16 18:37:46.927 +08:00] [INFO] [main.go:234] ["1 delete success: 1200"]
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03eac3740015 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:43608, start at 2024-05-16 18:37:44.078263165 +0800 CST m=+5.311775965 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:39:44.087 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:37:44.079 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:27:44.079 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03eac3740015 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:43608, start at 2024-05-16 18:37:44.078263165 +0800 CST m=+5.311775965 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:39:44.087 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:37:44.079 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:27:44.079 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
Verifying Downstream TiDB is started...
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03eac4280007 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:43683, start at 2024-05-16 18:37:44.080488781 +0800 CST m=+5.268641600 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:39:44.088 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:37:44.074 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:27:44.074 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
Starting Upstream TiFlash...
TiFlash
Release Version: v8.2.0-alpha-28-g961f9dded
Edition: Community
Git Commit Hash: 961f9dded38b814bb41b33c691ab58f3f090a0d9
Git Branch: HEAD
UTC Build Time: 2024-05-15 03:49:49
Enable Features: jemalloc sm4(GmSSL) avx2 avx512 unwind thinlto
Profile: RELWITHDEBINFO
Compiler: clang++ 13.0.0
Raft Proxy
Git Commit Hash: 7dc50b4eb06124e31f03adb06c20ff7ab61c5f79
Git Commit Branch: HEAD
UTC Build Time: 2024-05-15 03:53:57
Rust Version: rustc 1.67.0-nightly (96ddd32c4 2022-11-14)
Storage Engine: tiflash
Prometheus Prefix: tiflash_proxy_
Profile: release
Enable Features: external-jemalloc portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine cloud-aws cloud-gcp cloud-azure openssl-vendored portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine cloud-aws cloud-gcp cloud-azure openssl-vendored
Verifying Upstream TiFlash is started...
Logging trace to /tmp/tidb_cdc_test/canal_json_claim_check/tiflash/log/server.log
Logging errors to /tmp/tidb_cdc_test/canal_json_claim_check/tiflash/log/error.log
arg matches is ArgMatches { args: {"log-file": MatchedArg { occurs: 1, indices: [18], vals: ["/tmp/tidb_cdc_test/canal_json_claim_check/tiflash/log/proxy.log"] }, "addr": MatchedArg { occurs: 1, indices: [20], vals: ["127.0.0.1:9000"] }, "engine-version": MatchedArg { occurs: 1, indices: [12], vals: ["v8.2.0-alpha-28-g961f9dded"] }, "engine-git-hash": MatchedArg { occurs: 1, indices: [10], vals: ["961f9dded38b814bb41b33c691ab58f3f090a0d9"] }, "pd-endpoints": MatchedArg { occurs: 1, indices: [16], vals: ["127.0.0.1:2379"] }, "engine-addr": MatchedArg { occurs: 1, indices: [2], vals: ["127.0.0.1:9500"] }, "advertise-addr": MatchedArg { occurs: 1, indices: [4], vals: ["127.0.0.1:9000"] }, "engine-label": MatchedArg { occurs: 1, indices: [14], vals: ["tiflash"] }, "config": MatchedArg { occurs: 1, indices: [8], vals: ["/tmp/tidb_cdc_test/canal_json_claim_check/tiflash-proxy.toml"] }, "data-dir": MatchedArg { occurs: 1, indices: [6], vals: ["/tmp/tidb_cdc_test/canal_json_claim_check/tiflash/db/proxy"] }}, subcommand: None, usage: Some("USAGE:\n TiFlash Proxy [FLAGS] [OPTIONS] --engine-git-hash <engine-git-hash> --engine-label <engine-label> --engine-version <engine-version>") }
[2024/05/16 18:37:47.098 +08:00] [INFO] [main.go:220] ["0 insert success: 2600"]
[2024/05/16 18:37:47.100 +08:00] [INFO] [main.go:234] ["0 delete success: 1300"]
[2024/05/16 18:37:47.113 +08:00] [INFO] [main.go:220] ["1 insert success: 2500"]
+ pd_host=127.0.0.1
+ pd_port=2379
+ is_tls=false
+ '[' false == true ']'
++ run_cdc_cli tso query --pd=http://127.0.0.1:2379
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.canal_json_claim_check.cli.45123.out cli tso query --pd=http://127.0.0.1:2379
+ set +x
+ tso='449801321022750721
PASS
coverage: 1.8% of statements in github.com/pingcap/tiflow/...'
+ echo 449801321022750721 PASS coverage: 1.8% of statements in github.com/pingcap/tiflow/...
+ awk -F ' ' '{print $1}'
+ set +x
[Thu May 16 18:37:50 CST 2024] <<<<<< START cdc server in canal_json_claim_check case >>>>>>
+ [[ '' == \t\r\u\e ]]
+ set +e
+ get_info_fail_msg='failed to get info:'
+ etcd_info_msg='etcd info'
+ '[' -z '' ']'
+ curl_status_cmd='curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL'
+ GO_FAILPOINTS=
+ [[ no != \n\o ]]
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.canal_json_claim_check.4516045162.out server --log-file /tmp/tidb_cdc_test/canal_json_claim_check/cdc.log --log-level debug --data-dir /tmp/tidb_cdc_test/canal_json_claim_check/cdc_data --cluster-id default
+ (( i = 0 ))
+ (( i <= 50 ))
++ curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL
* About to connect() to 127.0.0.1 port 8300 (#0)
* Trying 127.0.0.1...
* Connection refused
* Failed connect to 127.0.0.1:8300; Connection refused
* Closing connection 0
+ res=
+ echo ''
+ grep -q 'failed to get info:'
+ echo ''
+ grep -q 'etcd info'
+ '[' 0 -eq 50 ']'
+ sleep 3
[2024/05/16 18:37:52.325 +08:00] [INFO] [main.go:86] ["running ddl test: 5 addDropIndexDDL"]
[2024/05/16 18:37:52.526 +08:00] [INFO] [main.go:220] ["0 insert success: 100"]
[2024/05/16 18:37:52.544 +08:00] [INFO] [main.go:220] ["1 insert success: 100"]
[2024/05/16 18:37:52.708 +08:00] [INFO] [main.go:234] ["0 delete success: 100"]
[2024/05/16 18:37:52.709 +08:00] [INFO] [main.go:220] ["0 insert success: 200"]
[2024/05/16 18:37:52.716 +08:00] [INFO] [main.go:220] ["1 insert success: 200"]
[2024/05/16 18:37:52.718 +08:00] [INFO] [main.go:234] ["1 delete success: 100"]
[2024/05/16 18:37:52.937 +08:00] [INFO] [main.go:220] ["0 insert success: 300"]
[2024/05/16 18:37:52.943 +08:00] [INFO] [main.go:220] ["1 insert success: 300"]
[2024/05/16 18:37:53.182 +08:00] [INFO] [main.go:234] ["0 delete success: 200"]
[2024/05/16 18:37:53.183 +08:00] [INFO] [main.go:220] ["0 insert success: 400"]
[2024/05/16 18:37:53.199 +08:00] [INFO] [main.go:220] ["1 insert success: 400"]
[2024/05/16 18:37:53.202 +08:00] [INFO] [main.go:234] ["1 delete success: 200"]
[2024/05/16 18:37:53.433 +08:00] [INFO] [main.go:220] ["0 insert success: 500"]
[2024/05/16 18:37:53.451 +08:00] [INFO] [main.go:220] ["1 insert success: 500"]
[2024/05/16 18:37:53.691 +08:00] [INFO] [main.go:234] ["0 delete success: 300"]
[2024/05/16 18:37:53.693 +08:00] [INFO] [main.go:220] ["0 insert success: 600"]
[2024/05/16 18:37:53.712 +08:00] [INFO] [main.go:220] ["1 insert success: 600"]
[2024/05/16 18:37:53.714 +08:00] [INFO] [main.go:234] ["1 delete success: 300"]
+ (( i++ ))
+ (( i <= 50 ))
++ curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL
* About to connect() to 127.0.0.1 port 8300 (#0)
* Trying 127.0.0.1...
* Connected to 127.0.0.1 (127.0.0.1) port 8300 (#0)
* Server auth using Basic with user 'ticdc'
> GET /debug/info HTTP/1.1
> Authorization: Basic dGljZGM6dGljZGNfc2VjcmV0
> User-Agent: curl/7.29.0
> Host: 127.0.0.1:8300
> Accept: */*
>
< HTTP/1.1 200 OK
< Date: Thu, 16 May 2024 10:37:53 GMT
< Content-Length: 815
< Content-Type: text/plain; charset=utf-8
<
{ [data not shown]
* Connection #0 to host 127.0.0.1 left intact
+ res='
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/8dfa4211-f0ec-4ed9-9316-f2914bf4e20d
{"id":"8dfa4211-f0ec-4ed9-9316-f2914bf4e20d","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855871}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80fa8483d6
8dfa4211-f0ec-4ed9-9316-f2914bf4e20d
/tidb/cdc/default/default/upstream/7369544783580390318
{"id":7369544783580390318,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ echo '
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/8dfa4211-f0ec-4ed9-9316-f2914bf4e20d
{"id":"8dfa4211-f0ec-4ed9-9316-f2914bf4e20d","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855871}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80fa8483d6
8dfa4211-f0ec-4ed9-9316-f2914bf4e20d
/tidb/cdc/default/default/upstream/7369544783580390318
{"id":7369544783580390318,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ grep -q 'failed to get info:'
+ echo '
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/8dfa4211-f0ec-4ed9-9316-f2914bf4e20d
{"id":"8dfa4211-f0ec-4ed9-9316-f2914bf4e20d","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855871}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80fa8483d6
8dfa4211-f0ec-4ed9-9316-f2914bf4e20d
/tidb/cdc/default/default/upstream/7369544783580390318
{"id":7369544783580390318,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ grep -q 'etcd info'
+ break
+ set +x
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.canal_json_claim_check.cli.45222.out cli changefeed create --start-ts=449801321022750721 '--sink-uri=kafka://127.0.0.1:9092/canal-json-claim-check?protocol=canal-json&enable-tidb-extension=true&max-message-bytes=1000&kafka-version=2.4.1' --config=/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/canal_json_claim_check/conf/changefeed.toml
[2024/05/16 18:37:53.993 +08:00] [INFO] [main.go:220] ["1 insert success: 700"]
[2024/05/16 18:37:54.025 +08:00] [INFO] [main.go:220] ["0 insert success: 700"]
Create changefeed successfully!
ID: 6390a44f-1244-4348-9538-5d1c91cbffe9
Info: {"upstream_id":7369544783580390318,"namespace":"default","id":"6390a44f-1244-4348-9538-5d1c91cbffe9","sink_uri":"kafka://127.0.0.1:9092/canal-json-claim-check?protocol=canal-json\u0026enable-tidb-extension=true\u0026max-message-bytes=1000\u0026kafka-version=2.4.1","create_time":"2024-05-16T18:37:54.44213514+08:00","start_ts":449801321022750721,"config":{"memory_quota":1073741824,"case_sensitive":false,"force_replicate":false,"ignore_ineligible_table":false,"check_gc_safe_point":true,"enable_sync_point":false,"enable_table_monitor":false,"bdr_mode":false,"sync_point_interval":600000000000,"sync_point_retention":86400000000000,"filter":{"rules":["*.*"]},"mounter":{"worker_num":16},"sink":{"protocol":"canal-json","csv":{"delimiter":",","quote":"\"","null":"\\N","include_commit_ts":false,"binary_encoding_method":"base64","output_old_value":false,"output_handle_key":false},"encoder_concurrency":32,"terminator":"\r\n","date_separator":"day","enable_partition_separator":true,"enable_kafka_sink_v2":false,"only_output_updated_columns":false,"delete_only_output_handle_key_columns":false,"content_compatible":false,"kafka_config":{"large_message_handle":{"large_message_handle_option":"claim-check","large_message_handle_compression":"snappy","claim_check_storage_uri":"file:///tmp/canal-json-claim-check"}},"advance_timeout":150,"send_bootstrap_interval_in_sec":120,"send_bootstrap_in_msg_count":10000,"send_bootstrap_to_all_partition":true,"debezium_disable_schema":false,"debezium":{"output_old_value":true},"open":{"output_old_value":true}},"consistent":{"level":"none","max_log_size":64,"flush_interval":2000,"meta_flush_interval":200,"encoding_worker_num":16,"flush_worker_num":8,"use_file_backend":false,"memory_usage":{"memory_quota_percentage":50}},"scheduler":{"enable_table_across_nodes":false,"region_threshold":100000,"write_key_threshold":0},"integrity":{"integrity_check_level":"none","corruption_handle_level":"warn"},"changefeed_error_stuck_duration":1800000000000,"synced_status":{"synced_check_interval":300,"checkpoint_interval":15}},"state":"normal","creator_version":"v8.2.0-alpha-46-g6ee8257c6","resolved_ts":449801321022750721,"checkpoint_ts":449801321022750721,"checkpoint_time":"2024-05-16 18:37:49.380"}
PASS
[2024/05/16 18:37:54.290 +08:00] [INFO] [main.go:220] ["1 insert success: 800"]
[2024/05/16 18:37:54.294 +08:00] [INFO] [main.go:234] ["1 delete success: 400"]
[2024/05/16 18:37:54.444 +08:00] [INFO] [main.go:234] ["0 delete success: 400"]
[2024/05/16 18:37:54.446 +08:00] [INFO] [main.go:220] ["0 insert success: 800"]
coverage: 2.5% of statements in github.com/pingcap/tiflow/...
[2024/05/16 18:37:54.612 +08:00] [INFO] [main.go:220] ["1 insert success: 900"]
[2024/05/16 18:37:54.885 +08:00] [INFO] [main.go:220] ["0 insert success: 900"]
[2024/05/16 18:37:54.985 +08:00] [INFO] [main.go:220] ["1 insert success: 1000"]
[2024/05/16 18:37:54.989 +08:00] [INFO] [main.go:234] ["1 delete success: 500"]
[2024/05/16 18:37:55.205 +08:00] [INFO] [main.go:220] ["1 insert success: 1100"]
[2024/05/16 18:37:55.211 +08:00] [INFO] [main.go:234] ["0 delete success: 500"]
[2024/05/16 18:37:55.213 +08:00] [INFO] [main.go:220] ["0 insert success: 1000"]
[2024/05/16 18:37:55.532 +08:00] [INFO] [main.go:220] ["1 insert success: 1200"]
[2024/05/16 18:37:55.536 +08:00] [INFO] [main.go:234] ["1 delete success: 600"]
[2024/05/16 18:37:55.587 +08:00] [INFO] [main.go:220] ["0 insert success: 1100"]
[90m6:37PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/datetime_key_test.sql
[2024/05/16 18:37:55.911 +08:00] [INFO] [main.go:220] ["1 insert success: 1300"]
[2024/05/16 18:37:55.994 +08:00] [INFO] [main.go:234] ["0 delete success: 600"]
[2024/05/16 18:37:55.996 +08:00] [INFO] [main.go:220] ["0 insert success: 1200"]
+ set +x
[2024/05/16 18:37:56.286 +08:00] [INFO] [main.go:220] ["1 insert success: 1400"]
[2024/05/16 18:37:56.292 +08:00] [INFO] [main.go:234] ["1 delete success: 700"]
[2024/05/16 18:37:56.422 +08:00] [INFO] [main.go:220] ["0 insert success: 1300"]
[2024/05/16 18:37:56.701 +08:00] [INFO] [main.go:220] ["1 insert success: 1500"]
[2024/05/16 18:37:56.879 +08:00] [INFO] [main.go:234] ["0 delete success: 700"]
[2024/05/16 18:37:56.881 +08:00] [INFO] [main.go:220] ["0 insert success: 1400"]
[2024/05/16 18:37:57.154 +08:00] [INFO] [main.go:220] ["1 insert success: 1600"]
[2024/05/16 18:37:57.159 +08:00] [INFO] [main.go:234] ["1 delete success: 800"]
table test.finish_mark not exists for 1-th check, retry later
table test.finish_mark not exists for 2-th check, retry later
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/db_default_charset.sql
table test.finish_mark exists
check diff successfully
wait process cdc.test exit for 1-th time...
wait process cdc.test exit for 2-th time...
[2024/05/16 18:38:03.040 +08:00] [INFO] [main.go:78] ["runDDLTest take 1m1.694048754s"]
table mark.finish_mark_0 exists
table mark.finish_mark_1 not exists for 1-th check, retry later
cdc.test: no process found
wait process cdc.test exit for 3-th time...
process cdc.test already exit
[Thu May 16 18:38:03 CST 2024] <<<<<< run test case canal_json_claim_check success! >>>>>>
table mark.finish_mark_1 not exists for 2-th check, retry later
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/db_default_charset_noutf.sql
table mark.finish_mark_1 not exists for 3-th check, retry later
table mark.finish_mark_1 not exists for 4-th check, retry later
table mark.finish_mark_1 not exists for 5-th check, retry later
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/decimal_column_test.sql
table mark.finish_mark_1 not exists for 6-th check, retry later
table mark.finish_mark_1 not exists for 7-th check, retry later
/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/canal_json_claim_check/run.sh: line 1: 45256 Killed cdc_kafka_consumer --upstream-uri $SINK_URI --downstream-uri="mysql://root@127.0.0.1:3306/?safe-mode=true&batch-dml-enable=false" --upstream-tidb-dsn="root@tcp(${UP_TIDB_HOST}:${UP_TIDB_PORT})/?" --config="$CUR/conf/changefeed.toml" 2>&1
=================>> Running test /home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/open_protocol_claim_check/run.sh using Sink-Type: kafka... <<=================
The 1 times to try to start tidb cluster...
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/enum_column_test.sql
table mark.finish_mark_1 not exists for 8-th check, retry later
start tidb cluster in /tmp/tidb_cdc_test/open_protocol_claim_check
Starting Upstream PD...
Release Version: v8.2.0-alpha-31-g7e858178a
Edition: Community
Git Commit Hash: 7e858178a78b180f7dad83554053bbc3817e9f2e
Git Branch: master
UTC Build Time: 2024-05-16 09:50:16
Starting Downstream PD...
Release Version: v8.2.0-alpha-31-g7e858178a
Edition: Community
Git Commit Hash: 7e858178a78b180f7dad83554053bbc3817e9f2e
Git Branch: master
UTC Build Time: 2024-05-16 09:50:16
Verifying upstream PD is started...
table mark.finish_mark_1 not exists for 9-th check, retry later
table mark.finish_mark_1 exists
table mark.finish_mark_2 not exists for 1-th check, retry later
Verifying downstream PD is started...
Starting Upstream TiKV...
TiKV
Release Version: 8.2.0-alpha
Edition: Community
Git Commit Hash: 3c2cbcf24e326ea917736538b05605c8143b6e1d
Git Commit Branch: master
UTC Build Time: 2024-05-16 09:05:19
Rust Version: rustc 1.77.0-nightly (89e2160c4 2023-12-27)
Enable Features: memory-engine pprof-fp jemalloc mem-profiling portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine trace-async-tasks openssl-vendored
Profile: dist_release
Starting Downstream TiKV...
TiKV
Release Version: 8.2.0-alpha
Edition: Community
Git Commit Hash: 3c2cbcf24e326ea917736538b05605c8143b6e1d
Git Commit Branch: master
UTC Build Time: 2024-05-16 09:05:19
Rust Version: rustc 1.77.0-nightly (89e2160c4 2023-12-27)
Enable Features: memory-engine pprof-fp jemalloc mem-profiling portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine trace-async-tasks openssl-vendored
Profile: dist_release
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/multitable_dbz_871.sql
table mark.finish_mark_2 not exists for 2-th check, retry later
Starting Upstream TiDB...
Release Version: v8.2.0-alpha-176-g0875abde25
Edition: Community
Git Commit Hash: 0875abde25467897e4e81ae6c18c5e8792ca28a9
Git Branch: master
UTC Build Time: 2024-05-16 09:43:15
GoVersion: go1.21.6
Race Enabled: false
Check Table Before Drop: false
Store: unistore
Starting Downstream TiDB...
Release Version: v8.2.0-alpha-176-g0875abde25
Edition: Community
Git Commit Hash: 0875abde25467897e4e81ae6c18c5e8792ca28a9
Git Branch: master
UTC Build Time: 2024-05-16 09:43:15
GoVersion: go1.21.6
Race Enabled: false
Check Table Before Drop: false
Store: unistore
Verifying Upstream TiDB is started...
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/mysql_dbz_6533.sql
table mark.finish_mark_2 not exists for 3-th check, retry later
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
table mark.finish_mark_2 not exists for 4-th check, retry later
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
table mark.finish_mark_2 not exists for 5-th check, retry later
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
table mark.finish_mark_2 not exists for 6-th check, retry later
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03ed83a00011 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:46478, start at 2024-05-16 18:38:29.117982565 +0800 CST m=+5.328227093 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:40:29.127 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:38:29.096 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:28:29.096 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03ed83a00011 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:46478, start at 2024-05-16 18:38:29.117982565 +0800 CST m=+5.328227093 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:40:29.127 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:38:29.096 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:28:29.096 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
Verifying Downstream TiDB is started...
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03ed85240003 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:46555, start at 2024-05-16 18:38:29.196034154 +0800 CST m=+5.357398159 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:40:29.202 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:38:29.193 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:28:29.193 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
Starting Upstream TiFlash...
TiFlash
Release Version: v8.2.0-alpha-28-g961f9dded
Edition: Community
Git Commit Hash: 961f9dded38b814bb41b33c691ab58f3f090a0d9
Git Branch: HEAD
UTC Build Time: 2024-05-15 03:49:49
Enable Features: jemalloc sm4(GmSSL) avx2 avx512 unwind thinlto
Profile: RELWITHDEBINFO
Compiler: clang++ 13.0.0
Raft Proxy
Git Commit Hash: 7dc50b4eb06124e31f03adb06c20ff7ab61c5f79
Git Commit Branch: HEAD
UTC Build Time: 2024-05-15 03:53:57
Rust Version: rustc 1.67.0-nightly (96ddd32c4 2022-11-14)
Storage Engine: tiflash
Prometheus Prefix: tiflash_proxy_
Profile: release
Enable Features: external-jemalloc portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine cloud-aws cloud-gcp cloud-azure openssl-vendored portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine cloud-aws cloud-gcp cloud-azure openssl-vendored
Verifying Upstream TiFlash is started...
Logging trace to /tmp/tidb_cdc_test/open_protocol_claim_check/tiflash/log/server.log
Logging errors to /tmp/tidb_cdc_test/open_protocol_claim_check/tiflash/log/error.log
arg matches is ArgMatches { args: {"log-file": MatchedArg { occurs: 1, indices: [18], vals: ["/tmp/tidb_cdc_test/open_protocol_claim_check/tiflash/log/proxy.log"] }, "addr": MatchedArg { occurs: 1, indices: [20], vals: ["127.0.0.1:9000"] }, "config": MatchedArg { occurs: 1, indices: [8], vals: ["/tmp/tidb_cdc_test/open_protocol_claim_check/tiflash-proxy.toml"] }, "advertise-addr": MatchedArg { occurs: 1, indices: [4], vals: ["127.0.0.1:9000"] }, "engine-git-hash": MatchedArg { occurs: 1, indices: [10], vals: ["961f9dded38b814bb41b33c691ab58f3f090a0d9"] }, "pd-endpoints": MatchedArg { occurs: 1, indices: [16], vals: ["127.0.0.1:2379"] }, "engine-addr": MatchedArg { occurs: 1, indices: [2], vals: ["127.0.0.1:9500"] }, "engine-label": MatchedArg { occurs: 1, indices: [14], vals: ["tiflash"] }, "engine-version": MatchedArg { occurs: 1, indices: [12], vals: ["v8.2.0-alpha-28-g961f9dded"] }, "data-dir": MatchedArg { occurs: 1, indices: [6], vals: ["/tmp/tidb_cdc_test/open_protocol_claim_check/tiflash/db/proxy"] }}, subcommand: None, usage: Some("USAGE:\n TiFlash Proxy [FLAGS] [OPTIONS] --engine-git-hash <engine-git-hash> --engine-label <engine-label> --engine-version <engine-version>") }
table mark.finish_mark_2 exists
table mark.finish_mark_3 not exists for 1-th check, retry later
+ pd_host=127.0.0.1
+ pd_port=2379
+ is_tls=false
+ '[' false == true ']'
++ run_cdc_cli tso query --pd=http://127.0.0.1:2379
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.open_protocol_claim_check.cli.47888.out cli tso query --pd=http://127.0.0.1:2379
table mark.finish_mark_3 not exists for 2-th check, retry later
+ set +x
+ tso='449801332849639425
PASS
coverage: 1.8% of statements in github.com/pingcap/tiflow/...'
+ echo 449801332849639425 PASS coverage: 1.8% of statements in github.com/pingcap/tiflow/...
+ awk -F ' ' '{print $1}'
+ set +x
table mark.finish_mark_3 not exists for 3-th check, retry later
table mark.finish_mark_3 not exists for 4-th check, retry later
+ pd_host=127.0.0.1
+ pd_port=2379
+ is_tls=false
+ '[' false == true ']'
++ run_cdc_cli tso query --pd=http://127.0.0.1:2379
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.open_protocol_claim_check.cli.47934.out cli tso query --pd=http://127.0.0.1:2379
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/nationalized_character_test.sql
+ set +x
+ tso='449801334658695169
PASS
coverage: 1.8% of statements in github.com/pingcap/tiflow/...'
+ echo 449801334658695169 PASS coverage: 1.8% of statements in github.com/pingcap/tiflow/...
+ awk -F ' ' '{print $1}'
+ set +x
[Thu May 16 18:38:42 CST 2024] <<<<<< START cdc server in open_protocol_claim_check case >>>>>>
+ [[ '' == \t\r\u\e ]]
+ set +e
+ get_info_fail_msg='failed to get info:'
+ etcd_info_msg='etcd info'
+ '[' -z '' ']'
+ curl_status_cmd='curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL'
+ GO_FAILPOINTS=
+ [[ no != \n\o ]]
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.open_protocol_claim_check.4797047972.out server --log-file /tmp/tidb_cdc_test/open_protocol_claim_check/cdc.log --log-level debug --data-dir /tmp/tidb_cdc_test/open_protocol_claim_check/cdc_data --cluster-id default
+ (( i = 0 ))
+ (( i <= 50 ))
++ curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL
* About to connect() to 127.0.0.1 port 8300 (#0)
* Trying 127.0.0.1...
* Connection refused
* Failed connect to 127.0.0.1:8300; Connection refused
* Closing connection 0
+ res=
+ echo ''
+ grep -q 'failed to get info:'
+ echo ''
+ grep -q 'etcd info'
+ '[' 0 -eq 50 ']'
+ sleep 3
table mark.finish_mark_3 exists
table mark.finish_mark_4 not exists for 1-th check, retry later
table mark.finish_mark_4 not exists for 2-th check, retry later
+ (( i++ ))
+ (( i <= 50 ))
++ curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL
* About to connect() to 127.0.0.1 port 8300 (#0)
* Trying 127.0.0.1...
* Connected to 127.0.0.1 (127.0.0.1) port 8300 (#0)
* Server auth using Basic with user 'ticdc'
> GET /debug/info HTTP/1.1
> Authorization: Basic dGljZGM6dGljZGNfc2VjcmV0
> User-Agent: curl/7.29.0
> Host: 127.0.0.1:8300
> Accept: */*
>
< HTTP/1.1 200 OK
< Date: Thu, 16 May 2024 10:38:45 GMT
< Content-Length: 815
< Content-Type: text/plain; charset=utf-8
<
{ [data not shown]
* Connection #0 to host 127.0.0.1 left intact
+ res='
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/03d612ef-52ee-4f04-848b-d008b59e1161
{"id":"03d612ef-52ee-4f04-848b-d008b59e1161","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855923}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80fb3a393f
03d612ef-52ee-4f04-848b-d008b59e1161
/tidb/cdc/default/default/upstream/7369544978613449498
{"id":7369544978613449498,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ echo '
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/03d612ef-52ee-4f04-848b-d008b59e1161
{"id":"03d612ef-52ee-4f04-848b-d008b59e1161","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855923}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80fb3a393f
03d612ef-52ee-4f04-848b-d008b59e1161
/tidb/cdc/default/default/upstream/7369544978613449498
{"id":7369544978613449498,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ grep -q 'failed to get info:'
+ echo '
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/03d612ef-52ee-4f04-848b-d008b59e1161
{"id":"03d612ef-52ee-4f04-848b-d008b59e1161","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855923}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80fb3a393f
03d612ef-52ee-4f04-848b-d008b59e1161
/tidb/cdc/default/default/upstream/7369544978613449498
{"id":7369544978613449498,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ grep -q 'etcd info'
+ break
+ set +x
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.open_protocol_claim_check.cli.48027.out cli changefeed create --start-ts=449801332849639425 --target-ts=449801334658695169 '--sink-uri=kafka://127.0.0.1:9092/open-protocol-claim-check?protocol=open-protocol&max-message-bytes=800&kafka-version=2.4.1' --config=/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/open_protocol_claim_check/conf/changefeed.toml
Create changefeed successfully!
ID: 32505f15-88dc-4f95-8cb4-ef7e01cf3869
Info: {"upstream_id":7369544978613449498,"namespace":"default","id":"32505f15-88dc-4f95-8cb4-ef7e01cf3869","sink_uri":"kafka://127.0.0.1:9092/open-protocol-claim-check?protocol=open-protocol\u0026max-message-bytes=800\u0026kafka-version=2.4.1","create_time":"2024-05-16T18:38:46.457665727+08:00","start_ts":449801332849639425,"target_ts":449801334658695169,"config":{"memory_quota":1073741824,"case_sensitive":false,"force_replicate":false,"ignore_ineligible_table":false,"check_gc_safe_point":true,"enable_sync_point":false,"enable_table_monitor":false,"bdr_mode":false,"sync_point_interval":600000000000,"sync_point_retention":86400000000000,"filter":{"rules":["*.*"]},"mounter":{"worker_num":16},"sink":{"protocol":"open-protocol","csv":{"delimiter":",","quote":"\"","null":"\\N","include_commit_ts":false,"binary_encoding_method":"base64","output_old_value":false,"output_handle_key":false},"encoder_concurrency":32,"terminator":"\r\n","date_separator":"day","enable_partition_separator":true,"enable_kafka_sink_v2":false,"only_output_updated_columns":false,"delete_only_output_handle_key_columns":false,"content_compatible":false,"kafka_config":{"large_message_handle":{"large_message_handle_option":"claim-check","large_message_handle_compression":"lz4","claim_check_storage_uri":"file:///tmp/open-protocol-claim-check"}},"advance_timeout":150,"send_bootstrap_interval_in_sec":120,"send_bootstrap_in_msg_count":10000,"send_bootstrap_to_all_partition":true,"debezium_disable_schema":false,"debezium":{"output_old_value":true},"open":{"output_old_value":true}},"consistent":{"level":"none","max_log_size":64,"flush_interval":2000,"meta_flush_interval":200,"encoding_worker_num":16,"flush_worker_num":8,"use_file_backend":false,"memory_usage":{"memory_quota_percentage":50}},"scheduler":{"enable_table_across_nodes":false,"region_threshold":100000,"write_key_threshold":0},"integrity":{"integrity_check_level":"none","corruption_handle_level":"warn"},"changefeed_error_stuck_duration":1800000000000,"synced_status":{"synced_check_interval":300,"checkpoint_interval":15}},"state":"normal","creator_version":"v8.2.0-alpha-46-g6ee8257c6","resolved_ts":449801332849639425,"checkpoint_ts":449801332849639425,"checkpoint_time":"2024-05-16 18:38:34.496"}
PASS
coverage: 2.5% of statements in github.com/pingcap/tiflow/...
table mark.finish_mark_4 not exists for 3-th check, retry later
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/numeric_column_test.sql
+ set +x
table test.finish_mark not exists for 1-th check, retry later
table mark.finish_mark_4 not exists for 4-th check, retry later
table test.finish_mark not exists for 2-th check, retry later
table mark.finish_mark_4 not exists for 5-th check, retry later
table test.finish_mark exists
check diff successfully
wait process cdc.test exit for 1-th time...
wait process cdc.test exit for 2-th time...
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/readbinlog_test.sql
[90m6:38PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/real_test.sql
table mark.finish_mark_4 not exists for 6-th check, retry later
cdc.test: no process found
wait process cdc.test exit for 3-th time...
process cdc.test already exit
[Thu May 16 18:38:53 CST 2024] <<<<<< run test case open_protocol_claim_check success! >>>>>>
table mark.finish_mark_4 not exists for 7-th check, retry later
table mark.finish_mark_4 not exists for 8-th check, retry later
table mark.finish_mark_4 exists
table mark.finish_mark_5 not exists for 1-th check, retry later
table mark.finish_mark_5 not exists for 2-th check, retry later
table mark.finish_mark_5 not exists for 3-th check, retry later
[90m6:39PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/regression_test.sql
table mark.finish_mark_5 not exists for 4-th check, retry later
/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/open_protocol_claim_check/run.sh: line 1: 48064 Killed cdc_kafka_consumer --upstream-uri $SINK_URI --downstream-uri="mysql://root@127.0.0.1:3306/?safe-mode=true&batch-dml-enable=false" --upstream-tidb-dsn="root@tcp(${UP_TIDB_HOST}:${UP_TIDB_PORT})/?" --config="$CUR/conf/changefeed.toml" 2>&1
=================>> Running test /home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/canal_json_storage_basic/run.sh using Sink-Type: kafka... <<=================
[Thu May 16 18:39:05 CST 2024] <<<<<< run test case canal_json_storage_basic success! >>>>>>
table mark.finish_mark_5 exists
table mark.finish_mark not exists for 1-th check, retry later
=================>> Running test /home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/canal_json_storage_partition_table/run.sh using Sink-Type: kafka... <<=================
[Thu May 16 18:39:08 CST 2024] <<<<<< run test case canal_json_storage_partition_table success! >>>>>>
table mark.finish_mark exists
check diff successfully
wait process cdc.test exit for 1-th time...
cdc.test: no process found
wait process cdc.test exit for 2-th time...
process cdc.test already exit
[Thu May 16 18:39:11 CST 2024] <<<<<< run test case multi_source success! >>>>>>
=================>> Running test /home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/multi_tables_ddl/run.sh using Sink-Type: kafka... <<=================
* About to connect() to 127.0.0.1 port 24927 (#0)
* Trying 127.0.0.1...
* Connection refused
* Failed connect to 127.0.0.1:24927; Connection refused
* Closing connection 0
You are running an older version of MinIO released 3 years ago
Update: Run `mc admin update`
Attempting encryption of all config, IAM users and policies on MinIO backend
Endpoint: http://127.0.0.1:24927
Object API (Amazon S3 compatible):
Go: https://docs.min.io/docs/golang-client-quickstart-guide
Java: https://docs.min.io/docs/java-client-quickstart-guide
Python: https://docs.min.io/docs/python-client-quickstart-guide
JavaScript: https://docs.min.io/docs/javascript-client-quickstart-guide
.NET: https://docs.min.io/docs/dotnet-client-quickstart-guide
* About to connect() to 127.0.0.1 port 24927 (#0)
* Trying 127.0.0.1...
* Connected to 127.0.0.1 (127.0.0.1) port 24927 (#0)
> GET / HTTP/1.1
> User-Agent: curl/7.29.0
> Host: 127.0.0.1:24927
> Accept: */*
>
< HTTP/1.1 403 Forbidden
< Accept-Ranges: bytes
< Content-Length: 226
< Content-Security-Policy: block-all-mixed-content
< Content-Type: application/xml
< Server: MinIO/RELEASE.2020-07-27T18-37-02Z
< Vary: Origin
< X-Amz-Request-Id: 17CFF1E655789803
< X-Xss-Protection: 1; mode=block
< Date: Thu, 16 May 2024 10:39:14 GMT
<
{ [data not shown]
* Connection #0 to host 127.0.0.1 left intact
Bucket 's3://logbucket/' created
The 1 times to try to start tidb cluster...
start tidb cluster in /tmp/tidb_cdc_test/multi_tables_ddl
Starting Upstream PD...
Release Version: v8.2.0-alpha-31-g7e858178a
Edition: Community
Git Commit Hash: 7e858178a78b180f7dad83554053bbc3817e9f2e
Git Branch: master
UTC Build Time: 2024-05-16 09:50:16
Starting Downstream PD...
Release Version: v8.2.0-alpha-31-g7e858178a
Edition: Community
Git Commit Hash: 7e858178a78b180f7dad83554053bbc3817e9f2e
Git Branch: master
UTC Build Time: 2024-05-16 09:50:16
Verifying upstream PD is started...
Verifying downstream PD is started...
Starting Upstream TiKV...
TiKV
Release Version: 8.2.0-alpha
Edition: Community
Git Commit Hash: 3c2cbcf24e326ea917736538b05605c8143b6e1d
Git Commit Branch: master
UTC Build Time: 2024-05-16 09:05:19
Rust Version: rustc 1.77.0-nightly (89e2160c4 2023-12-27)
Enable Features: memory-engine pprof-fp jemalloc mem-profiling portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine trace-async-tasks openssl-vendored
Profile: dist_release
Starting Downstream TiKV...
TiKV
Release Version: 8.2.0-alpha
Edition: Community
Git Commit Hash: 3c2cbcf24e326ea917736538b05605c8143b6e1d
Git Commit Branch: master
UTC Build Time: 2024-05-16 09:05:19
Rust Version: rustc 1.77.0-nightly (89e2160c4 2023-12-27)
Enable Features: memory-engine pprof-fp jemalloc mem-profiling portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine trace-async-tasks openssl-vendored
Profile: dist_release
Starting Upstream TiDB...
Release Version: v8.2.0-alpha-176-g0875abde25
Edition: Community
Git Commit Hash: 0875abde25467897e4e81ae6c18c5e8792ca28a9
Git Branch: master
UTC Build Time: 2024-05-16 09:43:15
GoVersion: go1.21.6
Race Enabled: false
Check Table Before Drop: false
Store: unistore
Starting Downstream TiDB...
Release Version: v8.2.0-alpha-176-g0875abde25
Edition: Community
Git Commit Hash: 0875abde25467897e4e81ae6c18c5e8792ca28a9
Git Branch: master
UTC Build Time: 2024-05-16 09:43:15
GoVersion: go1.21.6
Race Enabled: false
Check Table Before Drop: false
Store: unistore
Verifying Upstream TiDB is started...
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
ERROR 2003 (HY000): Can't connect to MySQL server on '127.0.0.1' (111)
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03f111700017 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:49522, start at 2024-05-16 18:39:27.348959898 +0800 CST m=+5.186412589 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:41:27.357 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:39:27.324 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:29:27.324 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03f111700017 Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:49522, start at 2024-05-16 18:39:27.348959898 +0800 CST m=+5.186412589 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:41:27.357 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:39:27.324 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:29:27.324 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
Verifying Downstream TiDB is started...
VARIABLE_NAME VARIABLE_VALUE COMMENT
bootstrapped True Bootstrap flag. Do not delete.
tidb_server_version 198 Bootstrap version. Do not delete.
system_tz Asia/Shanghai TiDB Global System Timezone.
new_collation_enabled True If the new collations are enabled. Do not edit it.
ddl_table_version 3 DDL Table Version. Do not delete.
tikv_gc_leader_uuid 63e03f113a8000d Current GC worker leader UUID. (DO NOT EDIT)
tikv_gc_leader_desc host:pingcap-tiflow-pull-cdc-integration-kafka-test-2008-tsj86-0crv9, pid:49600, start at 2024-05-16 18:39:27.477658258 +0800 CST m=+5.268256599 Host name and pid of current GC leader. (DO NOT EDIT)
tikv_gc_leader_lease 20240516-18:41:27.484 +0800 Current GC worker leader lease. (DO NOT EDIT)
tikv_gc_auto_concurrency true Let TiDB pick the concurrency automatically. If set false, tikv_gc_concurrency will be used
tikv_gc_enable true Current GC enable status
tikv_gc_run_interval 10m0s GC run interval, at least 10m, in Go format.
tikv_gc_life_time 10m0s All versions within life time will not be collected by GC, at least 10m, in Go format.
tikv_gc_last_run_time 20240516-18:39:27.466 +0800 The time when last GC starts. (DO NOT EDIT)
tikv_gc_safe_point 20240516-18:29:27.466 +0800 All versions after safe point can be accessed. (DO NOT EDIT)
Starting Upstream TiFlash...
TiFlash
Release Version: v8.2.0-alpha-28-g961f9dded
Edition: Community
Git Commit Hash: 961f9dded38b814bb41b33c691ab58f3f090a0d9
Git Branch: HEAD
UTC Build Time: 2024-05-15 03:49:49
Enable Features: jemalloc sm4(GmSSL) avx2 avx512 unwind thinlto
Profile: RELWITHDEBINFO
Compiler: clang++ 13.0.0
Raft Proxy
Git Commit Hash: 7dc50b4eb06124e31f03adb06c20ff7ab61c5f79
Git Commit Branch: HEAD
UTC Build Time: 2024-05-15 03:53:57
Rust Version: rustc 1.67.0-nightly (96ddd32c4 2022-11-14)
Storage Engine: tiflash
Prometheus Prefix: tiflash_proxy_
Profile: release
Enable Features: external-jemalloc portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine cloud-aws cloud-gcp cloud-azure openssl-vendored portable sse test-engine-kv-rocksdb test-engine-raft-raft-engine cloud-aws cloud-gcp cloud-azure openssl-vendored
Verifying Upstream TiFlash is started...
Logging trace to /tmp/tidb_cdc_test/multi_tables_ddl/tiflash/log/server.log
Logging errors to /tmp/tidb_cdc_test/multi_tables_ddl/tiflash/log/error.log
arg matches is ArgMatches { args: {"log-file": MatchedArg { occurs: 1, indices: [18], vals: ["/tmp/tidb_cdc_test/multi_tables_ddl/tiflash/log/proxy.log"] }, "addr": MatchedArg { occurs: 1, indices: [20], vals: ["127.0.0.1:9000"] }, "engine-addr": MatchedArg { occurs: 1, indices: [2], vals: ["127.0.0.1:9500"] }, "advertise-addr": MatchedArg { occurs: 1, indices: [4], vals: ["127.0.0.1:9000"] }, "config": MatchedArg { occurs: 1, indices: [8], vals: ["/tmp/tidb_cdc_test/multi_tables_ddl/tiflash-proxy.toml"] }, "data-dir": MatchedArg { occurs: 1, indices: [6], vals: ["/tmp/tidb_cdc_test/multi_tables_ddl/tiflash/db/proxy"] }, "engine-git-hash": MatchedArg { occurs: 1, indices: [10], vals: ["961f9dded38b814bb41b33c691ab58f3f090a0d9"] }, "engine-version": MatchedArg { occurs: 1, indices: [12], vals: ["v8.2.0-alpha-28-g961f9dded"] }, "pd-endpoints": MatchedArg { occurs: 1, indices: [16], vals: ["127.0.0.1:2379"] }, "engine-label": MatchedArg { occurs: 1, indices: [14], vals: ["tiflash"] }}, subcommand: None, usage: Some("USAGE:\n TiFlash Proxy [FLAGS] [OPTIONS] --engine-git-hash <engine-git-hash> --engine-label <engine-label> --engine-version <engine-version>") }
\033[0;36m<<< Run all test success >>>\033[0m
[Pipeline] }
Cache not saved (ws/jenkins-pingcap-tiflow-pull_cdc_integration_kafka_test-2008/tiflow-cdc already exists)
[Pipeline] // cache
[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // withCredentials
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[Pipeline] // container
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // podTemplate
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[Thu May 16 18:39:30 CST 2024] <<<<<< START cdc server in multi_tables_ddl case >>>>>>
+ [[ '' == \t\r\u\e ]]
+ set +e
+ get_info_fail_msg='failed to get info:'
+ etcd_info_msg='etcd info'
+ '[' -z '' ']'
+ curl_status_cmd='curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL'
+ GO_FAILPOINTS=
+ [[ no != \n\o ]]
+ cdc.test -test.coverprofile=/tmp/tidb_cdc_test/cov.multi_tables_ddl.5097050972.out server --log-file /tmp/tidb_cdc_test/multi_tables_ddl/cdc.log --log-level debug --data-dir /tmp/tidb_cdc_test/multi_tables_ddl/cdc_data --cluster-id default
+ (( i = 0 ))
+ (( i <= 50 ))
++ curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL
* About to connect() to 127.0.0.1 port 8300 (#0)
* Trying 127.0.0.1...
* Connection refused
* Failed connect to 127.0.0.1:8300; Connection refused
* Closing connection 0
+ res=
+ echo ''
+ grep -q 'failed to get info:'
+ echo ''
+ grep -q 'etcd info'
+ '[' 0 -eq 50 ']'
+ sleep 3
+ (( i++ ))
+ (( i <= 50 ))
++ curl -vsL --max-time 20 http://127.0.0.1:8300/debug/info --user ticdc:ticdc_secret -vsL
* About to connect() to 127.0.0.1 port 8300 (#0)
* Trying 127.0.0.1...
* Connected to 127.0.0.1 (127.0.0.1) port 8300 (#0)
* Server auth using Basic with user 'ticdc'
> GET /debug/info HTTP/1.1
> Authorization: Basic dGljZGM6dGljZGNfc2VjcmV0
> User-Agent: curl/7.29.0
> Host: 127.0.0.1:8300
> Accept: */*
>
< HTTP/1.1 200 OK
< Date: Thu, 16 May 2024 10:39:33 GMT
< Content-Length: 815
< Content-Type: text/plain; charset=utf-8
<
{ [data not shown]
* Connection #0 to host 127.0.0.1 left intact
+ res='
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/b9c2c077-dd96-44de-a9b1-0e3ddf8481e0
{"id":"b9c2c077-dd96-44de-a9b1-0e3ddf8481e0","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855970}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80fc2228c8
b9c2c077-dd96-44de-a9b1-0e3ddf8481e0
/tidb/cdc/default/default/upstream/7369545231585774717
{"id":7369545231585774717,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ echo '
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/b9c2c077-dd96-44de-a9b1-0e3ddf8481e0
{"id":"b9c2c077-dd96-44de-a9b1-0e3ddf8481e0","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855970}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80fc2228c8
b9c2c077-dd96-44de-a9b1-0e3ddf8481e0
/tidb/cdc/default/default/upstream/7369545231585774717
{"id":7369545231585774717,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ grep -q 'failed to get info:'
+ echo '
*** owner info ***:
*** processors info ***:
*** etcd info ***:
/tidb/cdc/default/__cdc_meta__/capture/b9c2c077-dd96-44de-a9b1-0e3ddf8481e0
{"id":"b9c2c077-dd96-44de-a9b1-0e3ddf8481e0","address":"127.0.0.1:8300","version":"v8.2.0-alpha-46-g6ee8257c6","git-hash":"6ee8257c620525e26b5a3843eb88228669d9f37a","deploy-path":"/home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/bin/cdc.test","start-timestamp":1715855970}
/tidb/cdc/default/__cdc_meta__/meta/meta-version
1
/tidb/cdc/default/__cdc_meta__/owner/22318f80fc2228c8
b9c2c077-dd96-44de-a9b1-0e3ddf8481e0
/tidb/cdc/default/default/upstream/7369545231585774717
{"id":7369545231585774717,"pd-endpoints":"http://127.0.0.1:2379,http://127.0.0.1:2379","key-path":"","cert-path":"","ca-path":"","cert-allowed-cn":null}'
+ grep -q 'etcd info'
+ break
+ set +x
Create changefeed successfully!
ID: test-normal
Info: {"upstream_id":7369545231585774717,"namespace":"default","id":"test-normal","sink_uri":"kafka://127.0.0.1:9092/ticdc-multi-tables-ddl-test-normal-15246?protocol=open-protocol\u0026partition-num=4\u0026kafka-version=2.4.1\u0026max-message-bytes=10485760","create_time":"2024-05-16T18:39:33.873132236+08:00","start_ts":449801347537043457,"config":{"memory_quota":1073741824,"case_sensitive":false,"force_replicate":false,"ignore_ineligible_table":false,"check_gc_safe_point":true,"enable_sync_point":false,"enable_table_monitor":false,"bdr_mode":false,"sync_point_interval":600000000000,"sync_point_retention":86400000000000,"filter":{"rules":["multi_tables_ddl_test.t1","multi_tables_ddl_test.t2","multi_tables_ddl_test.t3","multi_tables_ddl_test.t4","multi_tables_ddl_test.t1_7","multi_tables_ddl_test.t2_7","multi_tables_ddl_test.finish_mark"]},"mounter":{"worker_num":16},"sink":{"protocol":"open-protocol","csv":{"delimiter":",","quote":"\"","null":"\\N","include_commit_ts":true,"binary_encoding_method":"base64","output_old_value":false,"output_handle_key":false},"encoder_concurrency":32,"terminator":"\r\n","date_separator":"day","enable_partition_separator":true,"enable_kafka_sink_v2":false,"only_output_updated_columns":false,"delete_only_output_handle_key_columns":false,"content_compatible":false,"advance_timeout":150,"send_bootstrap_interval_in_sec":120,"send_bootstrap_in_msg_count":10000,"send_bootstrap_to_all_partition":true,"debezium_disable_schema":false,"debezium":{"output_old_value":true},"open":{"output_old_value":true}},"consistent":{"level":"none","max_log_size":64,"flush_interval":2000,"meta_flush_interval":200,"encoding_worker_num":16,"flush_worker_num":8,"use_file_backend":false,"memory_usage":{"memory_quota_percentage":50}},"scheduler":{"enable_table_across_nodes":false,"region_threshold":100000,"write_key_threshold":0},"integrity":{"integrity_check_level":"none","corruption_handle_level":"warn"},"changefeed_error_stuck_duration":1800000000000,"synced_status":{"synced_check_interval":300,"checkpoint_interval":15}},"state":"normal","creator_version":"v8.2.0-alpha-46-g6ee8257c6","resolved_ts":449801347537043457,"checkpoint_ts":449801347537043457,"checkpoint_time":"2024-05-16 18:39:30.524"}
Create changefeed successfully!
ID: test-error-1
Info: {"upstream_id":7369545231585774717,"namespace":"default","id":"test-error-1","sink_uri":"kafka://127.0.0.1:9092/ticdc-multi-tables-ddl-test-error-1-27760?protocol=open-protocol\u0026partition-num=4\u0026kafka-version=2.4.1\u0026max-message-bytes=10485760","create_time":"2024-05-16T18:39:34.071232016+08:00","start_ts":449801347537043457,"config":{"memory_quota":1073741824,"case_sensitive":false,"force_replicate":false,"ignore_ineligible_table":false,"check_gc_safe_point":true,"enable_sync_point":false,"enable_table_monitor":false,"bdr_mode":false,"sync_point_interval":600000000000,"sync_point_retention":86400000000000,"filter":{"rules":["multi_tables_ddl_test.t5","multi_tables_ddl_test.t6","multi_tables_ddl_test.t7","multi_tables_ddl_test.t8"]},"mounter":{"worker_num":16},"sink":{"protocol":"open-protocol","csv":{"delimiter":",","quote":"\"","null":"\\N","include_commit_ts":true,"binary_encoding_method":"base64","output_old_value":false,"output_handle_key":false},"encoder_concurrency":32,"terminator":"\r\n","date_separator":"day","enable_partition_separator":true,"enable_kafka_sink_v2":false,"only_output_updated_columns":false,"delete_only_output_handle_key_columns":false,"content_compatible":false,"advance_timeout":150,"send_bootstrap_interval_in_sec":120,"send_bootstrap_in_msg_count":10000,"send_bootstrap_to_all_partition":true,"debezium_disable_schema":false,"debezium":{"output_old_value":true},"open":{"output_old_value":true}},"consistent":{"level":"none","max_log_size":64,"flush_interval":2000,"meta_flush_interval":200,"encoding_worker_num":16,"flush_worker_num":8,"use_file_backend":false,"memory_usage":{"memory_quota_percentage":50}},"scheduler":{"enable_table_across_nodes":false,"region_threshold":100000,"write_key_threshold":0},"integrity":{"integrity_check_level":"none","corruption_handle_level":"warn"},"changefeed_error_stuck_duration":1800000000000,"synced_status":{"synced_check_interval":300,"checkpoint_interval":15}},"state":"normal","creator_version":"v8.2.0-alpha-46-g6ee8257c6","resolved_ts":449801347537043457,"checkpoint_ts":449801347537043457,"checkpoint_time":"2024-05-16 18:39:30.524"}
Create changefeed successfully!
ID: test-error-2
Info: {"upstream_id":7369545231585774717,"namespace":"default","id":"test-error-2","sink_uri":"kafka://127.0.0.1:9092/ticdc-multi-tables-ddl-test-error-2-12795?protocol=open-protocol\u0026partition-num=4\u0026kafka-version=2.4.1\u0026max-message-bytes=10485760","create_time":"2024-05-16T18:39:34.2710405+08:00","start_ts":449801347537043457,"config":{"memory_quota":1073741824,"case_sensitive":false,"force_replicate":false,"ignore_ineligible_table":false,"check_gc_safe_point":true,"enable_sync_point":false,"enable_table_monitor":false,"bdr_mode":false,"sync_point_interval":600000000000,"sync_point_retention":86400000000000,"filter":{"rules":["multi_tables_ddl_test.t9","multi_tables_ddl_test.t10"]},"mounter":{"worker_num":16},"sink":{"protocol":"open-protocol","csv":{"delimiter":",","quote":"\"","null":"\\N","include_commit_ts":true,"binary_encoding_method":"base64","output_old_value":false,"output_handle_key":false},"encoder_concurrency":32,"terminator":"\r\n","date_separator":"day","enable_partition_separator":true,"enable_kafka_sink_v2":false,"only_output_updated_columns":false,"delete_only_output_handle_key_columns":false,"content_compatible":false,"advance_timeout":150,"send_bootstrap_interval_in_sec":120,"send_bootstrap_in_msg_count":10000,"send_bootstrap_to_all_partition":true,"debezium_disable_schema":false,"debezium":{"output_old_value":true},"open":{"output_old_value":true}},"consistent":{"level":"none","max_log_size":64,"flush_interval":2000,"meta_flush_interval":200,"encoding_worker_num":16,"flush_worker_num":8,"use_file_backend":false,"memory_usage":{"memory_quota_percentage":50}},"scheduler":{"enable_table_across_nodes":false,"region_threshold":100000,"write_key_threshold":0},"integrity":{"integrity_check_level":"none","corruption_handle_level":"warn"},"changefeed_error_stuck_duration":1800000000000,"synced_status":{"synced_check_interval":300,"checkpoint_interval":15}},"state":"normal","creator_version":"v8.2.0-alpha-46-g6ee8257c6","resolved_ts":449801347537043457,"checkpoint_ts":449801347537043457,"checkpoint_time":"2024-05-16 18:39:30.524"}
[Thu May 16 18:39:34 CST 2024] <<<<<< START kafka consumer in multi_tables_ddl case >>>>>>
[Thu May 16 18:39:34 CST 2024] <<<<<< START kafka consumer in multi_tables_ddl case >>>>>>
[Thu May 16 18:39:34 CST 2024] <<<<<< START kafka consumer in multi_tables_ddl case >>>>>>
table multi_tables_ddl_test.t55 exists
table multi_tables_ddl_test.t66 exists
table multi_tables_ddl_test.t7 exists
table multi_tables_ddl_test.t88 exists
table multi_tables_ddl_test.finish_mark not exists for 1-th check, retry later
table multi_tables_ddl_test.finish_mark exists
check table exists success
+ endpoints=http://127.0.0.1:2379
+ changefeed_id=test-normal
+ expected_state=normal
+ error_msg=null
+ tls_dir=
+ [[ http://127.0.0.1:2379 =~ https ]]
++ cdc cli changefeed query --pd=http://127.0.0.1:2379 -c test-normal -s
+ info='{
"upstream_id": 7369545231585774717,
"namespace": "default",
"id": "test-normal",
"state": "normal",
"checkpoint_tso": 449801352019705880,
"checkpoint_time": "2024-05-16 18:39:47.624",
"error": null
}'
+ echo '{
"upstream_id": 7369545231585774717,
"namespace": "default",
"id": "test-normal",
"state": "normal",
"checkpoint_tso": 449801352019705880,
"checkpoint_time": "2024-05-16 18:39:47.624",
"error": null
}'
{
"upstream_id": 7369545231585774717,
"namespace": "default",
"id": "test-normal",
"state": "normal",
"checkpoint_tso": 449801352019705880,
"checkpoint_time": "2024-05-16 18:39:47.624",
"error": null
}
++ echo '{' '"upstream_id":' 7369545231585774717, '"namespace":' '"default",' '"id":' '"test-normal",' '"state":' '"normal",' '"checkpoint_tso":' 449801352019705880, '"checkpoint_time":' '"2024-05-16' '18:39:47.624",' '"error":' null '}'
++ jq -r .state
+ state=normal
+ [[ ! normal == \n\o\r\m\a\l ]]
++ echo '{' '"upstream_id":' 7369545231585774717, '"namespace":' '"default",' '"id":' '"test-normal",' '"state":' '"normal",' '"checkpoint_tso":' 449801352019705880, '"checkpoint_time":' '"2024-05-16' '18:39:47.624",' '"error":' null '}'
++ jq -r .error.message
+ message=null
+ [[ ! null =~ null ]]
+ endpoints=http://127.0.0.1:2379
+ changefeed_id=test-error-1
+ expected_state=normal
+ error_msg=null
+ tls_dir=
+ [[ http://127.0.0.1:2379 =~ https ]]
++ cdc cli changefeed query --pd=http://127.0.0.1:2379 -c test-error-1 -s
+ info='{
"upstream_id": 7369545231585774717,
"namespace": "default",
"id": "test-error-1",
"state": "normal",
"checkpoint_tso": 449801352701280274,
"checkpoint_time": "2024-05-16 18:39:50.224",
"error": null
}'
+ echo '{
"upstream_id": 7369545231585774717,
"namespace": "default",
"id": "test-error-1",
"state": "normal",
"checkpoint_tso": 449801352701280274,
"checkpoint_time": "2024-05-16 18:39:50.224",
"error": null
}'
{
"upstream_id": 7369545231585774717,
"namespace": "default",
"id": "test-error-1",
"state": "normal",
"checkpoint_tso": 449801352701280274,
"checkpoint_time": "2024-05-16 18:39:50.224",
"error": null
}
++ echo '{' '"upstream_id":' 7369545231585774717, '"namespace":' '"default",' '"id":' '"test-error-1",' '"state":' '"normal",' '"checkpoint_tso":' 449801352701280274, '"checkpoint_time":' '"2024-05-16' '18:39:50.224",' '"error":' null '}'
++ jq -r .state
+ state=normal
+ [[ ! normal == \n\o\r\m\a\l ]]
++ echo '{' '"upstream_id":' 7369545231585774717, '"namespace":' '"default",' '"id":' '"test-error-1",' '"state":' '"normal",' '"checkpoint_tso":' 449801352701280274, '"checkpoint_time":' '"2024-05-16' '18:39:50.224",' '"error":' null '}'
++ jq -r .error.message
+ message=null
+ [[ ! null =~ null ]]
+ endpoints=http://127.0.0.1:2379
+ changefeed_id=test-error-2
+ expected_state=failed
+ error_msg=ErrSyncRenameTableFailed
+ tls_dir=
+ [[ http://127.0.0.1:2379 =~ https ]]
++ cdc cli changefeed query --pd=http://127.0.0.1:2379 -c test-error-2 -s
+ info='{
"upstream_id": 7369545231585774717,
"namespace": "default",
"id": "test-error-2",
"state": "failed",
"checkpoint_tso": 449801351652704261,
"checkpoint_time": "2024-05-16 18:39:46.224",
"error": {
"time": "2024-05-16T18:39:47.265734569+08:00",
"addr": "127.0.0.1:8300",
"code": "CDC:ErrSyncRenameTableFailed",
"message": "[CDC:ErrSyncRenameTableFailed]table'\''s old name is not in filter rule, and its new name in filter rule table id '\''130'\'', ddl query: [rename table t11 to t9], it'\''s an unexpected behavior, if you want to replicate this table, please add its old name to filter rule."
}
}'
+ echo '{
"upstream_id": 7369545231585774717,
"namespace": "default",
"id": "test-error-2",
"state": "failed",
"checkpoint_tso": 449801351652704261,
"checkpoint_time": "2024-05-16 18:39:46.224",
"error": {
"time": "2024-05-16T18:39:47.265734569+08:00",
"addr": "127.0.0.1:8300",
"code": "CDC:ErrSyncRenameTableFailed",
"message": "[CDC:ErrSyncRenameTableFailed]table'\''s old name is not in filter rule, and its new name in filter rule table id '\''130'\'', ddl query: [rename table t11 to t9], it'\''s an unexpected behavior, if you want to replicate this table, please add its old name to filter rule."
}
}'
{
"upstream_id": 7369545231585774717,
"namespace": "default",
"id": "test-error-2",
"state": "failed",
"checkpoint_tso": 449801351652704261,
"checkpoint_time": "2024-05-16 18:39:46.224",
"error": {
"time": "2024-05-16T18:39:47.265734569+08:00",
"addr": "127.0.0.1:8300",
"code": "CDC:ErrSyncRenameTableFailed",
"message": "[CDC:ErrSyncRenameTableFailed]table's old name is not in filter rule, and its new name in filter rule table id '130', ddl query: [rename table t11 to t9], it's an unexpected behavior, if you want to replicate this table, please add its old name to filter rule."
}
}
++ jq -r .state
++ echo '{' '"upstream_id":' 7369545231585774717, '"namespace":' '"default",' '"id":' '"test-error-2",' '"state":' '"failed",' '"checkpoint_tso":' 449801351652704261, '"checkpoint_time":' '"2024-05-16' '18:39:46.224",' '"error":' '{' '"time":' '"2024-05-16T18:39:47.265734569+08:00",' '"addr":' '"127.0.0.1:8300",' '"code":' '"CDC:ErrSyncRenameTableFailed",' '"message":' '"[CDC:ErrSyncRenameTableFailed]table'\''s' old name is not in filter rule, and its new name in filter rule table id ''\''130'\'',' ddl query: '[rename' table t11 to 't9],' 'it'\''s' an unexpected behavior, if you want to replicate this table, please add its old name to filter 'rule."' '}' '}'
+ state=failed
+ [[ ! failed == \f\a\i\l\e\d ]]
++ jq -r .error.message
++ echo '{' '"upstream_id":' 7369545231585774717, '"namespace":' '"default",' '"id":' '"test-error-2",' '"state":' '"failed",' '"checkpoint_tso":' 449801351652704261, '"checkpoint_time":' '"2024-05-16' '18:39:46.224",' '"error":' '{' '"time":' '"2024-05-16T18:39:47.265734569+08:00",' '"addr":' '"127.0.0.1:8300",' '"code":' '"CDC:ErrSyncRenameTableFailed",' '"message":' '"[CDC:ErrSyncRenameTableFailed]table'\''s' old name is not in filter rule, and its new name in filter rule table id ''\''130'\'',' ddl query: '[rename' table t11 to 't9],' 'it'\''s' an unexpected behavior, if you want to replicate this table, please add its old name to filter 'rule."' '}' '}'
+ message='[CDC:ErrSyncRenameTableFailed]table'\''s old name is not in filter rule, and its new name in filter rule table id '\''130'\'', ddl query: [rename table t11 to t9], it'\''s an unexpected behavior, if you want to replicate this table, please add its old name to filter rule.'
+ [[ ! [CDC:ErrSyncRenameTableFailed]table's old name is not in filter rule, and its new name in filter rule table id '130', ddl query: [rename table t11 to t9], it's an unexpected behavior, if you want to replicate this table, please add its old name to filter rule. =~ ErrSyncRenameTableFailed ]]
check diff successfully
wait process cdc.test exit for 1-th time...
wait process cdc.test exit for 2-th time...
wait process cdc.test exit for 3-th time...
cdc.test: no process found
wait process cdc.test exit for 4-th time...
process cdc.test already exit
[Thu May 16 18:39:53 CST 2024] <<<<<< run test case multi_tables_ddl success! >>>>>>
Exiting on signal: INTERRUPT
\033[0;36m<<< Run all test success >>>\033[0m
[Pipeline] }
Cache not saved (ws/jenkins-pingcap-tiflow-pull_cdc_integration_kafka_test-2008/tiflow-cdc already exists)
[Pipeline] // cache
[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // withCredentials
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[Pipeline] // container
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // podTemplate
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[90m6:40PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/skip_messages_test.sql
[90m6:40PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/strategy_test.sql
[90m6:40PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/table_column_comment_test.sql
[90m6:40PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/timestamp_column_test.sql
[90m6:40PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/tinyint_test.sql
[90m6:40PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/topic_name_sanitization_test.sql
[90m6:40PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/debezium/unsigned_integer_test.sql
[90m6:41PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mRun[32m [0m[32mcase=[0msql/dml.sql
[90m6:42PM[0m[32m [0m[32mINF[0m[32m [0m[1m[32m>[0m[0m[32m [0mAll tests pass[32m [0m[32mfailed=[0m0[32m [0m[32mpassed=[0m219
[Thu May 16 18:43:07 CST 2024] <<<<<< run test case debezium success! >>>>>>
=================>> Running test /home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/lossy_ddl/run.sh using Sink-Type: kafka... <<=================
[Thu May 16 18:43:19 CST 2024] <<<<<< run test case lossy_ddl success! >>>>>>
=================>> Running test /home/jenkins/agent/workspace/pingcap/tiflow/pull_cdc_integration_kafka_test/tiflow/tests/integration_tests/storage_csv_update/run.sh using Sink-Type: kafka... <<=================
[Thu May 16 18:43:28 CST 2024] <<<<<< run test case storage_csv_update success! >>>>>>
\033[0;36m<<< Run all test success >>>\033[0m
[Pipeline] }
Cache not saved (ws/jenkins-pingcap-tiflow-pull_cdc_integration_kafka_test-2008/tiflow-cdc already exists)
[Pipeline] // cache
[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // withCredentials
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[Pipeline] // container
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // podTemplate
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[Pipeline] // parallel
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // container
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // podTemplate
[Pipeline] End of Pipeline
Finished: SUCCESS
![[Jenkins]](/jenkins/static/62b7ca6c/images/svgs/logo.svg){kind=logo}
