[jira] [Created] (FLINK-37279) Add Flink CDC Pipeline Clickhouse connector

2025-02-07 Thread qinghuan wang (Jira)
qinghuan wang created FLINK-37279: - Summary: Add Flink CDC Pipeline Clickhouse connector Key: FLINK-37279 URL: https://issues.apache.org/jira/browse/FLINK-37279 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-37216) Default MAX_BATCH_SIZE_IN_BYTES is less than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions

2025-01-23 Thread qinghuan wang (Jira)
qinghuan wang created FLINK-37216: - Summary: Default MAX_BATCH_SIZE_IN_BYTES is less than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions Key: FLINK-37216 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-24681) org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions

2021-10-28 Thread qinghuan wang (Jira)
qinghuan wang created FLINK-24681: - Summary: org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions Key: FLINK-24681 URL: https://issues.apache.org/

[jira] [Created] (FLINK-24672) [ WARN ] javax.management.InstanceAlreadyExistsException

2021-10-27 Thread qinghuan wang (Jira)
qinghuan wang created FLINK-24672: - Summary: [ WARN ] javax.management.InstanceAlreadyExistsException Key: FLINK-24672 URL: https://issues.apache.org/jira/browse/FLINK-24672 Project: Flink Is