[jira] [Commented] (FLINK-37233) Flink-CDC Documentation change request

[ https://issues.apache.org/jira/browse/FLINK-37233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17921981#comment-17921981 ] qinghuan wang commented on FLINK-37233: --- Could you cherry pick this commit to rele

[jira] [Commented] (FLINK-37233) Flink-CDC Documentation change request

[ https://issues.apache.org/jira/browse/FLINK-37233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17921786#comment-17921786 ] qinghuan wang commented on FLINK-37233: --- I'll take it. https://github.com/apache/f

[jira] [Commented] (FLINK-37200) Add e2e test for ElasticSearch Sink.

[ https://issues.apache.org/jira/browse/FLINK-37200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17921621#comment-17921621 ] qinghuan wang commented on FLINK-37200: --- https://github.com/apache/flink-cdc/pull/

[jira] [Commented] (FLINK-36782) Incorrect comment syntax

[ https://issues.apache.org/jira/browse/FLINK-36782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916686#comment-17916686 ] qinghuan wang commented on FLINK-36782: --- [~calelinflink] hi, I create a PR to fix.

[jira] [Commented] (FLINK-37200) Add e2e test for ElasticSearch Sink.

[ https://issues.apache.org/jira/browse/FLINK-37200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916657#comment-17916657 ] qinghuan wang commented on FLINK-37200: --- hi, are you working on it?   if not,  I w

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

[ https://issues.apache.org/jira/browse/FLINK-37216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916465#comment-17916465 ] qinghuan wang commented on FLINK-37216: --- [https://github.com/apache/flink-cdc/pull

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

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] [Commented] (FLINK-37177) Update chinese documentation of json function

[ https://issues.apache.org/jira/browse/FLINK-37177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916092#comment-17916092 ] qinghuan wang commented on FLINK-37177: --- hi, can you assign this one to me? [~gust

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

[ https://issues.apache.org/jira/browse/FLINK-24681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qinghuan wang updated FLINK-24681: -- Description: When create a Kafka Table {code:java} CREATE TABLE KafkaTable (   ... ) WITH (  

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

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

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

[jira] [Updated] (FLINK-23197) Errorneous description about 'TIMESTAMP WITH TIME ZONE' date type

[ https://issues.apache.org/jira/browse/FLINK-23197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qinghuan wang updated FLINK-23197: -- Description: Currently, Flink dont support 'TIMESTAMP WITH TIME ZONE' type.  We should add  n