Hi,
i am using the " per-job YARN session " mode deploy flink job on yarn.
The document
https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/jobmanager_high_availability.html#yarn-cluster-high-availability
says that "we don’t run multiple JobManager (ApplicationMaster)
instances" but
Hi anna, shyla
When we call setStreamTimeCharacteristic(env.setStreamTimeCharacteristic),
it means sets the time characteristic for all streams create from this
environment. So if your application contains multi environments, then yes.
Best, Hequn
On Mon, Aug 6, 2018 at 9:37 AM, shyla deshpande
Hi Hequn,
I now realize that in Production, data will not be a problem since this
will be a high volume kafka topic.
So, I will go with EventTime.
Still, I would like to know if
I can use both TimeCharacteristic.ProcessingTime and
TimeCharacteristic.EventTime in an application.
*Thanks, the
It appears the Flink Forwards 2018 videos are FUBAR. The data entry form
refuses to show them regardless of what you enter in it.
Hi Hequn,
Thanks for link. Looks like I better use ProcessingTime instead of
EventTime especially because of the 4th reason you listed..
"Data should cover a longer time span than the window size to advance the
event time."
I need the trigger when the data stops.
I have 1 more question.
Can I
