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

2018-03-23 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16412326#comment-16412326 ] Steven Zhen Wu edited comment on FLINK-9061 at 3/24/18 1:02 AM: Jamie,

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

2018-03-23 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16412326#comment-16412326 ] Steven Zhen Wu commented on FLINK-9061: --- Jamie, yes, we run into the same issue at Netflix. We did

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

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

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

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

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

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

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

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

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

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

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176662599 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientTest.java --- @@ -453,15 +460,51 @@ private void

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176663553 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheReadsFromBlobTest.java --- @@ -57,89 +65,59 @@ + "MICHAEL:

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176659407 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java --- @@ -159,7 +162,7 @@ public

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176658024 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -306,18 +311,20 @@ public JobSubmissionResult

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176662757 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientTest.java --- @@ -453,15 +460,51 @@ private void

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

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

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

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

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

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

[jira] [Comment Edited] (FLINK-6473) Add OVER window support for batch tables

2018-03-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410945#comment-16410945 ] Fabian Hueske edited comment on FLINK-6473 at 3/23/18 7:54 AM: --- Have a look

[jira] [Commented] (FLINK-6473) Add OVER window support for batch tables

2018-03-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410945#comment-16410945 ] Fabian Hueske commented on FLINK-6473: -- Have a look at the interface of the [user-defined aggregate

[jira] [Commented] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

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

[jira] [Closed] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

2018-03-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8919. Resolution: Implemented Implemented in 1.6.0 with cc94090ea29b5f33a0a110d7af46dfc2c7e8610a > Add

[GitHub] flink pull request #5752: [FLINK-8972] [e2eTests] Add DataSetAllroundTestPro...

2018-03-23 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/5752 [FLINK-8972] [e2eTests] Add DataSetAllroundTestProgram and e2e test script. ## What is the purpose of the change * Add a program that covers many features of the DataSet API * Add a

[jira] [Commented] (FLINK-8964) Port JobSubmissionFailsITCase to flip6

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

[GitHub] flink issue #5727: [FLINK-8964][tests] Port JobSubmissionFailsITCase to flip...

2018-03-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5727 merging. ---

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

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5739#discussion_r176668855 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolTest.java --- @@ -634,6 +653,99 @@ public void

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

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5739#discussion_r176668568 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolTest.java --- @@ -634,6 +653,99 @@ public void

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

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

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

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

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

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5739#discussion_r176668534 --- Diff: flink-runtime/src/test/resources/log4j-test.properties --- @@ -16,7 +16,7 @@ # limitations under the License.

[jira] [Created] (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-23 Thread PengYang (JIRA)
PengYang created FLINK-9062: --- Summary: 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 . Key: FLINK-9062 URL:

[jira] [Comment Edited] (FLINK-6473) Add OVER window support for batch tables

2018-03-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410799#comment-16410799 ] Fabian Hueske edited comment on FLINK-6473 at 3/23/18 7:52 AM: --- [~fhueske]

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176659832 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -488,13 +493,36 @@ public void addJar(Path jar) {

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176658879 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/api/environment/PythonStreamExecutionEnvironment.java ---

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176658516 --- Diff: flink-end-to-end-tests/pom.xml --- @@ -78,6 +78,27 @@ under the License.

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176661729 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java --- @@ -267,101 +208,60 @@ private static Thread

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176658632 --- Diff: flink-end-to-end-tests/pom.xml --- @@ -78,6 +78,27 @@ under the License.

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176660974 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java --- @@ -527,59 +403,83 @@ else if (response == RETURN_ERROR) { *

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176662637 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientTest.java --- @@ -453,15 +460,51 @@ private void

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176662188 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java --- @@ -267,101 +208,60 @@ private static Thread

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176662946 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheReadsFromBlobTest.java --- @@ -19,30 +19,38 @@ package

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176661496 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java --- @@ -267,101 +208,60 @@ private static Thread

[GitHub] flink issue #5722: [FLINK-8958][tests] Port TaskCancelAsyncProducerConsumerI...

2018-03-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5722 merging. ---

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

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

[jira] [Commented] (FLINK-8958) Port TaskCancelAsyncProducerConsumerITCase to flip6

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

[jira] [Commented] (FLINK-8957) Port JMXJobManagerMetricTest to flip6

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

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

2018-03-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5719 merging. ---

[GitHub] flink issue #5720: [FLINK-8957][tests] Port JMXJobManagerMetricTest to flip6

2018-03-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5720 merging. ---

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

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

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

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

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

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

[GitHub] flink issue #5741: [FLINK-8900] [yarn] Properly unregister application from ...

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5741 Merging the PR. ---

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

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

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r176657746 --- Diff: flink-libraries/flink-python/src/test/java/org/apache/flink/python/api/PythonPlanBinderTest.java --- @@ -30,6 +33,7 @@ /** * Tests for

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-8956) Port RescalingITCase to flip6

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

[GitHub] flink pull request #5715: [FLINK-8956][tests] Port RescalingITCase to flip6

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5715#discussion_r176663967 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java --- @@ -528,54 +454,44 @@ public void

[jira] [Commented] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

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

[GitHub] flink issue #5680: [FLINK-8919] [Table API & SQL] Add KeyedProcessFunctionWi...

2018-03-23 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5680 Merging. Thanks for the PR @liurenjie1024 and helping with the review @bowenli86! ---

[GitHub] flink pull request #5680: [FLINK-8919] [Table API & SQL] Add KeyedProcessFun...

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

[GitHub] flink issue #5739: [FLINK-9047] Fix slot recycling in case of failed release

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5739 Thanks for the review @GJL. Merging this PR. ---

[GitHub] flink issue #5740: [FLINK-9027] [web] Clean up web UI resources by installin...

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5740 Thanks for the feedback @StephanEwen. Merging this PR. ---

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

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

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

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5739#discussion_r176668913 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/TaskManagerSlot.java --- @@ -139,6 +139,16 @@ public boolean

[jira] [Commented] (FLINK-8972) Create general purpose DataSet testing job

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

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

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

[jira] [Commented] (FLINK-6473) Add OVER window support for batch tables

2018-03-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411060#comment-16411060 ] Fabian Hueske commented on FLINK-6473: -- I don't understand what you are asking for. Do you want to

[jira] [Commented] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-03-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411143#comment-16411143 ] Till Rohrmann commented on FLINK-9010: -- What's the state [~NicoK]? > NoResourceAvailableException

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

2018-03-23 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5734 Hi @tillrohrmann could you please have a look at this PR? ---

[jira] [Commented] (FLINK-9060) Deleting state using KeyedStateBackend.getKeys() throws Exception

2018-03-23 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411172#comment-16411172 ] Kostas Kloudas commented on FLINK-9060: --- I would say that this code reveals a real bug but in the

[jira] [Comment Edited] (FLINK-9060) Deleting state using KeyedStateBackend.getKeys() throws Exception

2018-03-23 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411172#comment-16411172 ] Kostas Kloudas edited comment on FLINK-9060 at 3/23/18 10:50 AM: - I would

[GitHub] flink pull request #5754: [FLINK-8901] [yarn] Set proper Yarn application na...

2018-03-23 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5754 [FLINK-8901] [yarn] Set proper Yarn application name ## What is the purpose of the change When deploying a session cluster, Flink will register under "Flink session cluster". When

[jira] [Commented] (FLINK-9060) Deleting state using KeyedStateBackend.getKeys() throws Exception

2018-03-23 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411238#comment-16411238 ] Sihua Zhou commented on FLINK-9060: --- [~kkl0u] Thanks for pointing out this! After reading your comments,

[GitHub] flink issue #5691: [FLINK-8802] [QS] Fix concurrent access to non-duplicated...

2018-03-23 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5691 Can someone have a look at this? ---

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

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

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

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

[jira] [Assigned] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

2018-03-23 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9056: --- Assignee: yuqi > Job submission fails with AskTimeoutException if not enough slots are > available >

[GitHub] flink issue #5702: [FLINK-8771] [Build System] [Checkstyle/Scalastyle] Upgra...

2018-03-23 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5702 Hi @zentol , can you take a look at this PR? ---

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

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r176688158 --- 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-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411158#comment-16411158 ] ASF GitHub Bot commented on FLINK-8961: --- Github user zentol commented on a diff in the pull request:

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

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

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

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

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

2018-03-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r176690193 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -21,54 +21,69 @@ import

[jira] [Commented] (FLINK-8789) StoppableFunctions sometimes not detected

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

[GitHub] flink pull request #5753: [FLINK-8789] Throw IllegalStateException when call...

2018-03-23 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5753 [FLINK-8789] Throw IllegalStateException when calling Task#stopExecution on not running Task ## What is the purpose of the change Before we threw an UnsupportedOperationException when

[jira] [Commented] (FLINK-9060) Deleting state using KeyedStateBackend.getKeys() throws Exception

2018-03-23 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411239#comment-16411239 ] Kostas Kloudas commented on FLINK-9060: --- Thanks a lot [~sihuazhou] ! > Deleting state using

[jira] [Commented] (FLINK-8965) Port TimestampITCase to flip6

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

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

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

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

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

[GitHub] flink pull request #5728: [FLINK-8965][tests] Port TimestampITCase to flip6

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5728#discussion_r176678985 --- Diff: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/TimestampITCase.java --- @@ -185,22 +177,23 @@ public void

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

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

[jira] [Commented] (FLINK-6473) Add OVER window support for batch tables

2018-03-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411093#comment-16411093 ] Fabian Hueske commented on FLINK-6473: -- Let's move this to the user mailing list. Jira issues should

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

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r176684188 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -21,54 +21,69 @@ import

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

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

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

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r176683463 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -21,54 +21,69 @@ import

[GitHub] flink pull request #5736: [FLINK-9042][tests] Port ResumeCheckpointManuallyI...

2018-03-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5736#discussion_r176686071 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ResumeCheckpointManuallyITCase.java --- @@ -263,56 +268,113 @@ private void

[jira] [Commented] (FLINK-7881) flink can't deployed on yarn with ha

2018-03-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411194#comment-16411194 ] Till Rohrmann commented on FLINK-7881: -- Unblocking since so far we could not reproduce the problem.

  1   2   3   >