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
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.
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
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 .
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