版本;2.0.3
数据通过flink-cdc从MYSQL同步的关系表。
表结构如下:
CREATE TABLE ac_cu_permission_account
(
PERMISSION_ID
bigint(20) NULL,
ACCOUNT_ID
bigint(20) NULL
) ENGINE=OLAP
UNIQUE KEY(PERMISSION_ID
, ACCOUNT_ID
)
COMMENT 'OLAP'
DISTRIBUTED BY HASH(PERMISSION_ID
, ACCOUNT_ID
) BUCKETS 1
PROPERTIES (
"replication_allocation" = "tag.location.default: 3",
"is_being_synced" = "false",
"storage_format" = "V2",
"light_schema_change" = "true",
"disable_auto_compaction" = "false",
"enable_single_replica_compaction" = "false"
);
同步后表中数据count()为83条,大概两天左右数据count()会变成到72条。期间排查过没有业务库操作,没有数据变更同步过来。重新同步后还是会复现。怀疑是不是内部什么机制导致的。难道是UNIQUE KEY不能只设置key,没有value吗?