accoring to
user-defined Sources & Sinks. Have any other ways to read data from FTP?
Appreciating any suggestions.
1095193...@qq.com
://cwiki.apache.org/confluence/display/KAFKA/KIP-83+-+Allow+multiple+SASL+authenticated+Java+clients+in+a+single+JVM+process.
How to acheive this in Flink sql task?
1095193...@qq.com
Hi
For example , a table like this:
A B C
--
a1 b1c1,c2,c3
---
how to split c1,c2,c3 into multiple rows like this in flink sql function:
A B C
a1 b1 c1
a1 b1 c2
a1 b1 c3 Thank you
1095193...@qq.com
?
Thank you
1095193...@qq.com
configuration rather than state.checkpoints.dir. Thanks for
any suggestions.
1095193...@qq.com
;172.16.1.109:8080"}
Flink still output result as not affected by changes to dimension table:
+I[172.16.1.109:8080, 56.32.15.55:8080]
Expect result: +I[172.16.1.109:8080, 56.32.15.54:8080]
Could you give me some suggestions why regualar join result not be affected
by changes to dimension table in mytest? Appreciation.
1095193...@qq.com
Thanks @JING ZHANG @Yun Gao. I will use processing time temporal join. BTW,
would we support read changelog for JDBC source when it works as right stream
of a regular join in future?
1095193...@qq.com
From: JING ZHANG
Date: 2021-06-04 18:32
To: Yun Gao
CC: 1095193...@qq.com; user
Subject
Hi community,
Now I have a timestamp field with format '-MM-dd HH:mm:ss', such as
'2021-06-29 09:00:00'. How to convert this field to iso 8601 time with offset
, such as '2021-06-29T09:00:00+08:00'?
Thanks.
1095193...@qq.com
w I have a timestamp field with format '-MM-dd HH:mm:ss', such as
'2021-06-29 09:00:00'. How to convert this field to iso 8601 time with offset
, such as '2021-06-29T09:00:00+08:00'?
Thanks.
1095193...@qq.com
Hi community,
I'll receive json message from Kafka, convert flat json to nested json and send
it back to Kafka.
receive message from Kafka: {“id”:"001","name":"wang"}
send message back to Kafka: {"employee":{“id”:"001","name":"wang"}}
How to do it in Flink sql?
1095193...@qq.com
e in CREATE FUNCTION statement, is there way to
pass function_instance ( parameterize function ) in this statement.
[1]https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sql/create/#create-function
1095193...@qq.com
Hi
I want to substract 1 day from current date with Flink sql. Do we have this
function like date_sub()?
1095193...@qq.com
12 matches
Mail list logo
