[jira] [Updated] (FLINK-7475) ListState support update

2017-10-26 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7475: Fix Version/s: 1.5.0 > ListState support update > > > Key:

[jira] [Created] (FLINK-7929) Add unit/integration tests for states backed by RocksDB

2017-10-26 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7929: --- Summary: Add unit/integration tests for states backed by RocksDB Key: FLINK-7929 URL: https://issues.apache.org/jira/browse/FLINK-7929 Project: Flink Issue Type: Test

[jira] [Commented] (FLINK-7574) flink-clients

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

[GitHub] flink issue #4712: [FLINK-7574][build] POM Cleanup flink-clients

2017-10-26 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4712 this needs an update. (flakka dependency was replaced with akka-actor; now has a dependency on flink-shaded-netty). We should definitely look for a plugin configuration that fails the build

[GitHub] flink issue #4904: [hotfix] reorder the methods so they conform to their ord...

2017-10-26 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4904 ```[INFO] [INFO] Building flink-streaming-java 1.4-SNAPSHOT [INFO]

[jira] [Assigned] (FLINK-7420) Move all Avro code to flink-avro

2017-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7420: --- Assignee: Aljoscha Krettek (was: Timo Walther) > Move all Avro code to flink-avro >

[jira] [Commented] (FLINK-4831) Implement a slf4j metric reporter

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

[GitHub] flink pull request #4661: [FLINK-4831][metrics] Implement a slf4j metric rep...

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

[jira] [Commented] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks

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

[GitHub] flink pull request #4900: [FLINK-7666] Close TimeService after closing opera...

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

[jira] [Closed] (FLINK-4831) Implement a slf4j metric reporter

2017-10-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4831. --- Resolution: Fixed 1.4: c0199f5d181a8d249201004f6ec6f897f9b799c4 > Implement a slf4j metric

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

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

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

2017-10-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7502. --- Resolution: Fixed 1.4: 56017a98fa61fdfae1c8dadd90a378ffdb3fea72 > PrometheusReporter

[GitHub] flink issue #4896: [FLINK-7909] Unify Flink test bases

2017-10-26 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4896 It compiles now @zentol. ---

[jira] [Commented] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16220118#comment-16220118 ] Kostas Kloudas commented on FLINK-7666: --- If I understand correctly, then this is how is used to be,

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

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

[jira] [Resolved] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7540. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) Fixed via

[GitHub] flink pull request #4812: [FLINK-7540] Apply consistent hostname normalizati...

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

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[jira] [Closed] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7666. - Resolution: Fixed Merged on master at b7f0f5f4d1dc49cafd50c7c72148580fe6947ef5 >

[jira] [Commented] (FLINK-7540) Akka hostnames are not normalised consistently

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

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[GitHub] flink issue #4896: [FLINK-7909] Unify Flink test bases

2017-10-26 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4896 Do you intend to merge this for 1.4? (I would prefer merging it after the fork). ---

[GitHub] flink issue #4903: [FLINK-7914] Introduce AkkaOptions.RETRY_GATE_CLOSED_FOR

2017-10-26 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4903 Akka's default value is actually 5 seconds, which I think is a bit too high. I actually tried to backtrack an instability in the `JobManagerFailsITCase` and noticed that this test took

[jira] [Commented] (FLINK-7914) Expose Akka gated interval as user option

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

[jira] [Commented] (FLINK-7920) Make MiniClusterConfiguration immutable

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

[GitHub] flink issue #4905: [FLINK-7920] Make MiniClusterConfiguration immutable

2017-10-26 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4905 Thanks for the review @StephanEwen. Merging this PR. ---

[jira] [Commented] (FLINK-7920) Make MiniClusterConfiguration immutable

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

[GitHub] flink pull request #4905: [FLINK-7920] Make MiniClusterConfiguration immutab...

2017-10-26 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/4905 ---

[jira] [Closed] (FLINK-7920) Make MiniClusterConfiguration immutable

2017-10-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7920. Resolution: Fixed Fix Version/s: 1.4.0 Fixed via a9743eb6850809784930c1199741aa83ae54e99a >

[GitHub] flink issue #4896: [FLINK-7909] Unify Flink test bases

2017-10-26 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4896 Yes, this can wait until after the fork. Moreover, I will do what @StephanEwen suggested and count the number of executed tests before and after of this change to make sure that we don't

[jira] [Commented] (FLINK-7909) Unify cluster creation for test bases

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

[jira] [Assigned] (FLINK-7076) Implement container release to support dynamic scaling

2017-10-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7076: Assignee: Shuyi Chen (was: Aljoscha Krettek) > Implement container release to support

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2017-10-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16220179#comment-16220179 ] Fabian Hueske commented on FLINK-7923: -- Thanks for reporting the problem [~walterddr]. Can you create

[jira] [Commented] (FLINK-7903) Add Flip6 build profile

2017-10-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16220184#comment-16220184 ] Till Rohrmann commented on FLINK-7903: -- I don't think that we will directly after 1.4 remove the

[jira] [Created] (FLINK-7930) Support periodic jobs with state that gets restored and persisted in a savepoint

2017-10-26 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-7930: - Summary: Support periodic jobs with state that gets restored and persisted in a savepoint Key: FLINK-7930 URL: https://issues.apache.org/jira/browse/FLINK-7930

[GitHub] flink pull request #4827: [FLINK-7840] [build] Shade netty in akka

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4827#discussion_r147087742 --- Diff: flink-runtime/pom.xml --- @@ -427,17 +427,42 @@ under the License. shade

[jira] [Commented] (FLINK-7840) Shade Akka's Netty Dependency

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

[GitHub] flink pull request #4827: [FLINK-7840] [build] Shade netty in akka

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4827#discussion_r147088234 --- Diff: flink-test-utils-parent/flink-test-utils/pom.xml --- @@ -117,6 +124,41 @@ under the License. true

[jira] [Commented] (FLINK-7840) Shade Akka's Netty Dependency

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

[GitHub] flink pull request #4827: [FLINK-7840] [build] Shade netty in akka

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4827#discussion_r147088428 --- Diff: flink-runtime/pom.xml --- @@ -427,17 +427,42 @@ under the License. shade

[jira] [Commented] (FLINK-7840) Shade Akka's Netty Dependency

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

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147088900 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java --- @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147089150 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -116,6 +117,10 @@ * accessing this

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147088825 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java --- @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147089325 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java --- @@ -229,29 +229,31 @@ public static

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147089435 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ConfigurableStateBackend.java --- @@ -0,0 +1,45 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[jira] [Commented] (FLINK-7843) Improve and enhance documentation for system metrics

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

[GitHub] flink pull request #4869: [FLINK-7843][docs] Improve documentation for metri...

2017-10-26 Thread yew1eb
Github user yew1eb commented on a diff in the pull request: https://github.com/apache/flink/pull/4869#discussion_r147090125 --- Diff: docs/monitoring/metrics.md --- @@ -543,62 +546,75 @@ Thus, in order to infer the metric identifier:

[jira] [Commented] (FLINK-7843) Improve and enhance documentation for system metrics

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

[GitHub] flink pull request #4869: [FLINK-7843][docs] Improve documentation for metri...

2017-10-26 Thread yew1eb
Github user yew1eb commented on a diff in the pull request: https://github.com/apache/flink/pull/4869#discussion_r147090107 --- Diff: docs/monitoring/metrics.md --- @@ -543,62 +546,75 @@ Thus, in order to infer the metric identifier:

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147090207 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/AbstractFileStateBackend.java --- @@ -0,0 +1,206 @@ +/* + *

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147090655 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java --- @@ -18,54 +18,92 @@ package

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[jira] [Commented] (FLINK-7843) Improve and enhance documentation for system metrics

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

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147091056 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackendFactory.java --- @@ -18,45 +18,41 @@ package

[GitHub] flink pull request #4869: [FLINK-7843][docs] Improve documentation for metri...

2017-10-26 Thread yew1eb
Github user yew1eb commented on a diff in the pull request: https://github.com/apache/flink/pull/4869#discussion_r147090946 --- Diff: docs/monitoring/metrics.md --- @@ -801,53 +849,67 @@ Thus, in order to infer the metric identifier: - Scope -

[jira] [Commented] (FLINK-7843) Improve and enhance documentation for system metrics

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

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[GitHub] flink pull request #4869: [FLINK-7843][docs] Improve documentation for metri...

2017-10-26 Thread yew1eb
Github user yew1eb commented on a diff in the pull request: https://github.com/apache/flink/pull/4869#discussion_r147091360 --- Diff: docs/monitoring/metrics.md --- @@ -801,53 +849,67 @@ Thus, in order to infer the metric identifier: - Scope -

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147092074 --- Diff: flink-core/src/main/java/org/apache/flink/util/FileUtils.java --- @@ -243,11 +245,19 @@ else if (directory.exists()) { * @throws

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[GitHub] flink pull request #4869: [FLINK-7843][docs] Improve documentation for metri...

2017-10-26 Thread yew1eb
Github user yew1eb commented on a diff in the pull request: https://github.com/apache/flink/pull/4869#discussion_r147092709 --- Diff: docs/monitoring/metrics.md --- @@ -856,66 +918,80 @@ Thus, in order to infer the metric identifier: - Scope -

[jira] [Commented] (FLINK-7843) Improve and enhance documentation for system metrics

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

[GitHub] flink pull request #4907: [FLINK-5823] [checkpoints] State Backends also han...

2017-10-26 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4907#discussion_r147093502 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java --- @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[GitHub] flink issue #4907: [FLINK-5823] [checkpoints] State Backends also handle Che...

2017-10-26 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4907 Btw, all my comments are not blocking this PR. If travis is green I would suggest to merge or continue with the follow-up work. The stuff about state backends and renaming should be done

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[jira] [Commented] (FLINK-7843) Improve and enhance documentation for system metrics

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

[GitHub] flink pull request #4869: [FLINK-7843][docs] Improve documentation for metri...

2017-10-26 Thread yew1eb
Github user yew1eb commented on a diff in the pull request: https://github.com/apache/flink/pull/4869#discussion_r147100695 --- Diff: docs/monitoring/metrics.md --- @@ -856,66 +918,80 @@ Thus, in order to infer the metric identifier: - Scope -

[jira] [Reopened] (FLINK-7884) Port CheckpointConfigHandler to new REST endpoint

2017-10-26 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reopened FLINK-7884: --- Assignee: (was: Hai Zhou UTC+8) > Port CheckpointConfigHandler to new REST endpoint >

[jira] [Closed] (FLINK-7884) Port CheckpointConfigHandler to new REST endpoint

2017-10-26 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7884. - Resolution: Duplicate > Port CheckpointConfigHandler to new REST endpoint >

[jira] [Reopened] (FLINK-7885) Port CheckpointStatsDetailsHandler to new REST endpoint

2017-10-26 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reopened FLINK-7885: --- Assignee: (was: Hai Zhou UTC+8) > Port CheckpointStatsDetailsHandler to new REST

[jira] [Reopened] (FLINK-7892) Port CheckpointStatsHandler to new REST endpoint

2017-10-26 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reopened FLINK-7892: --- Assignee: (was: Hai Zhou UTC+8) > Port CheckpointStatsHandler to new REST endpoint >

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

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16220281#comment-16220281 ] Kostas Kloudas commented on FLINK-7880: --- Yes I will look into it. > flink-queryable-state-java

[jira] [Closed] (FLINK-7885) Port CheckpointStatsDetailsHandler to new REST endpoint

2017-10-26 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7885. - Resolution: Duplicate > Port CheckpointStatsDetailsHandler to new REST endpoint >

[jira] [Reopened] (FLINK-7893) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint

2017-10-26 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reopened FLINK-7893: --- > Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint >

[jira] [Closed] (FLINK-7893) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint

2017-10-26 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7893. - Resolution: Fixed > Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint >

[jira] [Closed] (FLINK-7892) Port CheckpointStatsHandler to new REST endpoint

2017-10-26 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7892. - Resolution: Fixed > Port CheckpointStatsHandler to new REST endpoint >

[jira] [Updated] (FLINK-7931) FlinkKinesisProducer violates at-least-once guarantees (1.3 branch)

2017-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7931: Fix Version/s: (was: 1.4.0) > FlinkKinesisProducer violates at-least-once guarantees

[jira] [Created] (FLINK-7931) FlinkKinesisProducer violates at-least-once guarantees (1.3 branch)

2017-10-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7931: --- Summary: FlinkKinesisProducer violates at-least-once guarantees (1.3 branch) Key: FLINK-7931 URL: https://issues.apache.org/jira/browse/FLINK-7931 Project:

[jira] [Updated] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

2017-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5015: Priority: Critical (was: Blocker) > Add Tests/ITCase for Kafka Per-Partition Watermarks >

[jira] [Updated] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

2017-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7637: Fix Version/s: (was: 1.3.3) > FlinkKinesisProducer violates at-least-once guarantees >

[jira] [Closed] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

2017-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7637. --- Resolution: Fixed > FlinkKinesisProducer violates at-least-once guarantees >

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

2017-10-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16220286#comment-16220286 ] Aljoscha Krettek commented on FLINK-7637: - I created FLINK-7931 for tracking this issue for 1.3.3

[jira] [Commented] (FLINK-5967) Add RuntimeContext#getAggregatingState() and document AggregatingState

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

[GitHub] flink issue #4899: [FLINK-5967][DataStream API][Doc] Add RuntimeContext#getA...

2017-10-26 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4899 @StephanEwen @aljoscha Hi guys, I'm not sure if this is counted as a feature or not (I guess so, because this PR adds a few new public APIs). If so, it would be necessary to get this into master

[GitHub] flink issue #4884: [FLINK-7705] Add JobDetailsHandler

2017-10-26 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4884 Hi @tillrohrmann , could you merge this PR when you're free? Some issues depend on `MetricFetcher` and I found it would be added to `DispatcherRestEndpoint` in this PR. THX ---

[jira] [Commented] (FLINK-6875) Remote DataSet API job submission timing out

2017-10-26 Thread hetang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16221634#comment-16221634 ] hetang commented on FLINK-6875: --- 十月 26, 2017 7:51:15 δΈ‹εˆ org.apache.flink.runtime.blob.BlobClient

[jira] [Created] (FLINK-7935) Metrics with user supplied scope variables

2017-10-26 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7935: - Summary: Metrics with user supplied scope variables Key: FLINK-7935 URL: https://issues.apache.org/jira/browse/FLINK-7935 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7705) Port JobDetailsHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2017-10-26 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16221566#comment-16221566 ] Wei-Che Wei commented on FLINK-7935: Hi [~elevy] Is this issue same as FLINK-7692 > Metrics with user

[jira] [Commented] (FLINK-7100) TaskManager metrics are registered twice

2017-10-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16221567#comment-16221567 ] Fang Yong commented on FLINK-7100: -- [~Zentol] [~till.rohrmann], thank you for your suggestions. If I

[GitHub] flink issue #4844: [FLINK-7844] [ckPt] Fail unacknowledged pending checkpoin...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4844 Had an offline discussion with @tillrohrmann - rewriting this without Mockito results in a similar amount of code with similar maintenance effort, so seems to be okay in this case. +1

  1   2   3   >