Hi suman,
FlinkKafkaConsumer.setStartFromLatest() means you always consume messages
from the latest whenever you restart the flink job，the consumer ignore any
committed group offsets.
auto.offset.reset=latest means the consumer fetch messages from the latest
if you never committed
Hi,
Currently, When I was using a lot of the same udf in a sql, I can't locate
where the semantic occor if some udf being used in a wrong way. So I try to
change some code in flink-table-common and flink-table-runtime-blink to extract
more detail information such as position and sql context in t
Hi,
When I was using hbase table as my lookup table, I got this error:
Caused by: java.lang.IllegalArgumentException: Currently, HBase table can
only be lookup by single row key.
at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138)
My SQL is
insert into si
he behavior is different with Postgres and Mysql.
Best regards,
JING ZHANG
Leonard Xu 于2021年6月17日周四 下午8:11写道：
Hi, houying
It looks like a bug when code generate the operator code, which Flink version
are you using?
Could you help create an JIRA ticket?
Best,
Leonard
在 2021年6月17日，1
rator code, which Flink version
are you using?
Could you help create an JIRA ticket?
Best,
Leonard
在 2021年6月17日，19:48，纳兰清风 写道：
Hello,
When I am using case when statement in flink sql, I got an error as follow:
org.apache.flink.table.planner.codegen.CodeGenException: Unable to f
Hello,
When I am using case when statement in flink sql, I got an error as follow:
org.apache.flink.table.planner.codegen.CodeGenException: Unable to find common
type of GeneratedExpression(field$3,isNull$3,,INT,None) and
ArrayBuffer(GeneratedExpression(((org.apache.flink.table.data.binar
