zhushanwei

消费者信息获取失败，LogiKM 2.6.0

2

022-05-25 11:30:30.020 [pool-20-thread-15] ERROR c.x.k.manager.task.component.AbstractScheduledTask - customScheduled task running, but without registrant, and so sch eduled tasks can't execute, scheduledName:newCollectAndPublishCGData. 2022-05-25 11:31:15.136 [pool-20-thread-11] ERROR c.x.kafka.manager.service.cache.KafkaClientPool - create kafka admin client...

Cannot commit, found new delete for replaced data file

4

### Query engine iceberg-flink-runtime-1.14-0.14.0.jar，help me，Thanks ### Question org.apache.iceberg.exceptions.ValidationException: Cannot commit, found new delete for replaced data file: GenericDataFile{content=data, file_path=hdfs://dev-001:8020/iceberg/flink_hive_iceberg/flink_hive_db.db/test_repository_1/data/news_postdate=2022-07-31/00002-0-8b3590ea-a593-4734-b84a-a6084a426b95-00093.parquet, file_format= PARQUET, spec_id=0, partition=PartitionData{news_postdate=2022-07-31}, record_count=106, file_size_in_bytes=110049, column_sizes=null, value_counts=null, null_value_co unts=null, nan_value_counts=null,...