[jira] [Created] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
xx chai created FLINK-20780: --- Summary: Flink-sql-client query hive Key: FLINK-20780 URL: https://issues.apache.org/jira/browse/FLINK-20780 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255375#comment-17255375 ] xx chai commented on FLINK-20780: - I have deleted  {{flink-connector-hive_2.11-1.12.0.jar}}, 

[jira] [Commented] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255387#comment-17255387 ] xx chai commented on FLINK-20780: - Every time  i restart the cluster  after you change jars in the lib

[jira] [Commented] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255393#comment-17255393 ] xx chai commented on FLINK-20780: - export HADOOP_HOME=/opt/cloudera/parcels/CDH/lib/hadoop export

[jira] [Commented] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255407#comment-17255407 ] xx chai commented on FLINK-20780: - There is only one node in my cluster,the cluster is my test cluster

[jira] [Updated] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20780: Attachment: 1609127183(1).png > Flink-sql-client query hive > > >

[jira] [Comment Edited] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255369#comment-17255369 ] xx chai edited comment on FLINK-20780 at 12/28/20, 3:59 AM: Flink version is

[jira] [Commented] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255369#comment-17255369 ] xx chai commented on FLINK-20780: - Flink version is 1.12 > Flink-sql-client query hive >

[jira] [Created] (FLINK-20870) FlinkKafkaSink

2021-01-06 Thread xx chai (Jira)
xx chai created FLINK-20870: --- Summary: FlinkKafkaSink Key: FLINK-20870 URL: https://issues.apache.org/jira/browse/FLINK-20870 Project: Flink Issue Type: Improvement Components: API /

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

2021-01-06 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20870: Issue Type: Bug (was: Improvement) > FlinkKafkaSink > -- > > Key:

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20870: Attachment: 1610089153(1).png > FlinkKafkaSink > -- > > Key: FLINK-20870 >

[jira] [Comment Edited] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260938#comment-17260938 ] xx chai edited comment on FLINK-20870 at 1/8/21, 6:59 AM: -- !1610089153(1).png!

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20870: Attachment: (was: 1610072517(1).jpg) > FlinkKafkaSink > -- > > Key:

[jira] [Commented] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260938#comment-17260938 ] xx chai commented on FLINK-20870: - !1610072517(1).jpg! > FlinkKafkaSink > -- > >

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20870: Attachment: 1610072517(1).jpg > FlinkKafkaSink > -- > > Key: FLINK-20870 >

[jira] [Commented] (FLINK-20870) FlinkKafkaSink

2021-01-07 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260939#comment-17260939 ] xx chai commented on FLINK-20870: - this is my program > FlinkKafkaSink > -- > >

[jira] [Commented] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255442#comment-17255442 ] xx chai commented on FLINK-20780: - [^ps-flink-process.txt] the flie is I execute aux | grep

[jira] [Updated] (FLINK-20780) Flink-sql-client query hive

2020-12-27 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20780: Attachment: ps-flink-process.txt > Flink-sql-client query hive > > >

[jira] [Commented] (FLINK-20780) Flink-sql-client query hive

2020-12-28 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255497#comment-17255497 ] xx chai commented on FLINK-20780: - I may have found the reason，sql-client is not shut-down when ctrl+z

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

2021-04-14 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Component/s: Table SQL / API Affects Version/s: 1.12.0 Description: I use flink sql to

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

2021-04-14 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Description: I use flink sql to consumer kafka canal-json message the sql is CREATE TABLE

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

2021-04-14 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Description: I use flink sql to consumer kafka canal-json message the sql is CREATE TABLE

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

2021-04-14 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Attachment: screenshot-1.png > flink sql consumer kakfa canal-json message then sum(amount) >

[jira] [Updated] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

2021-04-14 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-22281: Description: I use flink sql to consumer kafka canal-json message the sql is CREATE TABLE

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

2021-04-14 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321856#comment-17321856 ] xx chai commented on FLINK-22281: - i add the Parameter

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

2021-04-14 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321878#comment-17321878 ] xx chai commented on FLINK-22281: - thanks [~jark] I solve the question . > flink sql consumer kakfa

[jira] [Created] (FLINK-22281) flink sql

2021-04-14 Thread xx chai (Jira)
xx chai created FLINK-22281: --- Summary: flink sql Key: FLINK-22281 URL: https://issues.apache.org/jira/browse/FLINK-22281 Project: Flink Issue Type: Improvement Reporter: xx chai

[jira] [Commented] (FLINK-22281) flink sql consumer kakfa canal-json message then sum(amount)

2021-04-14 Thread xx chai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321917#comment-17321917 ] xx chai commented on FLINK-22281: - Yes, I have added this parameter correctly > flink sql consumer