[jira] [Commented] (FLINK-17874) Writing to hbase throws NPE

[ https://issues.apache.org/jira/browse/FLINK-17874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113747#comment-17113747 ] chaiyongqiang commented on FLINK-17874: --- When writing a filed to hbase, we seriali

[jira] [Created] (FLINK-17874) Writing to hbase throws NPE

chaiyongqiang created FLINK-17874: - Summary: Writing to hbase throws NPE Key: FLINK-17874 URL: https://issues.apache.org/jira/browse/FLINK-17874 Project: Flink Issue Type: Bug Compo

[jira] [Commented] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17061326#comment-17061326 ] chaiyongqiang commented on FLINK-16626: ---  Maybe you'ra right. As far as i see, *fl

[jira] [Commented] (FLINK-16637) Flink per job mode terminates before serving job cancellation result

[ https://issues.apache.org/jira/browse/FLINK-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17061323#comment-17061323 ] chaiyongqiang commented on FLINK-16637: --- Hi, [~tison], i see this problem too.  I

[jira] [Updated] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chaiyongqiang updated FLINK-16626: -- Summary: Exception encountered when cancelling a job in yarn per-job mode (was: Exception nco

[jira] [Updated] (FLINK-16626) Exception ncountered when cancelling a job in yarn per-job mode

[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chaiyongqiang updated FLINK-16626: -- Summary: Exception ncountered when cancelling a job in yarn per-job mode (was: Exception Enco

[jira] [Comment Edited] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode

[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060639#comment-17060639 ] chaiyongqiang edited comment on FLINK-16626 at 3/17/20, 5:12 AM: -

[jira] [Commented] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode

[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060639#comment-17060639 ] chaiyongqiang commented on FLINK-16626: --- In my opinion, when the client call an ca

[jira] [Updated] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode

[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chaiyongqiang updated FLINK-16626: -- Description: When executing the following command to stop a flink job with yarn per-job mode,

[jira] [Created] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode

chaiyongqiang created FLINK-16626: - Summary: Exception Encountered when cancelling a job in yarn per-job mode Key: FLINK-16626 URL: https://issues.apache.org/jira/browse/FLINK-16626 Project: Flink

[jira] [Commented] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995396#comment-16995396 ] chaiyongqiang commented on FLINK-14719: --- [~jark], thanks. I'll handle this mysel

[jira] [Updated] (FLINK-15221) supporting Exactly-once for kafka table APi

[ https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chaiyongqiang updated FLINK-15221: -- Summary: supporting Exactly-once for kafka table APi (was: supporting Exactly-once for table

[jira] [Commented] (FLINK-15221) supporting Exactly-once for table APi

[ https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995247#comment-16995247 ] chaiyongqiang commented on FLINK-15221: --- [~jark] thanks . You're right . But i've 

[jira] [Created] (FLINK-15221) supporting Exactly-once for table APi

chaiyongqiang created FLINK-15221: - Summary: supporting Exactly-once for table APi Key: FLINK-15221 URL: https://issues.apache.org/jira/browse/FLINK-15221 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-14871) Better formatter of toString method for StateTransition

chaiyongqiang created FLINK-14871: - Summary: Better formatter of toString method for StateTransition Key: FLINK-14871 URL: https://issues.apache.org/jira/browse/FLINK-14871 Project: Flink Iss

[jira] [Comment Edited] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16972243#comment-16972243 ] chaiyongqiang edited comment on FLINK-13052 at 11/12/19 10:08 AM:

[jira] [Commented] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16972243#comment-16972243 ] chaiyongqiang commented on FLINK-13052: --- There're some limits when we support mult

[jira] [Comment Edited] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16972191#comment-16972191 ] chaiyongqiang edited comment on FLINK-14719 at 11/12/19 8:55 AM: -

[jira] [Commented] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16972191#comment-16972191 ] chaiyongqiang commented on FLINK-14719: --- when i check the code in branch Flink 1.9

[jira] [Created] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

chaiyongqiang created FLINK-14719: - Summary: Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API Key: FLINK-14719 URL: https://issues.apache.org/jira/browse/FLINK-1471

[jira] [Commented] (FLINK-12979) Sending data to kafka with CsvRowSerializationSchema always adding a "\n", "\r","\r\n" at the end of the message

[ https://issues.apache.org/jira/browse/FLINK-12979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915176#comment-16915176 ] chaiyongqiang commented on FLINK-12979: --- #9529 > Sending data to kafka with CsvRo

[jira] [Created] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

chaiyongqiang created FLINK-13052: - Summary: Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource Key: FLINK-13052 URL: https://issues.apache.org/jira/browse/FLINK-13052

[jira] [Commented] (FLINK-12979) Sending data to kafka with CsvRowSerializationSchema always adding a "\n", "\r","\r\n" at the end of the message

[ https://issues.apache.org/jira/browse/FLINK-12979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16876735#comment-16876735 ] chaiyongqiang commented on FLINK-12979: --- When i check com.fasterxml.jackson.dataf

[jira] [Created] (FLINK-12979) Sending data to kafka with CsvRowSerializationSchema always adding a "\n", "\r","\r\n" at the end of the message

chaiyongqiang created FLINK-12979: - Summary: Sending data to kafka with CsvRowSerializationSchema always adding a "\n", "\r","\r\n" at the end of the message Key: FLINK-12979 URL: https://issues.apache.org/jira/br

[jira] [Commented] (FLINK-12622) The process function compiles error in MyProcessWindowFunction in windows.md

[ https://issues.apache.org/jira/browse/FLINK-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848003#comment-16848003 ] chaiyongqiang commented on FLINK-12622: --- [https://github.com/apache/flink/pull/854

[jira] [Created] (FLINK-12622) The process function compiles error in MyProcessWindowFunction in windows.md

chaiyongqiang created FLINK-12622: - Summary: The process function compiles error in MyProcessWindowFunction in windows.md Key: FLINK-12622 URL: https://issues.apache.org/jira/browse/FLINK-12622 Projec

[jira] [Commented] (FLINK-11926) The Description of Assigners allowing a fixed amount of lateness is not correct

[ https://issues.apache.org/jira/browse/FLINK-11926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795518#comment-16795518 ] chaiyongqiang commented on FLINK-11926: --- I'm confused. Let's consider the simpler

[jira] [Updated] (FLINK-11926) The Description of Assigners allowing a fixed amount of lateness is not correct

[ https://issues.apache.org/jira/browse/FLINK-11926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chaiyongqiang updated FLINK-11926: -- Attachment: screenshot-1.png > The Description of Assigners allowing a fixed amount of latenes

[jira] [Commented] (FLINK-11926) The Description of Assigners allowing a fixed amount of lateness is not correct

[ https://issues.apache.org/jira/browse/FLINK-11926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794104#comment-16794104 ] chaiyongqiang commented on FLINK-11926: --- Let's suppose we hava a watermark with a

[jira] [Created] (FLINK-11926) The Description of Assigners allowing a fixed amount of lateness is not correct

chaiyongqiang created FLINK-11926: - Summary: The Description of Assigners allowing a fixed amount of lateness is not correct Key: FLINK-11926 URL: https://issues.apache.org/jira/browse/FLINK-11926 Pro