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 se
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,
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 li
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,
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,
The per-job YARN mode also supports HA. Even if the YARN ResourceManager
only
brings up one JobManager at a time, you require ZooKeeper for storing
metadata, such as which jobs are supposed to be running. In fact, the
distributed components will still take part in a leader election with only
o
