[2026-07-09 15:24:34.998] INFO handle barrier binlog, ignore it job=ccr_flink_to_406 line=ccr/job.go:3272
[2026-07-09 15:24:34.998] INFO all table/partition commit seq reach the commit seq, switch to incremental sync, commit seq: 237194 job=ccr_flink_to_406 line=ccr/job.go:3364
[2026-07-09 15:24:35.002] INFO begin txn 7036, label: ccrj-16e6:db_sync:1783415661923:1783580613612:237202, db: 1783580613612 job=ccr_flink_to_406 line=ccr/job_pipeline.go:682
[2026-07-09 15:24:35.012] WARN txn 7036 ingest binlog: prepare table 1783416187018 failed, err: [meta] index ids is empty, dropped tables map[], dropped partitions map[], dropped indexes map[] job=ccr_flink_to_406 line=ccr/ingest_binlog_job.go:711
[2026-07-09 15:24:35.012] WARN a meta error occurred, retry to handle upsert binlog again, commitSeq: 237202 job=ccr_flink_to_406 line=ccr/job_pipeline.go:742
[2026-07-09 15:24:35.017] WARN txn 7036 ingest binlog: prepare table 1783416187018 failed, err: [meta] index ids is empty, dropped tables map[], dropped partitions map[], dropped indexes map[] job=ccr_flink_to_406 line=ccr/ingest_binlog_job.go:711
[2026-07-09 15:24:35.017] WARN job sync failed, job: ccr_flink_to_406, err: [meta] index ids is empty
github.com/selectdb/ccr_syncer/pkg/ccr.(*IngestBinlogJob).preparePartition
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/ingest_binlog_job.go:487
github.com/selectdb/ccr_syncer/pkg/ccr.(*IngestBinlogJob).prepareTable
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/ingest_binlog_job.go:678
github.com/selectdb/ccr_syncer/pkg/ccr.(*IngestBinlogJob).prepareTabletIngestJobs
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/ingest_binlog_job.go:707
github.com/selectdb/ccr_syncer/pkg/ccr.(*IngestBinlogJob).Prepare
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/ingest_binlog_job.go:901
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).prepareIngestJob
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job_pipeline.go:771
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).prepareIngestJobWithRetry
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job_pipeline.go:743
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).launchIngestJob
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job_pipeline.go:695
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).launchTxn
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job_pipeline.go:539
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).pipelineSync
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job_pipeline.go:251
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).incrementalSync
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job.go:3866
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).dbTablesIncrementalSync
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job.go:4005
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).dbSync
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job.go:4015
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).sync
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job.go:4069
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).run
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job.go:4136
github.com/selectdb/ccr_syncer/pkg/ccr.(*Job).Run
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job.go:4275
github.com/selectdb/ccr_syncer/pkg/ccr.(*JobManager).runJob.func1
/data/data5/ccr-syncer/ccr-syncer/pkg/ccr/job_manager.go:210
runtime.goexit
/data/data5/maochuan/.local/opt/go/1.22.12/src/runtime/asm_amd64.s:1695 job=ccr_flink_to_406 line=ccr/job.go:4145
[2026-07-09 15:24:35.018] WARN receive meta category error, make new snapshot, job: ccr_flink_to_406, err: [meta] index ids is empty job=ccr_flink_to_406 line=ccr/job.go:4097
[2026-07-09 15:24:35.018] INFO new snapshot, commitSeq: 237194, prevCommitSeq: 237194, prevSyncState: DBIncrementalSync, prevSubSyncState: LaunchTransaction job=ccr_flink_to_406 line=ccr/job.go:4153
[2026-07-09 15:24:37.506] INFO fullsync status: create snapshot with prefix ccrs_ccr_flink_to_406_1783581061 job=ccr_flink_to_406 line=ccr/job.go:1080
[2026-07-09 15:24:37.514] INFO fullsync status: create snapshot ccrs_ccr_flink_to_406_1783581061_1783581877 job=ccr_flink_to_406 line=ccr/job.go:1127
[2026-07-09 15:24:37.514] INFO create snapshot flink.ccrs_ccr_flink_to_406_1783581061_1783581877, backup snapshot sql: BACKUP SNAPSHOT flink.ccrs_ccr_flink_to_406_1783581061_1783581877 TO __keep_on_local__ PROPERTIES ("type" = "full") job=ccr_flink_to_406 line=base/spec.go:820
[2026-07-09 15:24:40.507] INFO check snapshot ccrs_ccr_flink_to_406_1783581061_1783581877 backup state: [SNAPSHOTING] job=ccr_flink_to_406 line=base/spec.go:892
[2026-07-09 15:24:43.146] INFO begin txn 92464, label: ccrj-ee33:db_sync:17355250:1783415661923:171113471, db: 1783415661923 job=ccr_flink_to_314 line=ccr/job_pipeline.go:682
[2026-07-09 15:24:43.154] INFO txn 92464 ingest binlog: run 10 tablet ingest jobs line=ccr/ingest_binlog_job.go:720
[2026-07-09 15:24:43.155] INFO begin txn 92465, label: ccrj-d3ba:db_sync:17355250:1783415661923:171113473, db: 1783415661923 job=ccr_flink_to_314 line=ccr/job_pipeline.go:682
[2026-07-09 15:24:43.162] INFO txn 92465 ingest binlog: run 10 tablet ingest jobs line=ccr/ingest_binlog_job.go:720
[2026-07-09 15:24:43.164] INFO begin txn 92466, label: ccrj-40f1:db_sync:17355250:1783415661923:171113475, db: 1783415661923 job=ccr_flink_to_314 line=ccr/job_pipeline.go:682，
报错的表结构，
源表：
CREATE TABLE orderpayment (
oid bigint NULL,
parentId bigint NULL,
createdOn datetime(6) NULL,
updatedOn datetime(6) NULL,
createdBy bigint NULL,
updatedBy bigint NULL,
Amount decimal(16,2) NULL,
Code varchar(192) NULL,
DocStatus varchar(765) NULL,
Memo varchar(600) NULL,
OrderOrgId bigint NULL,
OutTradeNo varchar(192) NULL,
PaymentAccountId bigint NULL,
PaymentModeId bigint NULL,
PaymentTime datetime(6) NULL,
RelatedDocId bigint NULL,
SellerAccountId bigint NULL,
SellerOrgId bigint NULL,
VoucherImage text NULL,
WeChatPayFlowNo varchar(765) NULL,
PaymentMemo varchar(600) NULL,
ConfirmPaymentTime datetime(6) NULL,
Operator bigint NULL,
AmountPaidBack decimal(16,4) NULL,
AmountRefunded decimal(16,4) NULL,
IsSepAcct varchar(30) NULL,
IsTPPymt varchar(30) NULL,
PymtProductId bigint NULL,
SepAcctRuleId bigint NULL,
ServiceCharge decimal(16,4) NULL,
TPPymtInfoId bigint NULL,
RelatedDocNo varchar(192) NULL,
RelatedDocType varchar(192) NULL,
creditAccountType varchar(15) NULL
) ENGINE=OLAP
UNIQUE KEY(oid)
DISTRIBUTED BY HASH(oid) BUCKETS AUTO
PROPERTIES (
"replication_allocation" = "tag.location.default: 3",
"min_load_replica_num" = "-1",
"is_being_synced" = "true",
"storage_medium" = "hdd",
"storage_format" = "V2",
"inverted_index_storage_format" = "DEFAULT",
"enable_unique_key_merge_on_write" = "false",
"light_schema_change" = "true",
"disable_auto_compaction" = "false",
"binlog.enable" = "true",
"binlog.ttl_seconds" = "86400",
"binlog.max_bytes" = "9223372036854775807",
"binlog.max_history_nums" = "9223372036854775807",
"enable_single_replica_compaction" = "false",
"group_commit_interval_ms" = "10000",
"group_commit_data_bytes" = "134217728"
);
目标表：
CREATE TABLE orderpayment (
oid bigint NULL,
parentId bigint NULL,
createdOn datetime(6) NULL,
updatedOn datetime(6) NULL,
createdBy bigint NULL,
updatedBy bigint NULL,
Amount decimal(16,2) NULL,
Code varchar(192) NULL,
DocStatus varchar(765) NULL,
Memo varchar(600) NULL,
OrderOrgId bigint NULL,
OutTradeNo varchar(192) NULL,
PaymentAccountId bigint NULL,
PaymentModeId bigint NULL,
PaymentTime datetime(6) NULL,
RelatedDocId bigint NULL,
SellerAccountId bigint NULL,
SellerOrgId bigint NULL,
VoucherImage text NULL,
WeChatPayFlowNo varchar(765) NULL,
PaymentMemo varchar(600) NULL,
ConfirmPaymentTime datetime(6) NULL,
Operator bigint NULL,
AmountPaidBack decimal(16,4) NULL,
AmountRefunded decimal(16,4) NULL,
IsSepAcct varchar(30) NULL,
IsTPPymt varchar(30) NULL,
PymtProductId bigint NULL,
SepAcctRuleId bigint NULL,
ServiceCharge decimal(16,4) NULL,
TPPymtInfoId bigint NULL,
RelatedDocNo varchar(192) NULL,
RelatedDocType varchar(192) NULL,
creditAccountType varchar(15) NULL
) ENGINE=OLAP
UNIQUE KEY(oid)
DISTRIBUTED BY HASH(oid) BUCKETS AUTO
PROPERTIES (
"replication_allocation" = "tag.location.default: 3",
"min_load_replica_num" = "-1",
"is_being_synced" = "true",
"storage_medium" = "hdd",
"storage_format" = "V2",
"inverted_index_storage_format" = "DEFAULT",
"compression" = "LZ4F",
"enable_unique_key_merge_on_write" = "false",
"light_schema_change" = "true",
"disable_auto_compaction" = "false",
"binlog.enable" = "true",
"binlog.ttl_seconds" = "86400",
"binlog.max_bytes" = "9223372036854775807",
"binlog.max_history_nums" = "9223372036854775807",
"enable_single_replica_compaction" = "false",
"group_commit_interval_ms" = "10000",
"group_commit_data_bytes" = "134217728"
);
源端和目标端都是一模一样的，syncer 版本：ccr-syncer-4.0.1-rc03-x64
