Hey,
Thanks for the info, I haven't noticed that.
I was just going through older messages with no responses.
Best Regards,
Dom.
This issue was already resolved in another thread by the same author.
On 15.11.2018 10:52, Dominik Wosiński wrote:
Hey,
Could You please show a sample data that You want to process? This
would help in verifying the issue.
Best Regards,
Dom.
wt., 13 lis 2018 o 13:58 Jeff Zhang
Hey,
Could You please show a sample data that You want to process? This would
help in verifying the issue.
Best Regards,
Dom.
wt., 13 lis 2018 o 13:58 Jeff Zhang napisał(a):
> Hi,
>
> I hit the following error when I try to use kafka connector in flink table
> api. There's very little
Thanks hequn, it is very helpful
On Wed, Nov 14, 2018 at 2:32 PM Hequn Cheng wrote:
> Hi jeff,
>
> We need a different field name for the rowtime indicator, something looks
> like:
>
>> new Schema()
>> .field("status", Types.STRING)
>> .field("direction", Types.STRING)
>>
Hi jeff,
We need a different field name for the rowtime indicator, something looks
like:
> new Schema()
> .field("status", Types.STRING)
> .field("direction", Types.STRING)
> .field("rowtime", Types.SQL_TIMESTAMP).rowtime(
> new
>
Hi,
I hit the following error when I try to use kafka connector in flink table
api. There's very little document about how to use kafka connector in flink
table api, could anyone help me on that ? Thanks
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Field 'event_ts'
Hi,
I hit the following error when I try to use kafka connector in flink table
api. There's very little document about how to use kafka connector in flink
table api, could anyone help me on that ? Thanks
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Field 'event_ts'
