While  trying to run the Beam WordCount example on Flink runner using Job
Manager and Taskmanager docker images using the input pom.xml file, I can
see the task manager is creating the following files but no output inside
the counts-0000 file as expected - Any pointer what might be wrong here?

Thanks

bash-4.4$ ls -lrt /tmp
total 4
drwxr-xr-x    1 flink    flink            2 Jul  7 21:15 hsperfdata_flink
-rw-r--r--    1 flink    flink         1179 Jul  7 21:15
jaas-3210126497662256938.conf
drwxr-xr-x    1 flink    flink            0 Jul  7 21:15
flink-io-5922e9cc-91ee-4ae3-bee3-90006db36aaa
drwxr-xr-x    1 flink    flink            0 Jul  7 21:15
blobStore-1f336cf6-8885-4aff-bd36-ddf38f11c0a0
drwxr-xr-x    1 flink    flink            0 Jul  7 21:15
blobStore-13b09c7f-e371-430f-90aa-802aec50735e
drwxr-xr-x    1 flink    flink            0 Jul  7 21:15
flink-dist-cache-6330c1d8-3ab8-4baa-812b-485d6d850c1d
-rw-r--r--    1 flink    flink            0 Jul  7 21:15
counts-00000-of-00001
drwxr-xr-x    1 flink    flink            0 Jul  7 21:15
flink-netty-shuffle-69803f1d-c641-41b0-a090-7dc542ed98f4
drwxr-xr-x    1 flink    flink            0 Jul  7 21:15 localState

Reply via email to