Hello, When I submit a WordCount job from the examples, without any parameter, to a standalone cluster running on Docker, I cannot see the System.out.println() message. Instead I notice the org.apache.flink.metrics.MetricGroup entry below (last)
jobmanager_1 | Starting Job Manager jobmanager_1 | config file: jobmanager_1 | jobmanager.rpc.address: jobmanager jobmanager_1 | jobmanager.rpc.port: 6123 jobmanager_1 | jobmanager.heap.mb: 1024 jobmanager_1 | taskmanager.heap.mb: 1024 jobmanager_1 | taskmanager.numberOfTaskSlots: 1 jobmanager_1 | taskmanager.memory.preallocate: false jobmanager_1 | parallelism.default: 1 jobmanager_1 | web.port: 8081 jobmanager_1 | blob.server.port: 6124 jobmanager_1 | query.server.port: 6125 jobmanager_1 | Starting jobmanager as a console application on host 400baa8ff371. taskmanager_1 | Starting Task Manager taskmanager_1 | config file: taskmanager_1 | jobmanager.rpc.address: jobmanager taskmanager_1 | jobmanager.rpc.port: 6123 taskmanager_1 | jobmanager.heap.mb: 1024 taskmanager_1 | taskmanager.heap.mb: 1024 taskmanager_1 | taskmanager.numberOfTaskSlots: 4 taskmanager_1 | taskmanager.memory.preallocate: false taskmanager_1 | parallelism.default: 1 taskmanager_1 | web.port: 8081 taskmanager_1 | blob.server.port: 6124 taskmanager_1 | query.server.port: 6125 taskmanager_1 | Starting taskmanager as a console application on host 531ef6c27264. jobmanager_1 | Slf4jLogger started taskmanager_1 | Slf4jLogger started taskmanager_1 | Could not load Queryable State Client Proxy. Probable reason: flink-queryable-state-runtime is not in the classpath. To enable Queryable State, please move the flink-queryable-state-runtime jar from the opt to the lib folder. taskmanager_1 | Could not load Queryable State Server. Probable reason: flink-queryable-state-runtime is not in the classpath. To enable Queryable State, please move the flink-queryable-state-runtime jar from the opt to the lib folder. taskmanager_1 | The operator name DataSource (at getDefaultTextLineDataSet(WordCountData.java:70) (org.apache.flink.api.java.io.CollectionInputFormat)) exceeded the 80 characters length limit and was truncated. I am not sure why this happens. I am using the latest Docker image with 1.4.2 and the corresponding JAR from the 1.4.2 release of the examples. TIA JP
