Re: flink 1.10 support LONG as watermark?

2020-03-31 Thread jingjing bai
Thanks a lot! Jark Wu 于2020年4月1日周三 上午1:13写道: > Hi Jing, > > I created https://issues.apache.org/jira/browse/FLINK-16889 to support > converting from BIGINT to TIMESTAMP. > > Best, > Jark > > On Mon, 30 Mar 2020 at 20:30, jingjing bai > wrote: > >> Hi

Re: flink 1.10 support LONG as watermark?

2020-03-30 Thread jingjing bai
t; ) WITH ( > ... > ); > > Here my_func is a UDF which converts BIGINT into TIMESTAMP(3). > > Best, > Jark > > On Mon, 30 Mar 2020 at 18:16, jingjing bai > wrote: > >> >> Hi: >> flinkers! >> >> I try to upgrade our production to 1.

flink 1.10 support LONG as watermark?

2020-03-30 Thread jingjing bai
Hi: flinkers! I try to upgrade our production to 1.10V from 1.9 which is our current product version. in our case,the event_time is Long ,and we had implement this function which support long type as a watermark in our inner version, it is a different from the official version on 1.10. on 1.10 ve

Re: java.lang.NoClassDefFoundError: org/apache/kafka/common/serialization/ByteArrayDeserializer

2019-12-24 Thread jingjing bai
Typically , *NoClassDefFoundError* is caused by jar conflicts , it means, there are two same class and not same version jar in your classpath, I suggest you can check which jar is this class from ,and then to confirm is there more too than one jar in u classpath. if is and remove unuse jar .

Re: Flink task node shut it self off.

2019-12-20 Thread jingjing bai
hi john in our experience , the checkpoint interval we set interval 1-10 minute and timeout usurally 5*interval . mostly we set 2 or 5 minute and 10 or 20timeout. it depend on u data bulk per second and which window used. John Smith 于2019年12月21日周六 上午5:26写道: > Hi, using Flink 1.8.0 > > 1st off