[GitHub] flink pull request #4798: [FLINK-6505] Proactively cleanup local FS for Rock...

2017-10-22 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4798#discussion_r146167573 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -235,26

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214657#comment-16214657 ] ASF GitHub Bot commented on FLINK-6505: --- Github user bowenli86 commented on a diff in the pull

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214639#comment-16214639 ] ASF GitHub Bot commented on FLINK-6505: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4798: [FLINK-6505] Proactively cleanup local FS for Rock...

2017-10-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4798#discussion_r146166380 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214625#comment-16214625 ] ASF GitHub Bot commented on FLINK-6505: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #4798: [FLINK-6505] Proactively cleanup local FS for Rock...

2017-10-22 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4798#discussion_r146165645 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -235,6

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214624#comment-16214624 ] ASF GitHub Bot commented on FLINK-6505: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #4798: [FLINK-6505] Proactively cleanup local FS for Rock...

2017-10-22 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4798#discussion_r146165655 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -313,10

[jira] [Comment Edited] (FLINK-7669) ClassLoader resolution-order setting is not used on client

2017-10-22 Thread Raymond Tay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214556#comment-16214556 ] Raymond Tay edited comment on FLINK-7669 at 10/23/17 4:04 AM: -- The trunk

[jira] [Comment Edited] (FLINK-7669) ClassLoader resolution-order setting is not used on client

2017-10-22 Thread Raymond Tay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214556#comment-16214556 ] Raymond Tay edited comment on FLINK-7669 at 10/23/17 4:04 AM: -- The trunk

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214593#comment-16214593 ] ASF GitHub Bot commented on FLINK-6505: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214594#comment-16214594 ] ASF GitHub Bot commented on FLINK-6505: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #4798: [FLINK-6505] Proactively cleanup local FS for RocksDBKeye...

2017-10-22 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4798 I only had a minor comment, overall the PR looks good! 👍 ---

[GitHub] flink pull request #4798: [FLINK-6505] Proactively cleanup local FS for Rock...

2017-10-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4798#discussion_r146161007 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214589#comment-16214589 ] ASF GitHub Bot commented on FLINK-6505: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4798: [FLINK-6505] Proactively cleanup local FS for Rock...

2017-10-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4798#discussion_r146160907 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[GitHub] flink issue #4879: [FLINK-7783] Don't always remove checkpoints in ZooKeeper...

2017-10-22 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4879 I think overall this fix looks very good now. This is implementing a different strategy to deal with problematic checkpoints that can recover from more scenarios than the initial PR which was

[jira] [Commented] (FLINK-7783) Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214586#comment-16214586 ] ASF GitHub Bot commented on FLINK-7783: --- Github user StefanRRichter commented on the issue:

[jira] [Commented] (FLINK-7783) Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214582#comment-16214582 ] ASF GitHub Bot commented on FLINK-7783: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4879: [FLINK-7783] Don't always remove checkpoints in Zo...

2017-10-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4879#discussion_r146160129 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java --- @@ -163,22 +162,50 @@ public

[jira] [Comment Edited] (FLINK-7669) ClassLoader resolution-order setting is not used on client

2017-10-22 Thread Raymond Tay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214556#comment-16214556 ] Raymond Tay edited comment on FLINK-7669 at 10/23/17 3:20 AM: -- The trunk

[jira] [Commented] (FLINK-7783) Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214579#comment-16214579 ] ASF GitHub Bot commented on FLINK-7783: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4879: [FLINK-7783] Don't always remove checkpoints in Zo...

2017-10-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4879#discussion_r146159867 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java --- @@ -163,22 +162,50 @@ public

[jira] [Commented] (FLINK-7783) Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214575#comment-16214575 ] ASF GitHub Bot commented on FLINK-7783: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4879: [FLINK-7783] Don't always remove checkpoints in Zo...

2017-10-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4879#discussion_r146159739 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java --- @@ -302,4 +302,32 @@ public void

[jira] [Commented] (FLINK-7669) ClassLoader resolution-order setting is not used on client

2017-10-22 Thread Raymond Tay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214556#comment-16214556 ] Raymond Tay commented on FLINK-7669: The trunk commit stands at hash:

[jira] [Comment Edited] (FLINK-5967) Document AggregatingState

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214548#comment-16214548 ] Bowen Li edited comment on FLINK-5967 at 10/23/17 2:37 AM: --- [~StephanEwen]

[jira] [Commented] (FLINK-5967) Document AggregatingState

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214548#comment-16214548 ] Bowen Li commented on FLINK-5967: - [~StephanEwen] [~aljoscha] Hi guys, while documenting

[jira] [Assigned] (FLINK-5967) Document AggregatingState

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-5967: --- Assignee: Bowen Li > Document AggregatingState > - > > Key:

[jira] [Commented] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214520#comment-16214520 ] ASF GitHub Bot commented on FLINK-7703: --- Github user zjureel closed the pull request at:

[GitHub] flink pull request #4843: [FLINK-7703] Port JobExceptionsHandler to new REST...

2017-10-22 Thread zjureel
Github user zjureel closed the pull request at: https://github.com/apache/flink/pull/4843 ---

[jira] [Commented] (FLINK-7669) ClassLoader resolution-order setting is not used on client

2017-10-22 Thread Raymond Tay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214505#comment-16214505 ] Raymond Tay commented on FLINK-7669: couldn't stay ontop of this issue - work and all. [~aljoscha] i

[jira] [Updated] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7608: Fix Version/s: (was: 1.3.3) > LatencyGauge change to histogram metric >

[jira] [Commented] (FLINK-7898) TaskExecutorTest.testTriggerRegistrationOnLeaderChange fails on Travis

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

[GitHub] flink pull request #4880: [FLINK-7898] [flip6] Don't propagate CancellationE...

2017-10-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4880#discussion_r146140859 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/registration/RegisteredRpcConnection.java --- @@ -91,9 +92,15 @@ public void start() {

[jira] [Reopened] (FLINK-6979) Add documentation for Aggregation Functions

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reopened FLINK-6979: - > Add documentation for Aggregation Functions > --- > >

[jira] [Closed] (FLINK-6979) Add documentation for Aggregation Functions

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-6979. --- Resolution: Duplicate > Add documentation for Aggregation Functions >

[jira] [Updated] (FLINK-6979) Add documentation for Aggregation Functions in Tables/UDF doc

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6979: Summary: Add documentation for Aggregation Functions in Tables/UDF doc (was: Add documentation for

[jira] [Commented] (FLINK-6245) Fix late side output documentation in Window documents.

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214374#comment-16214374 ] ASF GitHub Bot commented on FLINK-6245: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #4882: [FLINK-6245] Fix late side output documentation in...

2017-10-22 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4882 [FLINK-6245] Fix late side output documentation in Window documents. ## What is the purpose of the change There are two things that need to be done: 1) in the syntax description

[jira] [Assigned] (FLINK-6245) Fix late side output documentation in Window documents.

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-6245: --- Assignee: Bowen Li > Fix late side output documentation in Window documents. >

[jira] [Commented] (FLINK-6546) Fix dependencies of flink-mesos

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214372#comment-16214372 ] Aljoscha Krettek commented on FLINK-6546: - I think this was resolved here:

[jira] [Comment Edited] (FLINK-7669) ClassLoader resolution-order setting is not used on client

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214356#comment-16214356 ] Aljoscha Krettek edited comment on FLINK-7669 at 10/22/17 4:17 PM: ---

[jira] [Updated] (FLINK-7669) ClassLoader resolution order setting is not used on client

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7669: Summary: ClassLoader resolution order setting is not used on client (was:

[jira] [Updated] (FLINK-7669) ClassLoader resolution-order setting is not used on client

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7669: Summary: ClassLoader resolution-order setting is not used on client (was: ClassLoader

[jira] [Commented] (FLINK-7587) Flink doesn't delete empty checkpoint file's dir from s3

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214371#comment-16214371 ] Bowen Li commented on FLINK-7587: - Hi [~StephanEwen] [~till.rohrmann], do you guys know where I should

[GitHub] flink pull request #4714: [FLINK-7577][build][WIP] POM Cleanup flink-core

2017-10-22 Thread yew1eb
GitHub user yew1eb reopened a pull request: https://github.com/apache/flink/pull/4714 [FLINK-7577][build][WIP] POM Cleanup flink-core ## What is the purpose of the change This PR changes the flink-core pom to - not contain unused dependencies - contain all used

[jira] [Commented] (FLINK-7577) flink-core

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214369#comment-16214369 ] ASF GitHub Bot commented on FLINK-7577: --- GitHub user yew1eb reopened a pull request:

[jira] [Assigned] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7669: --- Assignee: Aljoscha Krettek > org.apache.flink.api.common.ExecutionConfig cannot be

[GitHub] flink pull request #4714: [FLINK-7577][build][WIP] POM Cleanup flink-core

2017-10-22 Thread yew1eb
Github user yew1eb closed the pull request at: https://github.com/apache/flink/pull/4714 ---

[jira] [Commented] (FLINK-7577) flink-core

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214359#comment-16214359 ] ASF GitHub Bot commented on FLINK-7577: --- Github user yew1eb closed the pull request at:

[jira] [Commented] (FLINK-7889) Enable dependency convergence for flink-streaming-java

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214357#comment-16214357 ] ASF GitHub Bot commented on FLINK-7889: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #4875: [FLINK-7889] Enable dependency convergence in flink-strea...

2017-10-22 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4875 @pnowojski, I found to fix this PR, must first solve the `flink-core`, `flink-runtime`, and so on. Please ignore this PR, I will close it. Please feel free to continue working on **Enable

[jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214356#comment-16214356 ] Aljoscha Krettek commented on FLINK-7669: - [~raymondtay] I did reproduce the problem by also

[jira] [Comment Edited] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214349#comment-16214349 ] Aljoscha Krettek edited comment on FLINK-7669 at 10/22/17 3:38 PM: ---

[jira] [Assigned] (FLINK-7889) Enable dependency convergence for flink-streaming-java

2017-10-22 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reassigned FLINK-7889: - Assignee: (was: Hai Zhou UTC+8) > Enable dependency convergence for

[jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214349#comment-16214349 ] Aljoscha Krettek commented on FLINK-7669: - [~kzhu] Did you try only excluding {{flint-core}}? >

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214342#comment-16214342 ] ASF GitHub Bot commented on FLINK-6505: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #4798: [FLINK-6505] Proactively cleanup local FS for RocksDBKeye...

2017-10-22 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4798 Hi @StephanEwen @StefanRRichter , please let me know if you have any more feedbacks ---

[jira] [Commented] (FLINK-5968) Document WindowedStream.aggregate()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214341#comment-16214341 ] ASF GitHub Bot commented on FLINK-5968: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #4833: [FLINK-5968] Add documentation for WindowedStream.aggrega...

2017-10-22 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4833 I just saw this PR, and sorry for submitting my feedbacks late... ---

[GitHub] flink pull request #4833: [FLINK-5968] Add documentation for WindowedStream....

2017-10-22 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4833#discussion_r146134241 --- Diff: docs/dev/stream/operators/windows.md --- @@ -427,6 +427,93 @@ input The above example sums up the second fields of the tuples for all

[GitHub] flink pull request #4833: [FLINK-5968] Add documentation for WindowedStream....

2017-10-22 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4833#discussion_r146134311 --- Diff: docs/dev/stream/operators/windows.md --- @@ -721,6 +808,111 @@ input + Incremental Window Aggregation with

[jira] [Commented] (FLINK-5968) Document WindowedStream.aggregate()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214338#comment-16214338 ] ASF GitHub Bot commented on FLINK-5968: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #4833: [FLINK-5968] Add documentation for WindowedStream....

2017-10-22 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4833#discussion_r146134163 --- Diff: docs/dev/stream/operators/windows.md --- @@ -427,6 +427,93 @@ input The above example sums up the second fields of the tuples for all

[GitHub] flink pull request #4833: [FLINK-5968] Add documentation for WindowedStream....

2017-10-22 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4833#discussion_r146134235 --- Diff: docs/dev/stream/operators/windows.md --- @@ -427,6 +427,93 @@ input The above example sums up the second fields of the tuples for all

[GitHub] flink pull request #4833: [FLINK-5968] Add documentation for WindowedStream....

2017-10-22 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4833#discussion_r146134312 --- Diff: docs/dev/stream/operators/windows.md --- @@ -721,6 +808,111 @@ input + Incremental Window Aggregation with

[jira] [Commented] (FLINK-5968) Document WindowedStream.aggregate()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214337#comment-16214337 ] ASF GitHub Bot commented on FLINK-5968: --- Github user bowenli86 commented on a diff in the pull

[jira] [Commented] (FLINK-5968) Document WindowedStream.aggregate()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214340#comment-16214340 ] ASF GitHub Bot commented on FLINK-5968: --- Github user bowenli86 commented on a diff in the pull

[jira] [Commented] (FLINK-5968) Document WindowedStream.aggregate()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214339#comment-16214339 ] ASF GitHub Bot commented on FLINK-5968: --- Github user bowenli86 commented on a diff in the pull

[jira] [Commented] (FLINK-5968) Document WindowedStream.aggregate()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214336#comment-16214336 ] ASF GitHub Bot commented on FLINK-5968: --- Github user bowenli86 commented on a diff in the pull

[jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1

2017-10-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7642: -- Description: Surefire 2.19 release introduced more useful test filters which would let us run a subset of the

[jira] [Commented] (FLINK-7864) Support side-outputs in CoProcessFunction

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214328#comment-16214328 ] ASF GitHub Bot commented on FLINK-7864: --- Github user bowenli86 closed the pull request at:

[jira] [Commented] (FLINK-7864) Support side-outputs in CoProcessFunction

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214329#comment-16214329 ] ASF GitHub Bot commented on FLINK-7864: --- GitHub user bowenli86 reopened a pull request:

[GitHub] flink pull request #4881: [FLINK-7864] [DataStream API] Support side-outputs...

2017-10-22 Thread bowenli86
Github user bowenli86 closed the pull request at: https://github.com/apache/flink/pull/4881 ---

[GitHub] flink pull request #4881: [FLINK-7864] [DataStream API] Support side-outputs...

2017-10-22 Thread bowenli86
GitHub user bowenli86 reopened a pull request: https://github.com/apache/flink/pull/4881 [FLINK-7864] [DataStream API] Support side-outputs in CoProcessFunction ## What is the purpose of the change Support side-outputs in CoProcessFunction ## Brief change log

[GitHub] flink issue #4786: [FLINK-7388][DataStream API] ProcessFunction.onTimer() se...

2017-10-22 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4786 Hi @aljoscha @fhueske , please let me know if you have any more comments ---

[jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214327#comment-16214327 ] ASF GitHub Bot commented on FLINK-7388: --- Github user bowenli86 commented on the issue:

[jira] [Updated] (FLINK-7820) deprecate docs of FoldingState and FoldingStateDescriptor

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7820: Summary: deprecate docs of FoldingState and FoldingStateDescriptor (was: remove text related to

[GitHub] flink issue #4757: [Flink 7694][REST][Webfrontend]Port JobMetricsHandler to ...

2017-10-22 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4757 Hi @tillrohrmann , I'm spending time on issues of 1.4.0. This handler is not on my top priority right now. Please feel free to continue working on this if you'd like to :) ---

[jira] [Issue Comment Deleted] (FLINK-7864) Support side-outputs in CoProcessFunction

2017-10-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7864: Comment: was deleted (was: With the latest master branch, I found I cannot run {{SideOutputITCase.java}}

[GitHub] flink pull request #4881: Flink 7864

2017-10-22 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4881 Flink 7864 ## What is the purpose of the change Support side-outputs in CoProcessFunction ## Brief change log - Support side-outputs in CoProcessFunction - Added

[jira] [Resolved] (FLINK-7579) Documentation of yarn.application-attempts is not accurate

2017-10-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7579. -- Resolution: Fixed > Documentation of yarn.application-attempts is not accurate >

[jira] [Updated] (FLINK-7579) Documentation of yarn.application-attempts is not accurate

2017-10-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7579: - Fix Version/s: 1.4.0 > Documentation of yarn.application-attempts is not accurate >

[jira] [Commented] (FLINK-7579) Documentation of yarn.application-attempts is not accurate

2017-10-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214293#comment-16214293 ] Till Rohrmann commented on FLINK-7579: -- Fixed via 94f1d2b1672ee8f34db9ae85b94bd916ebc38f3e >

[jira] [Commented] (FLINK-7579) Documentation of yarn.application-attempts is not accurate

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

[jira] [Assigned] (FLINK-7579) Documentation of yarn.application-attempts is not accurate

2017-10-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7579: Assignee: Sebastian Klemke > Documentation of yarn.application-attempts is not accurate >

[GitHub] flink pull request #4642: [FLINK-7579] [Documentation] More accurate descrip...

2017-10-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4642 ---

[jira] [Commented] (FLINK-7898) TaskExecutorTest.testTriggerRegistrationOnLeaderChange fails on Travis

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214290#comment-16214290 ] ASF GitHub Bot commented on FLINK-7898: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4880: [FLINK-7898] [flip6] Don't propagate CancellationE...

2017-10-22 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4880 [FLINK-7898] [flip6] Don't propagate CancellationExceptions in RegisteredRpcConnection ## What is the purpose of the change The RegisteredRpcConnection should not call the exception

[jira] [Created] (FLINK-7898) TaskExecutorTest.testTriggerRegistrationOnLeaderChange fails on Travis

2017-10-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7898: Summary: TaskExecutorTest.testTriggerRegistrationOnLeaderChange fails on Travis Key: FLINK-7898 URL: https://issues.apache.org/jira/browse/FLINK-7898 Project: Flink

[jira] [Commented] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214281#comment-16214281 ] Aljoscha Krettek commented on FLINK-7880: - I {{@Ignored}} the unstable tests in

[jira] [Updated] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-10-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7880: Priority: Blocker (was: Critical) > flink-queryable-state-java fails with core-dump >

[jira] [Commented] (FLINK-7783) Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214255#comment-16214255 ] ASF GitHub Bot commented on FLINK-7783: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request #4879: [FLINK-7783] Don't always remove checkpoints in Zo...

2017-10-22 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4879 [FLINK-7783] Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover() I think this will be the final version for what I started in #4863. Now, the code will retrieve

[jira] [Commented] (FLINK-7783) Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214254#comment-16214254 ] ASF GitHub Bot commented on FLINK-7783: --- Github user aljoscha closed the pull request at:

[GitHub] flink pull request #4870: [FLINK-7783] Don't always remove checkpoints in Zo...

2017-10-22 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/4870 ---

[jira] [Commented] (FLINK-7502) PrometheusReporter improvements

2017-10-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16214244#comment-16214244 ] ASF GitHub Bot commented on FLINK-7502: --- Github user mbode commented on the issue:

[GitHub] flink issue #4586: [FLINK-7502] [metrics] Improve PrometheusReporter

2017-10-22 Thread mbode
Github user mbode commented on the issue: https://github.com/apache/flink/pull/4586 [Green Travis](https://travis-ci.org/mbode/flink/builds/290468452) ---