Thank you Ted! I still get the message below...
taskmanager_1 | The operator name DataSource (at getDefaultTextLineDataSet(WordCountData.java:70 (org.apache.flink.api.java.io <http://org.apache.flink.api.java.io>.CollectionInputFormat)) exceeded the 80 characters length limit and was truncated. The corresponding line 70 in Wordcount.java is System.out.println("Executing WordCount example with default input data set."); I got the docker image from https://github.com/docker-flink/docker-flink and still get this message even with all defaults. On 04/22/2018 12:39 AM, Ted Yu wrote: > bq. To enable Queryable State, please move the > flink-queryable-state-runtime jar from the opt to the lib folder. > > Have you noticed the above and taken corresponding action ? > > Thanks > > On Sat, Apr 21, 2018 at 3:15 PM, JP de Vooght <j...@vooght.de > <mailto:j...@vooght.de>> wrote: > > 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 > <http://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 > >
