[jira] [Assigned] (FLINK-7941) Port SubtasksTimesHandler to new REST endpoint

2017-10-29 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7941: Assignee: Fang Yong > Port SubtasksTimesHandler to new REST endpoint >

[jira] [Created] (FLINK-7941) Port SubtasksTimesHandler to new REST endpoint

2017-10-29 Thread Fang Yong (JIRA)
Fang Yong created FLINK-7941: Summary: Port SubtasksTimesHandler to new REST endpoint Key: FLINK-7941 URL: https://issues.apache.org/jira/browse/FLINK-7941 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

2017-10-29 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi reassigned FLINK-6109: - Assignee: aitozi > Add "consumer lag" report metric to FlinkKafkaConsumer >

[jira] [Assigned] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

2017-10-29 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi reassigned FLINK-6109: - Assignee: aitozi > Add "consumer lag" report metric to FlinkKafkaConsumer >

[jira] [Assigned] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

2017-10-29 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi reassigned FLINK-6109: - Assignee: (was: aitozi) > Add "consumer lag" report metric to FlinkKafkaConsumer >

[jira] [Commented] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

2017-10-29 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224395#comment-16224395 ] aitozi commented on FLINK-6109: --- Is anyone working on this issue, Now in version 1.3.2 we can only see that

[jira] [Commented] (FLINK-7940) Add timeout for futures

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

[jira] [Commented] (FLINK-7940) Add timeout for futures

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

[jira] [Commented] (FLINK-7940) Add timeout for futures

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

[GitHub] flink pull request #4918: [FLINK-7940] Add FutureUtils.orTimeout

2017-10-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4918#discussion_r147594462 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -446,19 +449,67 @@ public void onComplete(Throwable

[GitHub] flink pull request #4918: [FLINK-7940] Add FutureUtils.orTimeout

2017-10-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4918#discussion_r147594496 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -446,19 +449,67 @@ public void onComplete(Throwable

[GitHub] flink pull request #4918: [FLINK-7940] Add FutureUtils.orTimeout

2017-10-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4918#discussion_r147594412 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -446,19 +449,67 @@ public void onComplete(Throwable

[jira] [Comment Edited] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish

2017-10-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16069086#comment-16069086 ] Ted Yu edited comment on FLINK-7049 at 10/29/17 7:14 PM: - Stack trace for

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

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

[jira] [Updated] (FLINK-7795) Utilize error-prone to discover common coding mistakes

2017-10-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7795: -- Description: http://errorprone.info/ is a tool which detects common coding mistakes. We should incorporate

[jira] [Commented] (FLINK-7940) Add timeout for futures

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

[GitHub] flink pull request #4918: [FLINK-7940] Add FutureUtils.orTimeout

2017-10-29 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4918 [FLINK-7940] Add FutureUtils.orTimeout ## What is the purpose of the change This commit adds a convenience function `FutureUtils#orTimeout` which allows to easily add a timeout to

[jira] [Created] (FLINK-7940) Add timeout for futures

2017-10-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7940: Summary: Add timeout for futures Key: FLINK-7940 URL: https://issues.apache.org/jira/browse/FLINK-7940 Project: Flink Issue Type: Improvement

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

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

[GitHub] flink pull request #4909: [FLINK-7880][QS] Fix QS test instabilities.

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

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

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

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

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

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

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

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

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

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

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

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

2017-10-29 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r147583120 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/FieldComputer.scala --- @@ -0,0 +1,63 @@ +/* + * Licensed to the

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

2017-10-29 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r147574828 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSourceUtil.scala --- @@ -0,0 +1,518 @@ +/* + * Licensed to

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

2017-10-29 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r147580191 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala --- @@ -56,33 +63,123 @@ class

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

2017-10-29 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r147582469 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala --- @@ -38,23 +38,26 @@ import

[GitHub] flink issue #4751: [FLINK-7739][kafka-tests] Throttle down data producing th...

2017-10-29 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4751 I assume that the `Thread.sleep(1)` should not do much harm if the Kafka Producer already blocks due to buffering and I/O. If it should not block, then the `Thread.sleep(1)` will give other

[jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability

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

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

2017-10-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16223885#comment-16223885 ] 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-29 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4894 I'm planning to merge this PR before the feature freeze on Tuesday. Cheers, Fabian ---