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

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6567: Fix Version/s: (was: 1.5.0) 1.6.0 > ExecutionGraphMetricsTest fails

[jira] [Closed] (FLINK-8758) Expose method for non-blocking job submission on ClusterClient

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8758. --- Resolution: Fixed master: 1e48b722d23dc160e065b04c93d41b8df1400c19 1.5:

[GitHub] flink pull request #5573: [FLINK-8756][Client] Support ClusterClient.getAccu...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5573#discussion_r172651895 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -389,6 +394,33 @@ public String

[jira] [Updated] (FLINK-8759) Bump Netty to 4.0.56

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8759: Fix Version/s: (was: 1.5.0) 1.6.0 > Bump Netty to 4.0.56 >

[jira] [Updated] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7286: Fix Version/s: (was: 1.5.0) 1.6.0 > Flink Dashboard fails to display

[jira] [Updated] (FLINK-5513) Remove relocation of internal API classes

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5513: Fix Version/s: (was: 1.5.0) 1.6.0 > Remove relocation of internal

[GitHub] flink pull request #5573: [FLINK-8756][Client] Support ClusterClient.getAccu...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5573#discussion_r172648627 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsQueryParameter.java --- @@ -0,0 +1,41 @@ +/* + *

[GitHub] flink pull request #5573: [FLINK-8756][Client] Support ClusterClient.getAccu...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5573#discussion_r172648802 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java --- @@ -104,6 +129,18 @@ public UserTaskAccumulator(

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[GitHub] flink pull request #5573: [FLINK-8756][Client] Support ClusterClient.getAccu...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5573#discussion_r172648696 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsQueryParameter.java --- @@ -0,0 +1,41 @@ +/* + *

[GitHub] flink pull request #5646: [hotfix] [javadocs] minor javadoc fix in Timestamp...

2018-03-06 Thread pjfanning
GitHub user pjfanning opened a pull request: https://github.com/apache/flink/pull/5646 [hotfix] [javadocs] minor javadoc fix in TimestampAssigner You can merge this pull request into a Git repository by running: $ git pull https://github.com/pjfanning/flink patch-1

[jira] [Updated] (FLINK-8793) Hide key containing "secret" in web interface

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8793: Priority: Blocker (was: Minor) > Hide key containing "secret" in web interface >

[jira] [Updated] (FLINK-7957) Add MetricGroup#getLogicalScope

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7957: Fix Version/s: (was: 1.5.0) > Add MetricGroup#getLogicalScope >

[GitHub] flink issue #5573: [FLINK-8756][Client] Support ClusterClient.getAccumulator...

2018-03-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5573 We may want to delay merging this until [FLINK-8881](https://issues.apache.org/jira/browse/FLINK-8881) has been addressed, as it voids the primary use-case of this handler. ---

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[GitHub] flink issue #5645: FLINK-8876 Improve concurrent access handling in stateful...

2018-03-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5645 The end-to-end test would be cheap as we wouldn't execute a flink job or even start a flink cluster. The scripts in `flink-end-to-end-tests` can do pretty much anything they want; my idea was to

[jira] [Updated] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

2018-03-06 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8459: Release Note: The REST API to trigger the "cancel with savepoint" action has changed, and is not backwards

[GitHub] flink pull request #5573: [FLINK-8756][Client] Support ClusterClient.getAccu...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5573#discussion_r172650031 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java --- @@ -33,19 +39,38 @@ public class

[jira] [Commented] (FLINK-8876) Improve concurrent access handling in stateful serializers

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

[jira] [Reopened] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

2018-03-06 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reopened FLINK-8459: - > Implement cancelWithSavepoint in RestClusterClient > -- > >

[jira] [Updated] (FLINK-8031) Provide configuration to enable/disable ability to cancel jobs in Web Frontend

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8031: Fix Version/s: (was: 1.5.0) > Provide configuration to enable/disable ability to cancel

[jira] [Closed] (FLINK-8885) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8885. --- Resolution: Duplicate > The DispatcherThreadFactory should register uncaught exception

[jira] [Updated] (FLINK-8033) Build Flink with JDK 9

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8033: Fix Version/s: (was: 1.5.0) 1.6.0 > Build Flink with JDK 9 >

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

2018-03-06 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8887: --- Summary: ClusterClient.getJobStatus can throw FencingTokenException Key: FLINK-8887 URL: https://issues.apache.org/jira/browse/FLINK-8887 Project: Flink Issue Type:

[jira] [Closed] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

2018-03-06 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-8459. --- Resolution: Fixed > Implement cancelWithSavepoint in RestClusterClient >

[jira] [Created] (FLINK-8886) Job isolation via scheduling in shared cluster

2018-03-06 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8886: - Summary: Job isolation via scheduling in shared cluster Key: FLINK-8886 URL: https://issues.apache.org/jira/browse/FLINK-8886 Project: Flink Issue Type:

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6053: Fix Version/s: (was: 1.5.0) 1.6.0 > Gauge should only take

[jira] [Updated] (FLINK-8047) Create HTTP Sink

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8047: Fix Version/s: (was: 1.5.0) 1.6.0 > Create HTTP Sink >

[jira] [Updated] (FLINK-5005) Remove Scala 2.10 support; add Scala 2.12 support

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5005: Fix Version/s: (was: 1.5.0) 1.6.0 > Remove Scala 2.10 support; add

[jira] [Updated] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6900: Fix Version/s: (was: 1.5.0) 1.6.0 > Limit size of indiivual

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

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

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8655: Fix Version/s: (was: 1.5.0) 1.6.0 > Add a default keyspace to

[GitHub] flink issue #5501: [FLINK-6053][metrics] Add new Number-/StringGauge metric ...

2018-03-06 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5501 LGTM, +1 on merging to 1.6.0 ---

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

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

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[jira] [Created] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

2018-03-06 Thread Kailash Hassan Dayanand (JIRA)
Kailash Hassan Dayanand created FLINK-: -- Summary: Upgrade AWS SDK in flink-connector-kinesis Key: FLINK- URL: https://issues.apache.org/jira/browse/FLINK- Project: Flink

[jira] [Updated] (FLINK-8883) ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal

2018-03-06 Thread Ken Krugler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler updated FLINK-8883: --- Summary: ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal (was:

[jira] [Commented] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

2018-03-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16388891#comment-16388891 ] mingleizhang commented on FLINK-8687: - [~yuzhih...@gmail.com] I think I was wrong. >

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

2018-03-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8887: --- Assignee: vinoyang > ClusterClient.getJobStatus can throw FencingTokenException >

[jira] [Updated] (FLINK-8873) move unit tests of KeyedStream from DataStreamTest to KeyedStreamTest

2018-03-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8873: Summary: move unit tests of KeyedStream from DataStreamTest to KeyedStreamTest (was: move unit tests of

[jira] [Updated] (FLINK-8873) move unit tests of KeyedStream from DataStreamTest to KeyedStreamTest

2018-03-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8873: Fix Version/s: 1.5.0 > move unit tests of KeyedStream from DataStreamTest to KeyedStreamTest >

[GitHub] flink issue #5449: [FLINK-8623] ConnectionUtilsTest.testReturnLocalHostAddre...

2018-03-06 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5449 Thanks @NicoK . Use this patch pushed here at least two times and Travis CI verifies without error for this. ---

[jira] [Closed] (FLINK-8874) rewrite Flink docs/dev/stream/operators/process_function.md to recommend using KeyedProcessFunction

2018-03-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-8874. --- Resolution: Invalid > rewrite Flink docs/dev/stream/operators/process_function.md to recommend > using

[jira] [Updated] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

2018-03-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7775: -- Description: {code} public int getNumberOfCachedJobs() { return jobRefCounters.size(); } {code} The

[jira] [Commented] (FLINK-8873) move unit tests of KeyedStream from DataStreamTest to KeyedStreamTest

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

[GitHub] flink pull request #5649: [FLINK-8873] [DataStream API] [Tests] move unit te...

2018-03-06 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5649 [FLINK-8873] [DataStream API] [Tests] move unit tests of KeyedStream from DataStreamTest to KeyedStreamTest ## What is the purpose of the change move unit tests of `KeyedStream` from

[GitHub] flink pull request #5573: [FLINK-8756][Client] Support ClusterClient.getAccu...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5573#discussion_r172755830 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -389,6 +393,27 @@ public String

[jira] [Commented] (FLINK-8860) SlotManager spamming log files

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

[GitHub] flink pull request #5573: [FLINK-8756][Client] Support ClusterClient.getAccu...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5573#discussion_r172756640 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsMessageParameters.java --- @@ -0,0 +1,35 @@ +/* + *

[GitHub] flink issue #5637: [FLINK-8860][flip6] stop SlotManager spamming logs for ev...

2018-03-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5637 I would go for `TRACE` given how often we set the log level to `DEBUG`. ---

[jira] [Commented] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

2018-03-06 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16388890#comment-16388890 ] mingleizhang commented on FLINK-8687: - Thanks [~yuzhih...@gmail.com] , actually, I do not know the

[jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

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

[GitHub] flink issue #5634: [FLINK-5479] [kafka] Idleness detection for periodic per-...

2018-03-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5634 A few points to mention: 1. @StephanEwen there is already common idleness detection implemented within `SourceContext`s, see `StreamSourceContexts`. The idleness detection, however, is

[jira] [Commented] (FLINK-8845) Introduce `parallel recovery` mode for full checkpoint (savepoint)

2018-03-06 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389123#comment-16389123 ] Sihua Zhou commented on FLINK-8845: --- Unfortunately, even though according to RocksDB

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[GitHub] flink pull request #5573: [FLINK-8756][Client] Support ClusterClient.getAccu...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5573#discussion_r172756524 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -389,6 +393,27 @@ public String

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[jira] [Commented] (FLINK-8845) Introduce `parallel recovery` mode for full checkpoint (savepoint)

2018-03-06 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389179#comment-16389179 ] Sihua Zhou commented on FLINK-8845: --- Event though, {{SstFileWriter}} could not help us to improve

[GitHub] flink pull request #5647: [FLINK-8687] Make MaterializedCollectStreamResult#...

2018-03-06 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5647 [FLINK-8687] Make MaterializedCollectStreamResult#retrievePage to hav… …e resultLock ## What is the purpose of the change Currently

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

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

[GitHub] flink pull request #5648: [FLINK-8887][flip-6] ClusterClient.getJobStatus ca...

2018-03-06 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5648 [FLINK-8887][flip-6] ClusterClient.getJobStatus can throw FencingTokenException ## What is the purpose of the change *This pull request fixed ClusterClient.getJobStatus throw

[jira] [Commented] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

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

[jira] [Commented] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

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

[GitHub] flink issue #5573: [FLINK-8756][Client] Support ClusterClient.getAccumulator...

2018-03-06 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5573 hi @zentol , I refactor the code based on your review suggestion. Would you please review again, thanks! ---

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2018-03-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 3/6/18 5:03 PM: --- In

[GitHub] flink issue #5634: [FLINK-5479] [kafka] Idleness detection for periodic per-...

2018-03-06 Thread tweise
Github user tweise commented on the issue: https://github.com/apache/flink/pull/5634 There was a related discussion on the mailing list; this and several other features could be provided by a common connector framework. Such initiative is a much larger effort though and it is not

[jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

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

[jira] [Updated] (FLINK-8708) Unintended integer division in StandaloneThreadedGenerator

2018-03-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8708: -- Description: In

[GitHub] flink issue #5601: [FLINK-8818][yarn/s3][tests] harden YarnFileStageTest upl...

2018-03-06 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5601 Different FS implementations try to circumvent the problem (or not), e.g. Presto's implementation implements the retries itself whenever it cannot find an object, while Hadoop's implementation did not

[GitHub] flink issue #5481: [FLINK-8560] Access to the current key in ProcessFunction...

2018-03-06 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5481 Thanks @bowenli86 ! I will merge as soon as Travis gives green. ---

[GitHub] flink issue #5601: [FLINK-8818][yarn/s3][tests] harden YarnFileStageTest upl...

2018-03-06 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5601 also see further test changes in this regard in #5624 ---

[jira] [Commented] (FLINK-8819) Rework travis script to use build stages

2018-03-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16387522#comment-16387522 ] Stephan Ewen commented on FLINK-8819: - I agree, already helps. Does the "compile" stage also cover

[jira] [Comment Edited] (FLINK-8819) Rework travis script to use build stages

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382609#comment-16382609 ] Chesnay Schepler edited comment on FLINK-8819 at 3/6/18 9:43 AM: - A nearly

[jira] [Commented] (FLINK-8819) Rework travis script to use build stages

2018-03-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16387528#comment-16387528 ] Chesnay Schepler commented on FLINK-8819: - Yes. The "compile" stage also covers the various checks

[jira] [Commented] (FLINK-7612) Implement Event-driven Network IO

2018-03-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16387578#comment-16387578 ] Nico Kruber commented on FLINK-7612: The original approach had some issues with cases where we were

[jira] [Closed] (FLINK-4328) Harden JobManagerHA*ITCase

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4328. --- Resolution: Won't Fix Fix Version/s: (was: 1.5.0) Closing for now since these

[jira] [Closed] (FLINK-4005) LocalExecutorITCase.testLocalExecutorWithWordCount fails

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4005. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since we

[jira] [Closed] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4072. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since we

[jira] [Created] (FLINK-8878) Check for concurrent access to Kryo Serializer

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8878: --- Summary: Check for concurrent access to Kryo Serializer Key: FLINK-8878 URL: https://issues.apache.org/jira/browse/FLINK-8878 Project: Flink Issue Type:

[jira] [Created] (FLINK-8879) Add concurrent access check to AvroSerializer

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8879: --- Summary: Add concurrent access check to AvroSerializer Key: FLINK-8879 URL: https://issues.apache.org/jira/browse/FLINK-8879 Project: Flink Issue Type:

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

2018-03-06 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8880: -- Summary: Validate configurations for SQL Client Key: FLINK-8880 URL: https://issues.apache.org/jira/browse/FLINK-8880 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-7612) Implement Event-driven Network IO

2018-03-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-7612. -- Resolution: Won't Do > Implement Event-driven Network IO > - > >

[jira] [Closed] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3516. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since we

[jira] [Closed] (FLINK-5191) ConnectedComponentsWithDeferredUpdateITCase failed

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5191. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since we

[jira] [Closed] (FLINK-5202) test timeout (no output for 300s) in YARNHighAvailabilityITCase

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5202. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since we

[jira] [Closed] (FLINK-4878) ReduceTaskExternalITCase.testMultiLevelMergeCombiningReduceTask test instable

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4878. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since we

[jira] [Closed] (FLINK-5100) Test testZooKeeperReelection is instable

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5100. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since we

[jira] [Closed] (FLINK-4524) JobManagerProcessReapingTest.testReapProcessOnFailure unstable

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4524. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since we

[jira] [Created] (FLINK-8876) Improve concurrent access handling in stateful serializers

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8876: --- Summary: Improve concurrent access handling in stateful serializers Key: FLINK-8876 URL: https://issues.apache.org/jira/browse/FLINK-8876 Project: Flink Issue

[jira] [Resolved] (FLINK-8769) Quickstart job execution in IDE logs contain several exceptions

2018-03-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-8769. Resolution: Fixed Fix Version/s: 1.6.0 Fixed with master:

[jira] [Commented] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write

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

[jira] [Commented] (FLINK-8560) add KeyedProcessFunction to expose the key in onTimer() and other methods

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

[jira] [Commented] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write

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

[jira] [Closed] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3096. --- Resolution: Invalid Fix Version/s: (was: 1.5.0) The test is not in the code base

[jira] [Closed] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

2018-03-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2671. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since we

[jira] [Created] (FLINK-8875) Watermark tab on Web Interface should display low watermark in ISO8601

2018-03-06 Thread Daniel Harper (JIRA)
Daniel Harper created FLINK-8875: Summary: Watermark tab on Web Interface should display low watermark in ISO8601 Key: FLINK-8875 URL: https://issues.apache.org/jira/browse/FLINK-8875 Project: Flink

  1   2   >