[jira] [Created] (FLINK-9052) Flink complains when scala.Option is used inside POJO

Truong Duc Kien created FLINK-9052: -- Summary: Flink complains when scala.Option is used inside POJO Key: FLINK-9052 URL: https://issues.apache.org/jira/browse/FLINK-9052 Project: Flink

[jira] [Commented] (FLINK-9046) Improve error messages when receiving unexpected messages.

[ https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408978#comment-16408978 ] vinoyang commented on FLINK-9046: - [~kkl0u] I think the first scenario's log message is not a problem, it

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

[ https://issues.apache.org/jira/browse/FLINK-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408972#comment-16408972 ] ASF GitHub Bot commented on FLINK-8931: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5744: [FLINK-8931] TASK_KILLING is not covered by match in Task...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5744 cc @tillrohrmann ---

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

[ https://issues.apache.org/jira/browse/FLINK-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408927#comment-16408927 ] ASF GitHub Bot commented on FLINK-8931: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5744: [FLINK-8931] TASK_KILLING is not covered by match ...

GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5744 [FLINK-8931] TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled ## What is the purpose of the change *This pull request makes _TASK_KILLING_ covered by match in

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

[ https://issues.apache.org/jira/browse/FLINK-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8931: --- Assignee: vinoyang > TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled >

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

[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8933: --- Assignee: vinoyang > Avoid calling Class#newInstance > --- > >

[jira] [Assigned] (FLINK-9046) Improve error messages when receiving unexpected messages.

[ https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9046: --- Assignee: vinoyang > Improve error messages when receiving unexpected messages. >

[jira] [Commented] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

[ https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408905#comment-16408905 ] yinhua.dai commented on FLINK-6595: --- Is there anyway I can bypass the step? > Nested SQL queries do not

[jira] [Commented] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

[ https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408903#comment-16408903 ] yinhua.dai commented on FLINK-6595: --- [~fhueske] So that means I need separate to two sql and convert

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.1

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408894#comment-16408894 ] ASF GitHub Bot commented on FLINK-8335: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #5488: [FLINK-8335] [hbase] Upgrade hbase connector dependency t...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5488 Sup ? ---

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

[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408813#comment-16408813 ] vinoyang commented on FLINK-8946: - Could I create a new issue ? It seems that closing mertics group is not

[jira] [Commented] (FLINK-9051) Invert flip6 profile

[ https://issues.apache.org/jira/browse/FLINK-9051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408725#comment-16408725 ] ASF GitHub Bot commented on FLINK-9051: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5743: [FLINK-9051][build] Invert flip6 profile

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5743 [FLINK-9051][build] Invert flip6 profile ## What is the purpose of the change Invert the `flip6` profile so that flip6 tests are run by default. You can merge this pull request into a Git

[jira] [Created] (FLINK-9051) Invert flip6 profile

Chesnay Schepler created FLINK-9051: --- Summary: Invert flip6 profile Key: FLINK-9051 URL: https://issues.apache.org/jira/browse/FLINK-9051 Project: Flink Issue Type: Improvement

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

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

[GitHub] flink pull request #5738: [FLINK-8925][tests] Enable flip6 on travis

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/5738 ---

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

[ https://issues.apache.org/jira/browse/FLINK-8925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8925. --- Resolution: Fixed master: 893fabf6910b3e2ca55ba2b496f0c9530b35ef28 1.5:

[jira] [Closed] (FLINK-8984) Disabling credit based flow control deadlocks Flink on checkpoint

[ https://issues.apache.org/jira/browse/FLINK-8984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8984. --- Resolution: Fixed master: 91707e35d39a1b9c11448f21eafc27f0fd949370 1.5:

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

[ https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9020. --- Resolution: Fixed Fix Version/s: 1.5.0 master:

[jira] [Closed] (FLINK-8649) Scala StreamExecutionEnvironment.createInput should pass on the TypeInfo

[ https://issues.apache.org/jira/browse/FLINK-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8649. --- Resolution: Fixed master: 7e43f81866d3df8e839c9e01e71d6edca06bc8cd 1.5:

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

[ https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408708#comment-16408708 ] ASF GitHub Bot commented on FLINK-9020: --- Github user asfgit closed the pull request at:

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

[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7343. --- Resolution: Fixed master: b87e660ac64bebbd9a0a6aa4334a68736140053f 1.5:

[jira] [Commented] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()

[ https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408705#comment-16408705 ] ASF GitHub Bot commented on FLINK-8073: --- Github user asfgit closed the pull request at:

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

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5717 ---

[jira] [Updated] (FLINK-8984) Disabling credit based flow control deadlocks Flink on checkpoint

[ https://issues.apache.org/jira/browse/FLINK-8984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8984: Component/s: Configuration > Disabling credit based flow control deadlocks Flink on

[jira] [Commented] (FLINK-8984) Disabling credit based flow control deadlocks Flink on checkpoint

[ https://issues.apache.org/jira/browse/FLINK-8984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408707#comment-16408707 ] ASF GitHub Bot commented on FLINK-8984: --- Github user asfgit closed the pull request at:

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

[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16408706#comment-16408706 ] ASF GitHub Bot commented on FLINK-7343: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5708: [FLINK-8984][network] Drop taskmanager.exactly-onc...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5708 ---

[GitHub] flink pull request #5718: [FLINK-8073][kafka-tests] Disable timeout in tests

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5718 ---

[GitHub] flink pull request #5729: [FLINK-7343][kafka-tests] Fix test at-least-once t...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5729 ---

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

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

[ 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] [Updated] (FLINK-9050) Expose operator IO counter metrics

[ 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

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] [Updated] (FLINK-7811) Add support for Scala 2.12

[ 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 >

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

[ 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] [Assigned] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

[ 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] [Updated] (FLINK-9037) Test flake Kafka09ITCase#testCancelingEmptyTopic

[ 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-8900) YARN FinalStatus always shows as KILLED with Flip-6

[ 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] [Closed] (FLINK-9043) Flink recover from checkpoint like Spark Streaming

[ 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:

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

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] [Commented] (FLINK-8959) Port AccumulatorLiveITCase to flip6

[ 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:

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

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

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

[ 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:

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

[ 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:

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

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

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

[ 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 issue #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecuredITCase

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

[ 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 pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

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

[ 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...

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-9027) Web UI does not cleanup temporary files

[ 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:

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

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-9034) State Descriptors drop TypeInformation on serialization

[ 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

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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

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

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...

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

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

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...

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 pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip...

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...

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...

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...

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

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

[ 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 >

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

[ 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

[ 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] [Created] (FLINK-9049) Create unified interfaces to configure and instatiate TableSink

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

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

[ 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] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

[ 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] [Updated] (FLINK-8779) ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis

[ 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

[ 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-8562) Fix YARNSessionFIFOSecuredITCase

[ 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

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

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

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

[ 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...

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()

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

[ 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] [Commented] (FLINK-8721) Client blocks indefinitely if job archiving fails

[ 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

[ 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

[ 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 #5737: [FLINK-8721][flip6] Handle archiving failures for ...

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 ...

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 ...

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 ...

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

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

[ 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...

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

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

[ 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

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

[ 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

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

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

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

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-8655) Add a default keyspace to CassandraSink

[ 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:

  1   2   3   >