[jira] [Commented] (FLINK-9047) SlotPool can fail to release slots

2018-03-21 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408249#comment-16408249 ] Sihua Zhou commented on FLINK-9047: --- Hi [~till.rohrmann] have you already work on this? Or I'd like to

[GitHub] flink issue #5538: [FLINK-8655] [DataSink] Added default keyspace to Cassand...

2018-03-21 Thread Bekreth
Github user Bekreth commented on the issue: https://github.com/apache/flink/pull/5538 I've been looking into this more in depth and I'm uncertain there is going to be a cleaner solution. The DataStax annotation parser will fail during runtime if it can't determine the keyspace

[jira] [Commented] (FLINK-8721) Client blocks indefinitely if job archiving fails

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408473#comment-16408473 ] ASF GitHub Bot commented on FLINK-8721: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8721) Client blocks indefinitely if job archiving fails

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408471#comment-16408471 ] ASF GitHub Bot commented on FLINK-8721: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8721) Client blocks indefinitely if job archiving fails

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408470#comment-16408470 ] ASF GitHub Bot commented on FLINK-8721: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5742: [FLINK-9031] Fix DataSet Union operator translatio...

2018-03-21 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/5742 [FLINK-9031] Fix DataSet Union operator translation bug. ## What is the purpose of the change - Fixes a bug reported in [FLINK-9031](https://issues.apache.org/jira/browse/FLINK-9031) -

[jira] [Commented] (FLINK-9031) DataSet Job result changes when adding rebalance after union

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408636#comment-16408636 ] ASF GitHub Bot commented on FLINK-9031: --- GitHub user fhueske opened a pull request:

[jira] [Assigned] (FLINK-8943) Jobs will not recover if DFS is temporarily unavailable

2018-03-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-8943: Assignee: Till Rohrmann > Jobs will not recover if DFS is temporarily unavailable >

[jira] [Updated] (FLINK-9049) Create unified interfaces to configure and instatiate TableSink

2018-03-21 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9049: -- Description: This is a similar effort to

[jira] [Commented] (FLINK-9034) State Descriptors drop TypeInformation on serialization

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408522#comment-16408522 ] ASF GitHub Bot commented on FLINK-9034: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-9034) State Descriptors drop TypeInformation on serialization

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408516#comment-16408516 ] ASF GitHub Bot commented on FLINK-9034: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-9034) State Descriptors drop TypeInformation on serialization

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408517#comment-16408517 ] ASF GitHub Bot commented on FLINK-9034: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-9034) State Descriptors drop TypeInformation on serialization

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408519#comment-16408519 ] ASF GitHub Bot commented on FLINK-9034: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-9034) State Descriptors drop TypeInformation on serialization

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408520#comment-16408520 ] ASF GitHub Bot commented on FLINK-9034: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-9034) State Descriptors drop TypeInformation on serialization

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408518#comment-16408518 ] ASF GitHub Bot commented on FLINK-9034: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-9034) State Descriptors drop TypeInformation on serialization

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408515#comment-16408515 ] ASF GitHub Bot commented on FLINK-9034: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-9034) State Descriptors drop TypeInformation on serialization

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408521#comment-16408521 ] ASF GitHub Bot commented on FLINK-9034: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip...

2018-03-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5732#discussion_r176220075 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/state/MapStateDescriptorTest.java --- @@ -129,23 +125,12 @@ public void

[GitHub] flink pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip...

2018-03-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5732#discussion_r176219997 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/state/ListStateDescriptorTest.java --- @@ -121,13 +117,9 @@ public void

[GitHub] flink pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip...

2018-03-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5732#discussion_r176220974 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java --- @@ -77,18 +80,22 @@ /** The serializer for the

[jira] [Commented] (FLINK-8925) Activate flip6 on travis

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408589#comment-16408589 ] ASF GitHub Bot commented on FLINK-8925: --- Github user zentol closed the pull request at:

[jira] [Closed] (FLINK-9043) Flink recover from checkpoint like Spark Streaming

2018-03-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9043. --- Resolution: Not A Problem For more information, you can take a look at:

[jira] [Commented] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408607#comment-16408607 ] ASF GitHub Bot commented on FLINK-8900: --- GitHub user tillrohrmann opened a pull request:

[jira] [Updated] (FLINK-9037) Test flake Kafka09ITCase#testCancelingEmptyTopic

2018-03-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9037: Fix Version/s: 1.5.0 > Test flake Kafka09ITCase#testCancelingEmptyTopic >

[jira] [Commented] (FLINK-8721) Client blocks indefinitely if job archiving fails

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408472#comment-16408472 ] ASF GitHub Bot commented on FLINK-8721: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Assigned] (FLINK-9047) SlotPool can fail to release slots

2018-03-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9047: --- Assignee: Till Rohrmann > SlotPool can fail to release slots >

[GitHub] flink pull request #5740: [FLINK-9027] [web] Clean up web UI resources by in...

2018-03-21 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5740 [FLINK-9027] [web] Clean up web UI resources by installing shut down hook ## What is the purpose of the change The RestServerEndpoint creates temp directories to upload files and

[jira] [Commented] (FLINK-9027) Web UI does not cleanup temporary files

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408528#comment-16408528 ] ASF GitHub Bot commented on FLINK-9027: --- GitHub user tillrohrmann opened a pull request:

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408549#comment-16408549 ] ASF GitHub Bot commented on FLINK-8562: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-21 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r176231789 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -465,27 +514,23 @@ private static void start(YarnConfiguration

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408556#comment-16408556 ] ASF GitHub Bot commented on FLINK-8562: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink issue #5719: [FLINK-8959][tests] Port AccumulatorLiveITCase to flip6

2018-03-21 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5719 Looks good now, when travis is green! 👌 ---

[jira] [Updated] (FLINK-9050) Expose operator IO counter metrics

2018-03-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9050: Component/s: DataStream API DataSet API > Expose operator IO counter

[jira] [Created] (FLINK-9050) Expose operator IO counter metrics

2018-03-21 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9050: --- Summary: Expose operator IO counter metrics Key: FLINK-9050 URL: https://issues.apache.org/jira/browse/FLINK-9050 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-03-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408626#comment-16408626 ] Aljoscha Krettek commented on FLINK-7811: - I'm afraid I don't have any updates but will definitely

[jira] [Updated] (FLINK-7811) Add support for Scala 2.12

2018-03-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7811: Fix Version/s: (was: 1.5.0) 1.6.0 > Add support for Scala 2.12 >

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-21 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r176230467 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -106,8 +106,16 @@ public void testDetachedMode() throws

[jira] [Commented] (FLINK-8959) Port AccumulatorLiveITCase to flip6

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408603#comment-16408603 ] ASF GitHub Bot commented on FLINK-8959: --- Github user aljoscha commented on the issue:

[jira] [Assigned] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-8900: Assignee: Till Rohrmann > YARN FinalStatus always shows as KILLED with Flip-6 >

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-03-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408492#comment-16408492 ] Till Rohrmann commented on FLINK-8946: -- Yes this only applies to the {{TaskExecutor}}. > TaskManager

[jira] [Assigned] (FLINK-9027) Web UI does not cleanup temporary files

2018-03-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9027: Assignee: Till Rohrmann > Web UI does not cleanup temporary files >

[jira] [Created] (FLINK-9049) Create unified interfaces to configure and instatiate TableSink

2018-03-21 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9049: - Summary: Create unified interfaces to configure and instatiate TableSink Key: FLINK-9049 URL: https://issues.apache.org/jira/browse/FLINK-9049 Project: Flink

[GitHub] flink pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip...

2018-03-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5732#discussion_r176221943 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java --- @@ -249,12 +257,13 @@ public boolean

[GitHub] flink pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip...

2018-03-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5732#discussion_r176222855 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/state/StateDescriptorTest.java --- @@ -130,6 +135,31 @@ public void

[GitHub] flink pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip...

2018-03-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5732#discussion_r176219956 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/state/AggregatingStateDescriptorTest.java --- @@ -41,16 +40,11 @@ * Tests that the

[GitHub] flink pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip...

2018-03-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5732#discussion_r176220129 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/state/ValueStateDescriptorTest.java --- @@ -149,13 +145,9 @@ public void

[GitHub] flink pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip...

2018-03-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5732#discussion_r176220108 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/state/ReducingStateDescriptorTest.java --- @@ -118,17 +115,14 @@ public void

[GitHub] flink issue #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecuredITCase

2018-03-21 Thread suez1224
Github user suez1224 commented on the issue: https://github.com/apache/flink/pull/5416 @tillrohrmann addressed your comments. PTAL. ---

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408566#comment-16408566 ] ASF GitHub Bot commented on FLINK-8562: --- Github user suez1224 commented on the issue:

[GitHub] flink pull request #5714: [FLINK-8925][tests] Enable Flip6 on travis

2018-03-21 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/5714 ---

[jira] [Commented] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-03-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408599#comment-16408599 ] Aljoscha Krettek commented on FLINK-8707: - There is also this ML thread:

[GitHub] flink pull request #5741: [FLINK-8900] [yarn] Properly unregister applicatio...

2018-03-21 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5741 [FLINK-8900] [yarn] Properly unregister application from Yarn RM ## What is the purpose of the change Unregisters the Flink application from Yarn if the application is shut down. This

[jira] [Updated] (FLINK-8933) Avoid calling Class#newInstance

2018-03-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8933: -- Description: Class#newInstance is deprecated starting in Java 9 -

[jira] [Updated] (FLINK-8931) TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled

2018-03-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8931: -- Description: Noticed the following : {code} [WARNING]

[jira] [Commented] (FLINK-8655) Add a default keyspace to CassandraSink

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408449#comment-16408449 ] ASF GitHub Bot commented on FLINK-8655: --- Github user Bekreth commented on the issue:

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408459#comment-16408459 ] ASF GitHub Bot commented on FLINK-8562: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-21 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r176209369 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -105,7 +105,7 @@ public void testDetachedMode() throws

[GitHub] flink pull request #5737: [FLINK-8721][flip6] Handle archiving failures for ...

2018-03-21 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5737#discussion_r176207009 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/StringifiedAccumulatorResult.java --- @@ -67,22 +72,29 @@ public String

[GitHub] flink pull request #5737: [FLINK-8721][flip6] Handle archiving failures for ...

2018-03-21 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5737#discussion_r176208188 --- Diff: flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorErrorITCase.java --- @@ -45,84 +47,87 @@ * b) are not

[GitHub] flink pull request #5737: [FLINK-8721][flip6] Handle archiving failures for ...

2018-03-21 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5737#discussion_r176207225 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/StringifiedAccumulatorResult.java --- @@ -67,22 +72,29 @@ public String

[GitHub] flink pull request #5737: [FLINK-8721][flip6] Handle archiving failures for ...

2018-03-21 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5737#discussion_r176212439 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -763,48 +764,32 @@ public Executor

[GitHub] flink issue #5580: [FLINK-8620] Enable shipping custom files to BlobStore an...

2018-03-21 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5580 I think that's a very good solution in the end that even simplifies things. What do you think, @zentol ? ---

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408258#comment-16408258 ] ASF GitHub Bot commented on FLINK-8620: --- Github user aljoscha commented on the issue:

[GitHub] flink pull request #5739: [FLINK-9047] Fix slot recycling in case of failed ...

2018-03-21 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5739 [FLINK-9047] Fix slot recycling in case of failed release ## What is the purpose of the change In case that a slot cannot be released it will only recycled/reused if the owning

[jira] [Commented] (FLINK-9047) SlotPool can fail to release slots

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408322#comment-16408322 ] ASF GitHub Bot commented on FLINK-9047: --- GitHub user tillrohrmann opened a pull request:

[jira] [Created] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails

2018-03-21 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9048: - Summary: LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails Key: FLINK-9048 URL: https://issues.apache.org/jira/browse/FLINK-9048

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408480#comment-16408480 ] ASF GitHub Bot commented on FLINK-8562: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408479#comment-16408479 ] ASF GitHub Bot commented on FLINK-8562: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-21 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r176215020 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -465,27 +514,23 @@ private static void start(YarnConfiguration

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-21 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r176214419 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -106,8 +106,16 @@ public void testDetachedMode()

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-21 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r176209172 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -465,27 +514,23 @@ private static void start(YarnConfiguration

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408458#comment-16408458 ] ASF GitHub Bot commented on FLINK-8562: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-21 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r176209223 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -515,28 +514,23 @@ private static void start(YarnConfiguration

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408457#comment-16408457 ] ASF GitHub Bot commented on FLINK-8562: --- Github user suez1224 commented on a diff in the pull

[jira] [Updated] (FLINK-8779) ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis

2018-03-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8779: - Priority: Critical (was: Blocker) > ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails

[jira] [Commented] (FLINK-8779) ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis

2018-03-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408481#comment-16408481 ] Till Rohrmann commented on FLINK-8779: -- Unblocking and setting to critical because it is the legacy

[jira] [Commented] (FLINK-8909) pyflink.sh not working with yarn

2018-03-21 Thread Hitesh Tiwari (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407633#comment-16407633 ] Hitesh Tiwari commented on FLINK-8909: -- Thanks, Configured `python.dc.tmp.dir` and it worked for

[jira] [Created] (FLINK-9038) YARNSessionCapacitySchedulerITCase fails on travis

2018-03-21 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9038: --- Summary: YARNSessionCapacitySchedulerITCase fails on travis Key: FLINK-9038 URL: https://issues.apache.org/jira/browse/FLINK-9038 Project: Flink Issue

[jira] [Updated] (FLINK-9038) YARNSessionCapacitySchedulerITCase fails on travis

2018-03-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9038: Description: https://travis-ci.org/apache/flink/jobs/355821305 {code} est

[jira] [Created] (FLINK-9039) Broken link to Hadoop Setup Guide in docs

2018-03-21 Thread Florian Schmidt (JIRA)
Florian Schmidt created FLINK-9039: -- Summary: Broken link to Hadoop Setup Guide in docs Key: FLINK-9039 URL: https://issues.apache.org/jira/browse/FLINK-9039 Project: Flink Issue Type: Bug

[GitHub] flink pull request #5717: [FLINK-9020][E2E Tests] Use separate modules per t...

2018-03-21 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5717#discussion_r176032646 --- Diff: flink-end-to-end-tests/parent-child-classloading-test/pom.xml --- @@ -0,0 +1,107 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Commented] (FLINK-9020) Move test projects of end-to-end tests in separate modules

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407724#comment-16407724 ] ASF GitHub Bot commented on FLINK-9020: --- Github user zentol commented on a diff in the pull request:

[jira] [Created] (FLINK-9040) JobVertex#setMaxParallelism does not valid argument

2018-03-21 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9040: --- Summary: JobVertex#setMaxParallelism does not valid argument Key: FLINK-9040 URL: https://issues.apache.org/jira/browse/FLINK-9040 Project: Flink

[GitHub] flink issue #5725: [FLINK-8394] Lack of synchronization accessing expectedRe...

2018-03-21 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5725 Thank your trying to help improve Flink. I think, however, this patch is not necessary. The method does not require synchronization, it should be correct as it is. ---

[jira] [Commented] (FLINK-9011) YarnResourceManager spamming log file at INFO level

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407770#comment-16407770 ] ASF GitHub Bot commented on FLINK-9011: --- Github user yanghua commented on a diff in the pull

[GitHub] flink pull request #5712: [FLINK-9011] YarnResourceManager spamming log file...

2018-03-21 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/5712#discussion_r176048790 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java --- @@ -351,16 +351,16 @@ static ContainerLaunchContext createTaskExecutorContext(

[jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException

2018-03-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8899: - Priority: Major (was: Minor) > Submitting YARN job with FLIP-6 may lead to >

[jira] [Commented] (FLINK-9038) YARNSessionCapacitySchedulerITCase fails on travis

2018-03-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407641#comment-16407641 ] Till Rohrmann commented on FLINK-9038: -- I thin this one is a duplicate of FLINK-8899 or vice versa.

[jira] [Closed] (FLINK-9038) YARNSessionCapacitySchedulerITCase fails on travis

2018-03-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9038. Resolution: Duplicate > YARNSessionCapacitySchedulerITCase fails on travis >

[GitHub] flink issue #5734: [FLINK-9026][Metrics] Close the TaskManagerMetricGroup wh...

2018-03-21 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5734 CC: @tillrohrmann ---

[GitHub] flink pull request #5734: [FLINK-9026][Metrics] Close the TaskManagerMetricG...

2018-03-21 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5734 [FLINK-9026][Metrics] Close the TaskManagerMetricGroup when the TaskExecutor is shut down ## What is the purpose of the change We should close the `TaskManagerMetricGroup` when the

[jira] [Commented] (FLINK-9026) Unregister finished tasks from TaskManagerMetricGroup and close it

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407686#comment-16407686 ] ASF GitHub Bot commented on FLINK-9026: --- GitHub user sihuazhou opened a pull request:

[jira] [Commented] (FLINK-9026) Unregister finished tasks from TaskManagerMetricGroup and close it

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407688#comment-16407688 ] ASF GitHub Bot commented on FLINK-9026: --- Github user sihuazhou commented on the issue:

[jira] [Commented] (FLINK-9031) DataSet Job result changes when adding rebalance after union

2018-03-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407683#comment-16407683 ] Fabian Hueske commented on FLINK-9031: -- Adding relevant information from the mail thread:

[GitHub] flink pull request #5733: [FLINK-8975] [test] Add resume from savepoint end-...

2018-03-21 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5733#discussion_r176029439 --- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh --- @@ -0,0 +1,102 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-8975) End-to-end test: Resume from savepoint

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407705#comment-16407705 ] ASF GitHub Bot commented on FLINK-8975: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-9020) Move test projects of end-to-end tests in separate modules

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407732#comment-16407732 ] ASF GitHub Bot commented on FLINK-9020: --- Github user florianschmidt1994 commented on the issue:

[GitHub] flink issue #5729: [FLINK-7343][kafka-tests] Fix test at-least-once test ins...

2018-03-21 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5729 Sweet, nice to see this fixed. Code looks good, +1 to merge! ---

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

2018-03-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407737#comment-16407737 ] ASF GitHub Bot commented on FLINK-7343: --- Github user StephanEwen commented on the issue:

[jira] [Created] (FLINK-9041) Refactor StreamTaskTest to not use scala and akka

2018-03-21 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9041: --- Summary: Refactor StreamTaskTest to not use scala and akka Key: FLINK-9041 URL: https://issues.apache.org/jira/browse/FLINK-9041 Project: Flink Issue

  1   2   3   >