Can you try to look into log folder for error? May be some clue.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi,
I need to create a sliding window of 4 events in Flink streaming application.
The window should slide by one event per every new arriving event. Furthermore,
per each new arriving event I need to calculate the aggregate sum of a
particular field in the 4 events I have in the window. I have r
Flink gurus!
I have built Flink from source. I find that the executables are all at:
/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT.
However, when I try to run start-scala-shell.sh local from the bin
subfolder of this folder, it does not seem to run the simple wordcount
example. Am
hi:
my streaming application always do Key by the some keys with event timestamp,
such as keyBy( “qps_1520777430”), so the expired keys(1 hours ago) are useless.
And I use rocksdb to store the state, I want to know What's the best way to
clean up the expired rocksdb state, should I must imple
Hello Nico,
Thanks for helping me with this. It's really nerve-wracking, not coming further
with this. No here's what I tried: I checked if port is open by using telnet
and connecting to jobmanager's port, worked. Furthermore I've started the
jobmanager and taskmanager individual on each node,
