[
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_order_info (
id int,
amount double,
PRIMARY KEY ( id) NOT ENFORCED
) WITH (
'connector' = 'kafka',
'topic' = 'topic_yx-dc-3-102_3306',
'properties.bootstrap.servers' =
'192.168.3.100:9092,192.168.3.101:9092,192.168.3.102:9092',
'properties.group.id' = 'kafka_to_hive',
'scan.startup.mode' = 'latest-offset',
'format' = 'canal-json');
create table t2 (amount double) with ('connector' = 'print');
insert into t2 select sum(amount) from kafka_mall_order_info ;
but the result is not i think
the result in image
was:
I use flink sql to consumer kafka canal-json message the sql is
CREATE TABLE kafka_mall_order_info (
id int,
amount double,
PRIMARY KEY ( id) NOT ENFORCED
) WITH (
'connector' = 'kafka',
'topic' = 'topic_yx-dc-3-102_3306',
'properties.bootstrap.servers' =
'192.168.3.100:9092,192.168.3.101:9092,192.168.3.102:9092',
'properties.group.id' = 'kafka_to_hive',
'scan.startup.mode' = 'latest-offset',
'format' = 'canal-json');
create table t2 (amount double) with ('connector' = 'print');
insert into t2 select sum(amount) from kafka_mall_order_info ;
but the result is not i think
> flink sql consumer kakfa canal-json message then sum(amount)
> --------------------------------------------------------------
>
> Key: FLINK-22281
> URL: https://issues.apache.org/jira/browse/FLINK-22281
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Affects Versions: 1.12.0
> Environment: flink 1.12 local
> Reporter: xx chai
> Priority: Major
> Attachments: screenshot-1.png
>
>
> I use flink sql to consumer kafka canal-json message the sql is
> CREATE TABLE kafka_mall_order_info (
> id int,
> amount double,
> PRIMARY KEY ( id) NOT ENFORCED
> ) WITH (
> 'connector' = 'kafka',
> 'topic' = 'topic_yx-dc-3-102_3306',
> 'properties.bootstrap.servers' =
> '192.168.3.100:9092,192.168.3.101:9092,192.168.3.102:9092',
> 'properties.group.id' = 'kafka_to_hive',
> 'scan.startup.mode' = 'latest-offset',
> 'format' = 'canal-json');
> create table t2 (amount double) with ('connector' = 'print');
>
>
> insert into t2 select sum(amount) from kafka_mall_order_info ;
> but the result is not i think
> the result in image
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
