[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321917#comment-17321917
]
xx chai commented on FLINK-22281:
-
Yes, I have added this parameter correctly
> flink s
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321878#comment-17321878
]
xx chai commented on FLINK-22281:
-
thanks [~jark] I solve the question .
> flink sql co
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321856#comment-17321856
]
xx chai commented on FLINK-22281:
-
i add the Parameter
streamTableEnvironment.getConfi
[
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 kafka_mall_ord
[
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 kafka_mall_ord
[
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)
> --
[
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 kafka_mall_ord
[
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
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
-
[
https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260938#comment-17260938
]
xx chai edited comment on FLINK-20870 at 1/8/21, 6:59 AM:
--
!16
[
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
>
[
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: FLINK-
[
https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260939#comment-17260939
]
xx chai commented on FLINK-20870:
-
this is my program
> FlinkKafkaSink
> -
[
https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260938#comment-17260938
]
xx chai commented on FLINK-20870:
-
!1610072517(1).jpg!
> FlinkKafkaSink
> ---
[
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
>
[
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: FLINK-20870
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 / Data
[
https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255497#comment-17255497
]
xx chai commented on FLINK-20780:
-
I may have found the reason，sql-client is not shut-do
[
https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255442#comment-17255442
]
xx chai commented on FLINK-20780:
-
[^ps-flink-process.txt]
the flie is I execute aux |
[
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
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255407#comment-17255407
]
xx chai commented on FLINK-20780:
-
There is only one node in my cluster,the cluster is m
[
https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255393#comment-17255393
]
xx chai commented on FLINK-20780:
-
export HADOOP_HOME=/opt/cloudera/parcels/CDH/lib/hado
[
https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255387#comment-17255387
]
xx chai commented on FLINK-20780:
-
Every time i restart the cluster after you change j
[
https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255375#comment-17255375
]
xx chai commented on FLINK-20780:
-
I have deleted {{flink-connector-hive_2.11-1.12.0.ja
[
https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255369#comment-17255369
]
xx chai edited comment on FLINK-20780 at 12/28/20, 3:59 AM:
[
https://issues.apache.org/jira/browse/FLINK-20780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255369#comment-17255369
]
xx chai commented on FLINK-20780:
-
Flink version is 1.12
> Flink-sql-client query hive
[
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
>
>
>
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: Tabl
28 matches
Mail list logo
