Hi, Youzha
Sorry for the late reply. It seems that the type is mis-type-match.
Could you
1. tableA.printSchema to print the schema?
2. KafkaSource.getType() to print the typeinformation?
Best,
Guowei
On Mon, Nov 23, 2020 at 5:28 PM Youzha wrote:
> Hi, this is sample code :
>
>
> Table tableA =
Could you share your code?
Best,
Guowei
On Mon, Nov 23, 2020 at 12:05 PM tkg_cangkul wrote:
> Hi,
>
> i'm using java for do this thing.
> and i've success to register the tables.
>
> i've success to select each table.
>
> Table result1 = tEnv.sqlQuery("select status_code from table_kafka");
> T
Hi,
i'm using java for do this thing.
and i've success to register the tables.
i've success to select each table.
Table result1 = tEnv.sqlQuery("select status_code from table_kafka");
Table result2 = tEnv.sqlQuery("select status_code from table_mysql_reff");
but when i try join query i've some
Hi
One way would look like as following
1. create the probe table from Kafka as following. You could find more
detailed information from doc[1]
CREATE TABLE myTopic (
id BIGINT,
item_id BIGINT,
category_id BIGINT,
behavior STRING,
ts TIMESTAMP(3)) WITH (
'connector' = 'kafka',
'topic' = 'us
Hi Guowei Ma,
Thanks for your reply,
In my case.
I've some data on my kafka topic. and i want to get the detail of the
data from my reference mysql table.
for example :
in my kafka topic i've this fields :
id, name, position, experience
in my reference mysql table i've this fields:
id, name
Hi, Youzha
In general `CoGroup` is for the window based operation. How it could
satisfy your requirements depends on your specific scenario. But if you
want to look at the mysql table as a dimension table. There might be other
two ways:
1. Using Table/Sql SDK. You could find a sql example(tempora
Hi i want to do join reference between kafka with mysql table reference.
how can i do this thing with flink stream. does coGroup function can handle
this ? or anyone have java sample code with this case? i’ve read some
article that said if cogroup function can do left outer join. but i’m still
conf
