intermediate datastream so when I dropped
that step and directly use the inner table (with the rowtime timestamp), things
work as expected!
Thanks,
-- Piyush
From: Dawid Wysakowicz
Date: Thursday, November 14, 2019 at 10:57 AM
To:
Subject: Re: Propagating event time field from nested query
Hi
Hi Piyush,
Could you verify that the type of the `timestamp` field in the table
my_kafka_stream is of TIMESTAMP(3) *ROWTIME* type? Could you share how
you create this table?
What you are doing should work and what I suspect is that the
`timestamp` field in the `my_kafka_stream` changed the type s
Hi folks,
We have a Flink streaming Table / SQL job that we were looking to migrate from
an older Flink release (1.6.x) to 1.9. As part of doing so, we have been seeing
a few errors which I was trying to figure out how to work around. Would
appreciate any help / pointers.
Job essentially involv
