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

2017-10-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-7820. --- Resolution: Fixed This is done as part of FLINK-5967 > deprecate docs of FoldingState and FoldingStateDescrip

[jira] [Commented] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-10-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222978#comment-16222978 ] Bowen Li commented on FLINK-6615: - I would recommend closing this ticket as 'Not a problem

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

2017-10-27 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222972#comment-16222972 ] Elias Levy commented on FLINK-7935: --- Possibly. It depends on whether you could add mult

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

2017-10-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222891#comment-16222891 ] Bowen Li commented on FLINK-6951: - The workaround is: rather than using httpclient-4.2.5 a

[jira] [Created] (FLINK-7938) support addAll() in ListState

2017-10-27 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7938: --- Summary: support addAll() in ListState Key: FLINK-7938 URL: https://issues.apache.org/jira/browse/FLINK-7938 Project: Flink Issue Type: Improvement Component

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

2017-10-27 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: Summary: support update() in ListState (was: ListState support update) > support update() in ListState > --

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

2017-10-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222868#comment-16222868 ] Bowen Li commented on FLINK-7929: - [~aljoscha] Thanks for pointing that out! I'm closing t

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

2017-10-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-7929. --- Resolution: Invalid > Add unit/integration tests for states backed by RocksDB > --

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222855#comment-16222855 ] ASF GitHub Bot commented on FLINK-6225: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222852#comment-16222852 ] ASF GitHub Bot commented on FLINK-6225: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

2017-10-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r147517745 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java --- @@ -0,0 +1,82

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

2017-10-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r147442488 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -205,12 +207,16

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222853#comment-16222853 ] ASF GitHub Bot commented on FLINK-6225: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222854#comment-16222854 ] ASF GitHub Bot commented on FLINK-6225: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

2017-10-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r147507230 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java --- @@ -0,0 +1,82

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

2017-10-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r147456818 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -375,6 +381,34

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

2017-10-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r147517530 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@ -392

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222856#comment-16222856 ] ASF GitHub Bot commented on FLINK-6225: --- Github user fhueske commented on a diff in

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

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

[GitHub] flink pull request #4899: [FLINK-5967][DataStream API][Doc] Add RuntimeConte...

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

[GitHub] flink pull request #4904: [hotfix] reorder the methods so they conform to th...

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

[jira] [Updated] (FLINK-7873) Introduce HybridStreamHandle to optimize the recovery mechanism and try to read the checkpoint data locally

2017-10-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-7873: -- Summary: Introduce HybridStreamHandle to optimize the recovery mechanism and try to read the checkpoint

[jira] [Resolved] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

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

[jira] [Commented] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

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

[jira] [Updated] (FLINK-7873) Introduce HybridStreamStateHandle for quick recovery from checkpoint.

2017-10-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-7873: -- Description: Current recover strategy will always read checkpoint data from remote FileStream (HDFS). T

[jira] [Assigned] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

2017-10-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7844: Assignee: Till Rohrmann (was: Zhenzhong Xu) > Fine Grained Recovery triggers checkpoint ti

[GitHub] flink pull request #4844: [FLINK-7844] [ckPt] Fail unacknowledged pending ch...

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

[jira] [Updated] (FLINK-7873) Introduce HybridStreamStateHandle for quick recovery from checkpoint.

2017-10-27 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-7873: -- Description: Current recover strategy will always read checkpoint data from remote FileStream (HDFS). T

[jira] [Commented] (FLINK-7153) Eager Scheduling can't allocate source for ExecutionGraph correctly

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

[GitHub] flink pull request #4916: [FLINK-7153] Re-introduce preferred locations for ...

2017-10-27 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4916 [FLINK-7153] Re-introduce preferred locations for scheduling ## What is the purpose of the change This PR makes the `TaskManagerLocation` accessible for asynchronous scheduling.

[jira] [Closed] (FLINK-7924) Fix incorrect names of checkpoint options

2017-10-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7924. --- > Fix incorrect names of checkpoint options > - > >

[jira] [Resolved] (FLINK-7924) Fix incorrect names of checkpoint options

2017-10-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7924. - Resolution: Fixed Fixed in fe3b276818eec1d4a70632a45343d70dc2be53f3 > Fix incorrect names of chec

[jira] [Commented] (FLINK-7765) Enable dependency convergence

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222619#comment-16222619 ] ASF GitHub Bot commented on FLINK-7765: --- Github user StephanEwen commented on the is

[GitHub] flink issue #4777: [FLINK-7765] Enable dependency convergence

2017-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4777 Looks good - still the open question whether we add dependency convergence by default, and deactivate it in not yet done modules. That gives the completed modules a "done" feeling and king of dou

[GitHub] flink issue #4914: [hotfix] [docs] Fix typos in types serialization document...

2017-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4914 Good fix, merging... ---

[GitHub] flink issue #4913: [hotfix] [javadoc] Fix typo in Javadoc of ManagedSnapshot...

2017-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4913 Thanks, good catch! Merging... ---

[GitHub] flink issue #4912: [hotfix] [docs] Fix broken downloads page url

2017-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4912 Thanks, merging... ---

[jira] [Commented] (FLINK-7838) Kafka011ProducerExactlyOnceITCase do not finish

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222551#comment-16222551 ] ASF GitHub Bot commented on FLINK-7838: --- Github user GJL commented on the issue:

[GitHub] flink issue #4915: [FLINK-7838] Bunch of hotfixes and fix missing synchroniz...

2017-10-27 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/4915 👍 ---

[jira] [Commented] (FLINK-7838) Kafka011ProducerExactlyOnceITCase do not finish

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222550#comment-16222550 ] ASF GitHub Bot commented on FLINK-7838: --- Github user GJL commented on a diff in the

[GitHub] flink pull request #4915: [FLINK-7838] Bunch of hotfixes and fix missing syn...

2017-10-27 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4915#discussion_r147442314 --- Diff: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java --- @@ -563,7 +553,7

[jira] [Commented] (FLINK-7838) Kafka011ProducerExactlyOnceITCase do not finish

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222522#comment-16222522 ] ASF GitHub Bot commented on FLINK-7838: --- Github user GJL commented on a diff in the

[GitHub] flink pull request #4915: [FLINK-7838] Bunch of hotfixes and fix missing syn...

2017-10-27 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4915#discussion_r147436687 --- Diff: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java --- @@ -483,11 +478,6

[GitHub] flink issue #4894: [FLINK-7548] [table] Improve rowtime support of TableSour...

2017-10-27 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4894 Added documentation for the new TableSource interfaces. ---

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222519#comment-16222519 ] ASF GitHub Bot commented on FLINK-7548: --- Github user fhueske commented on the issue:

[jira] [Created] (FLINK-7937) Add pagination to Flink History view

2017-10-27 Thread Andrew Roberts (JIRA)
Andrew Roberts created FLINK-7937: - Summary: Add pagination to Flink History view Key: FLINK-7937 URL: https://issues.apache.org/jira/browse/FLINK-7937 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7838) Kafka011ProducerExactlyOnceITCase do not finish

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222494#comment-16222494 ] ASF GitHub Bot commented on FLINK-7838: --- Github user pnowojski commented on the issu

[GitHub] flink issue #4915: [FLINK-7838] Bunch of hotfixes and fix missing synchroniz...

2017-10-27 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4915 @GJL @aljoscha could you take a look? ---

[jira] [Commented] (FLINK-7838) Kafka011ProducerExactlyOnceITCase do not finish

2017-10-27 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222450#comment-16222450 ] Piotr Nowojski commented on FLINK-7838: --- The main problem in this issue is this bug

[jira] [Commented] (FLINK-7838) Kafka011ProducerExactlyOnceITCase do not finish

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

[GitHub] flink pull request #4915: [FLINK-7838] Bunch of hotfixes and fix missing syn...

2017-10-27 Thread pnowojski
GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4915 [FLINK-7838] Bunch of hotfixes and fix missing synchronization in FlinkKafkaProducer011 ## What is the purpose of the change Most important is the commit adding missing synchronization, t

[jira] [Commented] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222429#comment-16222429 ] ASF GitHub Bot commented on FLINK-7737: --- Github user pnowojski commented on the issu

[GitHub] flink issue #4876: [FLINK-7737][filesystem] Add syncOnFlush flag to StreamWr...

2017-10-27 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4876 Yes I know what you mean. However including `outStream` to `hashCode` and `equals` wouldn't add any quirks. ---

[jira] [Commented] (FLINK-7876) Register TaskManagerMetricGroup under ResourceID instead of InstanceID

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

[GitHub] flink issue #4872: [FLINK-7876] Register TaskManagerMetricGroup under Resour...

2017-10-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4872 This PR does not strictly depend on the `MetricFetcher` changes. The reason why they are is simply that I directly wanted to adapt the `MetricFetcher` which I touched with #4852. It just turned

[jira] [Assigned] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7051: Assignee: Fabian Hueske (was: Haohui Mai) > Bump up Calcite version to 1.14 >

[jira] [Assigned] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7051: Assignee: Haohui Mai (was: Fabian Hueske) > Bump up Calcite version to 1.14 >

[jira] [Commented] (FLINK-7876) Register TaskManagerMetricGroup under ResourceID instead of InstanceID

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

[GitHub] flink pull request #4872: [FLINK-7876] Register TaskManagerMetricGroup under...

2017-10-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4872#discussion_r147416486 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryImpl.java --- @@ -239,7 +239,15 @@ public void shutdown() {

[jira] [Commented] (FLINK-7876) Register TaskManagerMetricGroup under ResourceID instead of InstanceID

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

[GitHub] flink pull request #4872: [FLINK-7876] Register TaskManagerMetricGroup under...

2017-10-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4872#discussion_r147415854 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryImpl.java --- @@ -239,7 +239,15 @@ public void shutdown() {

[jira] [Commented] (FLINK-7876) Register TaskManagerMetricGroup under ResourceID instead of InstanceID

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

[GitHub] flink pull request #4872: [FLINK-7876] Register TaskManagerMetricGroup under...

2017-10-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4872#discussion_r147415810 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosSessionClusterEntrypoint.java --- @@ -113,7 +113,7 @@ protected void startCl

[jira] [Commented] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

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

[jira] [Commented] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

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

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

2017-10-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4844 Thanks for the review @StephanEwen. I will address your comments and then merge this PR. ---

[GitHub] flink pull request #4844: [FLINK-7844] [ckPt] Fail unacknowledged pending ch...

2017-10-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4844#discussion_r147415027 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -1270,6 +1272,42 @@ public void run() {

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

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

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

2017-10-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4884 Hi @zjureel, I'll merge this PR once we forked off the 1.4 release branch. ---

[jira] [Commented] (FLINK-7800) Enable window joins without equi-join predicates

2017-10-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222325#comment-16222325 ] Xingcan Cui commented on FLINK-7800: Hi [~fhueske], the problem is not as easy as I ex

[GitHub] flink pull request #4914: [hotfix] [docs] Fix typos in types serialization d...

2017-10-27 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/4914 [hotfix] [docs] Fix typos in types serialization documentation This fixes typos in the types serialization documentation. You can merge this pull request into a Git repository by running: $ git pul

[GitHub] flink pull request #4913: [hotfix] [javadoc] Fix typo in Javadoc of ManagedS...

2017-10-27 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/4913 [hotfix] [javadoc] Fix typo in Javadoc of ManagedSnapshotContext#getCheckpointId() This fixes a typo in the Javadoc of ManagedSnapshotContext#getCheckpointId(). You can merge this pull request into a

[GitHub] flink pull request #4912: [hotfix] [docs] Fix broken downloads page url

2017-10-27 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/4912 [hotfix] [docs] Fix broken downloads page url This fixes a broken *Downloads Page* url on the AWS page of the documentation: https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/aws.html

[jira] [Closed] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-10-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6173. Resolution: Fixed Fix Version/s: 1.3.3 Fixed for 1.3.3 with c3289c9d982292975caded4c45926e965

[jira] [Commented] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1609#comment-1609 ] ASF GitHub Bot commented on FLINK-7737: --- Github user StephanEwen commented on the is

[GitHub] flink issue #4876: [FLINK-7737][filesystem] Add syncOnFlush flag to StreamWr...

2017-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4876 But do you understand what I mean? Semantics of code in the main scope should not be quirked to make assertions in tests shorter to write. Equals/hashCode is usually not implemented on I/

[jira] [Assigned] (FLINK-7871) SlotPool should release its unused slot to RM

2017-10-27 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuai.xu reassigned FLINK-7871: --- Assignee: shuai.xu > SlotPool should release its unused slot to RM >

[jira] [Commented] (FLINK-7933) Test instability PrometheusReporterTest

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

[jira] [Commented] (FLINK-7933) Test instability PrometheusReporterTest

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

[GitHub] flink pull request #4908: [FLINK-7933][metrics] Improve PrometheusReporter t...

2017-10-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4908#discussion_r147379229 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTaskScopeTest.java --- @@ -72,10 +72,30

[GitHub] flink pull request #4908: [FLINK-7933][metrics] Improve PrometheusReporter t...

2017-10-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4908#discussion_r147379207 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTaskScopeTest.java --- @@ -72,10 +72,30

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222143#comment-16222143 ] ASF GitHub Bot commented on FLINK-7878: --- Github user shuai-xu commented on the issue

[GitHub] flink issue #4911: [FLINK-7878] [api] make resource type extendible in Resou...

2017-10-27 Thread shuai-xu
Github user shuai-xu commented on the issue: https://github.com/apache/flink/pull/4911 I run the failed test on my machine and it pass, and it seems my changes will not influence it. ---

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222013#comment-16222013 ] ASF GitHub Bot commented on FLINK-7548: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4894: [FLINK-7548] [table] Improve rowtime support of TableSour...

2017-10-27 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4894 Thanks for the feedback @twalthr. I pushed an update. ---

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221986#comment-16221986 ] ASF GitHub Bot commented on FLINK-7548: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r147358782 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java --- @@ -84,6 +86,13 @@

[GitHub] flink pull request #4908: [FLINK-7933][metrics] Improve PrometheusReporter t...

2017-10-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4908#discussion_r147357330 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTest.java --- @@ -70,9 +69,25 @@

[jira] [Commented] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221979#comment-16221979 ] ASF GitHub Bot commented on FLINK-7933: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #4908: [FLINK-7933][metrics] Improve PrometheusReporter t...

2017-10-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4908#discussion_r147357533 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTaskScopeTest.java --- @@ -72,10 +72,

[jira] [Commented] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221978#comment-16221978 ] ASF GitHub Bot commented on FLINK-7933: --- Github user pnowojski commented on a diff i

[jira] [Commented] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221977#comment-16221977 ] ASF GitHub Bot commented on FLINK-7933: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #4908: [FLINK-7933][metrics] Improve PrometheusReporter t...

2017-10-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4908#discussion_r147357745 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTaskScopeTest.java --- @@ -72,10 +72,

[jira] [Commented] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221980#comment-16221980 ] ASF GitHub Bot commented on FLINK-7933: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #4908: [FLINK-7933][metrics] Improve PrometheusReporter t...

2017-10-27 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4908#discussion_r147357050 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTaskScopeTest.java --- @@ -72,10 +72,

[jira] [Commented] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221963#comment-16221963 ] ASF GitHub Bot commented on FLINK-7933: --- Github user StephanEwen commented on the is

[GitHub] flink issue #4908: [FLINK-7933][metrics] Improve PrometheusReporter tests

2017-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4908 Thanks, looks good, +1 to merge ---

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221940#comment-16221940 ] ASF GitHub Bot commented on FLINK-7878: --- GitHub user shuai-xu opened a pull request:

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-10-27 Thread shuai-xu
GitHub user shuai-xu opened a pull request: https://github.com/apache/flink/pull/4911 [FLINK-7878] [api] make resource type extendible in ResourceSpec Summary: Now, flink only support user define CPU and MEM, but some user need to specify the GPU, FPGA and so on resources.

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221869#comment-16221869 ] ASF GitHub Bot commented on FLINK-7548: --- Github user fhueske commented on a diff in

  1   2   >