[jira] [Closed] (FLINK-7219) Current allocate strategy cann‘t achieve the optimal effect with input's location

2018-03-28 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou closed FLINK-7219. - Resolution: Fixed Release Note: fixed by till in 1.4 > Current allocate strategy cann‘t achieve the

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

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418360#comment-16418360 ] ASF GitHub Bot commented on FLINK-8335: --- Github user zhangminglei commented on the i

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

2018-03-28 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5488 Thanks you very much @StephanEwen and @greghogan . When I am free, I will take a look and verify on hbase 1.4.2. ---

[jira] [Commented] (FLINK-9062) As the Chinese government closed its visit to Google(GFW),the drop-down menu about document on the home page (https://flink.apache.org/) doesn't work .

2018-03-28 Thread PengYang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418336#comment-16418336 ] PengYang commented on FLINK-9062: - [~twalthr] Thank you very much! Allow me to thank you o

[jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2018-03-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351986#comment-16351986 ] Ted Yu edited comment on FLINK-5486 at 3/29/18 1:03 AM: Can this g

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

2018-03-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8943. -- Resolution: Fixed Fixed via master: aa6cf3539bc895211a44476a50b30d70e1759ad1 1.5.0: cd9009d962f

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

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418045#comment-16418045 ] ASF GitHub Bot commented on FLINK-8943: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-9081) ResourceManagerTaskExecutorTest is unstable

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418046#comment-16418046 ] ASF GitHub Bot commented on FLINK-9081: --- Github user asfgit closed the pull request

[GitHub] flink pull request #5783: [FLINK-9081][test] Harden ResourceManagerTaskExecu...

2018-03-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5783 ---

[GitHub] flink pull request #5746: [FLINK-8943] [ha] Fail Dispatcher if jobs cannot b...

2018-03-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5746 ---

[jira] [Resolved] (FLINK-9081) ResourceManagerTaskExecutorTest is unstable

2018-03-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9081. -- Resolution: Fixed Fixed via master: e5ed2fbc4a31808bea8be89b371bbe4269288003 1.5.0: c0cf2234ca3b

[jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security

2018-03-28 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417997#comment-16417997 ] Shuyi Chen commented on FLINK-8981: --- Setting up a real YARN cluster from the binary migh

[jira] [Commented] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

2018-03-28 Thread Steve Loughran (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417964#comment-16417964 ] Steve Loughran commented on FLINK-9061: --- [~greghogan] I cut the link as it was just

[jira] [Commented] (FLINK-8880) Validate configurations for SQL Client

2018-03-28 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417893#comment-16417893 ] Rong Rong commented on FLINK-8880: -- Hi [~xccui]. I think I can help with this task. There

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417878#comment-16417878 ] ASF GitHub Bot commented on FLINK-8966: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5766#discussion_r177843186 --- Diff: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroExternalJarProgramITCase.java --- @@ -44,49 +39,24 @@ privat

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417868#comment-16417868 ] ASF GitHub Bot commented on FLINK-8966: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5766#discussion_r177841546 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -69,6 +73,10 @@ pri

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417836#comment-16417836 ] ASF GitHub Bot commented on FLINK-9059: --- Github user walterddr commented on a diff i

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417835#comment-16417835 ] ASF GitHub Bot commented on FLINK-9059: --- Github user walterddr commented on a diff i

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417834#comment-16417834 ] ASF GitHub Bot commented on FLINK-9059: --- Github user walterddr commented on a diff i

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

2018-03-28 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5758#discussion_r177830071 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java --- @@ -102,10 +112,10 @@ public static Env

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

2018-03-28 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5758#discussion_r177828794 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java --- @@ -29,38 +30,47 @@ /**

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

2018-03-28 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5758#discussion_r177836030 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala --- @@ -0,0 +1,75 @@ +/* + * License

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-03-28 Thread Jiayi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417808#comment-16417808 ] Jiayi commented on FLINK-6895: -- [~fdiazgon] [~fhueske] [~twalthr]  I will try to fix my pull

[jira] [Commented] (FLINK-7554) Add a testing RuntimeContext to test utilities

2018-03-28 Thread Jiayi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417779#comment-16417779 ] Jiayi commented on FLINK-7554: -- [~twalthr]  I think I should let you know my idea about this

[jira] [Commented] (FLINK-9081) ResourceManagerTaskExecutorTest is unstable

2018-03-28 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417720#comment-16417720 ] Sihua Zhou commented on FLINK-9081: --- This can be reproduced by insert a sleep: {code}

[jira] [Commented] (FLINK-9081) ResourceManagerTaskExecutorTest is unstable

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417721#comment-16417721 ] ASF GitHub Bot commented on FLINK-9081: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5783: [FLINK-9081][test] Harden ResourceManagerTaskExecutorTest

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

[jira] [Commented] (FLINK-9081) ResourceManagerTaskExecutorTest is unstable

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

[GitHub] flink pull request #5783: [FLINK-9081][test] Harden ResourceManagerTaskExecu...

2018-03-28 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5783 [FLINK-9081][test] Harden ResourceManagerTaskExecutorTest ## What is the purpose of the change Currently, `heartbeatTimeout` is 5, it's too small, so the `ResourceManagerTaskExecutorTest.

[jira] [Assigned] (FLINK-9081) ResourceManagerTaskExecutorTest is unstable

2018-03-28 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reassigned FLINK-9081: - Assignee: Sihua Zhou > ResourceManagerTaskExecutorTest is unstable >

[GitHub] flink pull request #5730: [FLINK-8961][tests] Port JobRetrievalITCase to fli...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r177804924 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -80,42 +95,38 @@ public void testJobRetrieval()

[jira] [Commented] (FLINK-8961) Port JobRetrievalITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417657#comment-16417657 ] ASF GitHub Bot commented on FLINK-8961: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-6567) ExecutionGraphMetricsTest fails on Windows CI

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417653#comment-16417653 ] ASF GitHub Bot commented on FLINK-6567: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6567) ExecutionGraphMetricsTest fails on Windows CI

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417652#comment-16417652 ] ASF GitHub Bot commented on FLINK-6567: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417650#comment-16417650 ] ASF GitHub Bot commented on FLINK-8966: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5782: [FLINK-6567] [tests] Harden ExecutionGraphMetricsT...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5782#discussion_r177804309 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphMetricsTest.java --- @@ -193,6 +197,8 @@ public void testExecutio

[GitHub] flink pull request #5782: [FLINK-6567] [tests] Harden ExecutionGraphMetricsT...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5782#discussion_r177803798 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphMetricsTest.java --- @@ -140,6 +140,9 @@ public void testExecutio

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417648#comment-16417648 ] ASF GitHub Bot commented on FLINK-8704: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417649#comment-16417649 ] ASF GitHub Bot commented on FLINK-8966: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5766#discussion_r177804335 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -69,6 +73,10 @@

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5766#discussion_r177804176 --- Diff: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroExternalJarProgramITCase.java --- @@ -44,49 +39,24 @@

[GitHub] flink pull request #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumers...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5697#discussion_r177804076 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/LegacyScheduleOrUpdateConsumersTest.java --- @@ -0,0 +1,168 @@ +/* +

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417627#comment-16417627 ] ASF GitHub Bot commented on FLINK-8704: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumers...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5697#discussion_r177801606 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/LegacyScheduleOrUpdateConsumersTest.java --- @@ -0,0 +1,168 @@ +/* + * Lice

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417622#comment-16417622 ] ASF GitHub Bot commented on FLINK-8703: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5664: [FLINK-8703][tests] Port CancelingTestBase to Mini...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5664#discussion_r177800863 --- Diff: flink-tests/src/test/java/org/apache/flink/test/cancelling/CancelingTestBase.java --- @@ -18,160 +18,111 @@ package org.apache.flink.tes

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417621#comment-16417621 ] ASF GitHub Bot commented on FLINK-8703: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5664: [FLINK-8703][tests] Port CancelingTestBase to Mini...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5664#discussion_r177801072 --- Diff: flink-tests/src/test/java/org/apache/flink/test/cancelling/JoinCancelingITCase.java --- @@ -30,19 +30,18 @@ import org.apache.flink.test.util.

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417615#comment-16417615 ] ASF GitHub Bot commented on FLINK-8966: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417612#comment-16417612 ] ASF GitHub Bot commented on FLINK-8966: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5766#discussion_r177800460 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -69,6 +73,10 @@ pri

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5766#discussion_r177800173 --- Diff: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroExternalJarProgramITCase.java --- @@ -44,49 +39,24 @@ privat

[jira] [Commented] (FLINK-8961) Port JobRetrievalITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417589#comment-16417589 ] ASF GitHub Bot commented on FLINK-8961: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-03-28 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417588#comment-16417588 ] Sihua Zhou commented on FLINK-9070: --- Hi [~kien_truong] Thanks for sharing the code and n

[GitHub] flink pull request #5730: [FLINK-8961][tests] Port JobRetrievalITCase to fli...

2018-03-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r177798624 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -80,42 +95,38 @@ public void testJobRetrieval() throw

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417581#comment-16417581 ] ASF GitHub Bot commented on FLINK-8704: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumers...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5697#discussion_r177795751 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/LegacyScheduleOrUpdateConsumersTest.java --- @@ -0,0 +1,168 @@ +/* +

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417571#comment-16417571 ] ASF GitHub Bot commented on FLINK-8703: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417570#comment-16417570 ] ASF GitHub Bot commented on FLINK-8703: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5664: [FLINK-8703][tests] Port CancelingTestBase to Mini...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5664#discussion_r177794734 --- Diff: flink-tests/src/test/java/org/apache/flink/test/cancelling/CancelingTestBase.java --- @@ -18,160 +18,111 @@ package org.apache.fli

[GitHub] flink pull request #5664: [FLINK-8703][tests] Port CancelingTestBase to Mini...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5664#discussion_r177794320 --- Diff: flink-tests/src/test/java/org/apache/flink/test/cancelling/JoinCancelingITCase.java --- @@ -30,19 +30,18 @@ import org.apache.flink.test

[jira] [Commented] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417558#comment-16417558 ] ASF GitHub Bot commented on FLINK-9102: --- Github user sihuazhou closed the pull reque

[jira] [Commented] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417557#comment-16417557 ] ASF GitHub Bot commented on FLINK-9102: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5781: [FLINK-9102][FLIP6] disable queued scheduling for JobGrap...

2018-03-28 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5781 Thanks a lot for you reply, closing this PR since it's invalid. ---

[GitHub] flink pull request #5781: [FLINK-9102][FLIP6] disable queued scheduling for ...

2018-03-28 Thread sihuazhou
Github user sihuazhou closed the pull request at: https://github.com/apache/flink/pull/5781 ---

[jira] [Commented] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417553#comment-16417553 ] ASF GitHub Bot commented on FLINK-8699: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5705: [FLINK-8699][FLINK-8968][state]Fix native resource leak c...

2018-03-28 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5705 Hi @tillrohrmann thanks for your reply, and god bless Stefan, hope he will get well soon... ---

[jira] [Resolved] (FLINK-8740) Job-level metrics lost during job re-submission in HA mode

2018-03-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8740. -- Resolution: Fixed Fixed via master: 9a31deae7ebdbda5a78f19ae8967e6b9d35834a4 1.5.0: 237563215fa9

[jira] [Closed] (FLINK-9099) Failing allocated slots not noticed

2018-03-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9099. Resolution: Fixed Fixed via master: e6b1d5cee423831dd0f7b3b57c31c9cd899ac8f0 1.5.0: 101f99779c684114

[jira] [Commented] (FLINK-8740) Job-level metrics lost during job re-submission in HA mode

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417541#comment-16417541 ] ASF GitHub Bot commented on FLINK-8740: --- Github user asfgit closed the pull request

[jira] [Resolved] (FLINK-8887) ClusterClient.getJobStatus can throw FencingTokenException

2018-03-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8887. -- Resolution: Fixed Fixed via master: c0dddc1a6e3eef8ded1963e61ee4a8f8ecf66475 1.5.0: 11548456d52c

[jira] [Resolved] (FLINK-9063) Possible SpillableSubpartitionTest testSpillFinishedBufferConsumers test failure

2018-03-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9063. -- Resolution: Fixed Fixed via master: af53f28e568353998dc370a780de4e09483429ea 1.5.0: 535e26792785

[jira] [Commented] (FLINK-9099) Failing allocated slots not noticed

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417542#comment-16417542 ] ASF GitHub Bot commented on FLINK-9099: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-9063) Possible SpillableSubpartitionTest testSpillFinishedBufferConsumers test failure

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417543#comment-16417543 ] ASF GitHub Bot commented on FLINK-9063: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8887) ClusterClient.getJobStatus can throw FencingTokenException

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417544#comment-16417544 ] ASF GitHub Bot commented on FLINK-8887: --- Github user asfgit closed the pull request

[GitHub] flink pull request #5767: [FLINK-8887] Wait for JobMaster leader election in...

2018-03-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5767 ---

[GitHub] flink pull request #5755: [FLINK-8740] [metrics] Create new JobManagerJobMet...

2018-03-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5755 ---

[GitHub] flink pull request #5765: [FLINK-9063] Fix SpillableSubpartitionTest testSpi...

2018-03-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5765 ---

[GitHub] flink pull request #5775: [FLINK-9099] Assign Execution to LogicalSlot when ...

2018-03-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5775 ---

[jira] [Commented] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417527#comment-16417527 ] ASF GitHub Bot commented on FLINK-9102: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #5781: [FLINK-9102][FLIP6] disable queued scheduling for JobGrap...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5781 This is a good question and so far I couldn't find a good solution for it. We could have different slot timeouts for standalone vs non-standalone. But this might be a bit tricky to maintain. Mor

[jira] [Created] (FLINK-9103) SSL verification on TaskManager when parallelism > 1

2018-03-28 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-9103: --- Summary: SSL verification on TaskManager when parallelism > 1 Key: FLINK-9103 URL: https://issues.apache.org/jira/browse/FLINK-9103 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417522#comment-16417522 ] ASF GitHub Bot commented on FLINK-8699: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #5705: [FLINK-8699][FLINK-8968][state]Fix native resource leak c...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5705 Hi @sihuazhou, Stefan is currently sick but he should come back in a bit. Since he already reviewed parts of the PR, I would suggest to wait for his return. If he should not be back by next week

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417489#comment-16417489 ] ASF GitHub Bot commented on FLINK-8703: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #5664: [FLINK-8703][tests] Port CancelingTestBase to MiniCluster...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5664 Interesting, there is a aborted test run with a core dump. ---

[jira] [Commented] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417483#comment-16417483 ] ASF GitHub Bot commented on FLINK-8699: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5705: [FLINK-8699][FLINK-8968][state]Fix native resource leak c...

2018-03-28 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5705 Could anyone have a look at this PR? ---

[jira] [Commented] (FLINK-9063) Possible SpillableSubpartitionTest testSpillFinishedBufferConsumers test failure

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417477#comment-16417477 ] ASF GitHub Bot commented on FLINK-9063: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #5765: [FLINK-9063] Fix SpillableSubpartitionTest testSpillFinis...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5765 Thanks for the fix @pnowojski and the review @NicoK. Merging this PR. ---

[jira] [Commented] (FLINK-8961) Port JobRetrievalITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417467#comment-16417467 ] ASF GitHub Bot commented on FLINK-8961: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5730: [FLINK-8961][tests] Port JobRetrievalITCase to fli...

2018-03-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r18690 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -80,42 +95,38 @@ public void testJobRetrieval()

[jira] [Commented] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

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

[GitHub] flink pull request #5777: [FLINK-7897] Consider using nio.Files for file del...

2018-03-28 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/5777#discussion_r17396 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCleanupTask.java --- @@ -100,9 +102,15 @@ public void run() {

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417450#comment-16417450 ] ASF GitHub Bot commented on FLINK-8966: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417447#comment-16417447 ] ASF GitHub Bot commented on FLINK-8966: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417448#comment-16417448 ] ASF GitHub Bot commented on FLINK-8966: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8813) AutoParallellismITCase fails with Flip6

2018-03-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16417446#comment-16417446 ] ASF GitHub Bot commented on FLINK-8813: --- Github user kl0u commented on a diff in the

  1   2   3   >