Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1947#issuecomment-217213101
Is it possible that submitting the same job two times doesn't work?
```
./bin/flink run ./examples/streaming/SocketWindowWordCount.jar --port 54323
05/05/2016 19:09:08 Job execution switched to status RUNNING.
05/05/2016 19:09:08 Source: Socket Stream -> Flat Map(1/1) switched to
SCHEDULED
05/05/2016 19:09:08 Source: Socket Stream -> Flat Map(1/1) switched to
DEPLOYING
05/05/2016 19:09:08 Fast SlidingProcessingTimeWindows(5000, 1000) of
WindowedStream.main(SocketWindowWordCount.java:79) -> Sink: Unnamed(1/1)
switched to SCHEDULED
05/05/2016 19:09:08 Fast SlidingProcessingTimeWindows(5000, 1000) of
WindowedStream.main(SocketWindowWordCount.java:79) -> Sink: Unnamed(1/1)
switched to DEPLOYING
05/05/2016 19:09:08 Source: Socket Stream -> Flat Map(1/1) switched to
RUNNING
05/05/2016 19:09:08 Source: Socket Stream -> Flat Map(1/1) switched to
FAILED
java.lang.IllegalArgumentException: This group ([key0, localhost, Actor,
TaskManager, TaskManager, 964566cfcf032710aff86614010fce21, Category, Tasks,
Job, "Socket Window WordCount", Operator, Flat Map, SubTask, 0, ChannelType,
OutputChannel, Index, 0]) already contains a metric named numBytesOut
at org.apache.flink.metrics.MetricGroup.addMetric(MetricGroup.java:246)
at org.apache.flink.metrics.MetricGroup.counter(MetricGroup.java:123)
at
org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializer.setMetrics(SpanningRecordSerializer.java:206)
at
org.apache.flink.runtime.io.network.api.writer.RecordWriter.setMetrics(RecordWriter.java:216)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createStreamOutput(OperatorChain.java:294)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:94)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:188)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
at java.lang.Thread.run(Thread.java:745)
05/05/2016 19:09:08 Fast SlidingProcessingTimeWindows(5000, 1000) of
WindowedStream.main(SocketWindowWordCount.java:79) -> Sink: Unnamed(1/1)
switched to RUNNING
05/05/2016 19:09:08 Job execution switched to status FAILING.
```
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
