[jira] [Created] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator

2018-05-29 Thread aitozi (JIRA)
aitozi created FLINK-9476: - Summary: Lost sideOutPut Late Elements in CEP Operator Key: FLINK-9476 URL: https://issues.apache.org/jira/browse/FLINK-9476 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9443) Remove unused parameter in StreamGraphHasherV2

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494721#comment-16494721 ] ASF GitHub Bot commented on FLINK-9443: --- Github user Aitozi commented on the issue:

[GitHub] flink issue #6080: [FLINK-9443]Remove unused parameter in generateNodeLocalH...

2018-05-29 Thread Aitozi
Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/6080 @aljoscha please help review this ,thanks ---

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494712#comment-16494712 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on a diff in the pull

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

2018-05-29 Thread lamber-ken
Github user lamber-ken commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r191647381 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79

[jira] [Created] (FLINK-9475) introduce an approximate version of "select distinct"

2018-05-29 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9475: - Summary: introduce an approximate version of "select distinct" Key: FLINK-9475 URL: https://issues.apache.org/jira/browse/FLINK-9475 Project: Flink Issue Type:

[jira] [Created] (FLINK-9474) Introduce an approximate version of "count distinct"

2018-05-29 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9474: - Summary: Introduce an approximate version of "count distinct" Key: FLINK-9474 URL: https://issues.apache.org/jira/browse/FLINK-9474 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-9473) Compilation fails after upgrade to Calcite 1.17

2018-05-29 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-9473: --- Description: {noformat}

[jira] [Created] (FLINK-9473) Compilation fails after upgrade to Calcite 1.17

2018-05-29 Thread Sergey Nuyanzin (JIRA)
Sergey Nuyanzin created FLINK-9473: -- Summary: Compilation fails after upgrade to Calcite 1.17 Key: FLINK-9473 URL: https://issues.apache.org/jira/browse/FLINK-9473 Project: Flink Issue

[jira] [Commented] (FLINK-9451) End-to-end test: Scala Quickstarts

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494682#comment-16494682 ] ASF GitHub Bot commented on FLINK-9451: --- Github user medcv commented on the issue:

[GitHub] flink issue #6089: [FLINK-9451]End-to-end test: Scala Quickstarts

2018-05-29 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6089 @zentol updated the PR as suggested! Please review ---

[jira] [Updated] (FLINK-9364) Add doc of the memory usage in flink

2018-05-29 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9364: -- Summary: Add doc of the memory usage in flink (was: Add doc for the memory usage in flink) > Add doc

[jira] [Commented] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494674#comment-16494674 ] ASF GitHub Bot commented on FLINK-9325: --- Github user sihuazhou commented on the issue:

[jira] [Commented] (FLINK-9468) get outputLimit of LimitedConnectionsFileSystem incorrectly

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494676#comment-16494676 ] ASF GitHub Bot commented on FLINK-9468: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5982: [FLINK-9325][checkpoint]generate the meta file for checkp...

2018-05-29 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5982 @StephanEwen I've addressed your comments, could you please have a look again? ---

[GitHub] flink issue #6094: [FLINK-9468][filesystem] fix calculate outputLimit incorr...

2018-05-29 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/6094 CC @StephanEwen ---

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494606#comment-16494606 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on a diff in the pull

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

2018-05-29 Thread lamber-ken
Github user lamber-ken commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r191628800 --- Diff: docs/monitoring/metrics.md --- @@ -699,6 +699,39 @@ Flink metric types are mapped to Prometheus metric types as follows: All Flink

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494605#comment-16494605 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on a diff in the pull

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

2018-05-29 Thread lamber-ken
Github user lamber-ken commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r191628488 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79

[jira] [Closed] (FLINK-9460) Redundant output in table & upsert semantics

2018-05-29 Thread zhengcanbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengcanbin closed FLINK-9460. -- Resolution: Not A Problem > Redundant output in table & upsert semantics >

[jira] [Commented] (FLINK-9472) Maven archetype code has typo in documentation

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494511#comment-16494511 ] ASF GitHub Bot commented on FLINK-9472: --- GitHub user alexeyts reopened a pull request:

[GitHub] flink pull request #6098: [FLINK-9472] fix archetype documentation typo

2018-05-29 Thread alexeyts
GitHub user alexeyts reopened a pull request: https://github.com/apache/flink/pull/6098 [FLINK-9472] fix archetype documentation typo ## What is the purpose of the change Simple typo fix ## Does this pull request potentially affect one of the following parts:

[jira] [Commented] (FLINK-9472) Maven archetype code has typo in documentation

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

[GitHub] flink pull request #6098: [FLINK-9472] fix archetype documentation typo

2018-05-29 Thread alexeyts
Github user alexeyts closed the pull request at: https://github.com/apache/flink/pull/6098 ---

[jira] [Commented] (FLINK-9472) Maven archetype code has typo in documentation

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494350#comment-16494350 ] ASF GitHub Bot commented on FLINK-9472: --- GitHub user alexeyts reopened a pull request:

[jira] [Commented] (FLINK-9472) Maven archetype code has typo in documentation

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

[GitHub] flink pull request #6098: [FLINK-9472] fix archetype documentation typo

2018-05-29 Thread alexeyts
GitHub user alexeyts reopened a pull request: https://github.com/apache/flink/pull/6098 [FLINK-9472] fix archetype documentation typo ## What is the purpose of the change Simple typo fix ## Does this pull request potentially affect one of the following parts:

[GitHub] flink pull request #6098: [FLINK-9472] fix archetype documentation typo

2018-05-29 Thread alexeyts
Github user alexeyts closed the pull request at: https://github.com/apache/flink/pull/6098 ---

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

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

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

2018-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r191578999 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79 @@

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

2018-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r191576816 --- Diff: docs/monitoring/metrics.md --- @@ -699,6 +699,39 @@ Flink metric types are mapped to Prometheus metric types as follows: All Flink

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

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

[jira] [Updated] (FLINK-9472) Maven archetype code has typo in documentation

2018-05-29 Thread Alexey Tsitkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Tsitkin updated FLINK-9472: -- Labels: documentation easyfix pull-request-available (was: documentation easyfix) > Maven

[jira] [Commented] (FLINK-9472) Maven archetype code has typo in documentation

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494231#comment-16494231 ] ASF GitHub Bot commented on FLINK-9472: --- GitHub user alexeyts opened a pull request:

[GitHub] flink pull request #6098: [FLINK-9472] fix archetype documentation typo

2018-05-29 Thread alexeyts
GitHub user alexeyts opened a pull request: https://github.com/apache/flink/pull/6098 [FLINK-9472] fix archetype documentation typo ## What is the purpose of the change Simple typo fix ## Does this pull request potentially affect one of the following parts:

[jira] [Updated] (FLINK-9472) Maven archetype code has typo in documentation

2018-05-29 Thread Alexey Tsitkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Tsitkin updated FLINK-9472: -- Labels: documentation easyfix (was: ) > Maven archetype code has typo in documentation >

[jira] [Updated] (FLINK-9472) Maven archetype code has typo in documentation

2018-05-29 Thread Alexey Tsitkin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Tsitkin updated FLINK-9472: -- Component/s: Documentation > Maven archetype code has typo in documentation >

[jira] [Created] (FLINK-9472) Maven archetype code has typo in documentation

2018-05-29 Thread Alexey Tsitkin (JIRA)
Alexey Tsitkin created FLINK-9472: - Summary: Maven archetype code has typo in documentation Key: FLINK-9472 URL: https://issues.apache.org/jira/browse/FLINK-9472 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

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

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

2018-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r191561341 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79 @@

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

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

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

2018-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r191560994 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79 @@

[jira] [Commented] (FLINK-5550) NotFoundException: Could not find job with id

2018-05-29 Thread Alexandr Arkhipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494118#comment-16494118 ] Alexandr Arkhipov commented on FLINK-5550: -- Would you mind if I take this issue and work on it?

[jira] [Updated] (FLINK-9471) Job ending exceptions being logged at Info level

2018-05-29 Thread SUBRAMANYA SURESH (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SUBRAMANYA SURESH updated FLINK-9471: - Description: We are using Flink SQL, I see job ending logs that are logged at info

[jira] [Commented] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI

2018-05-29 Thread Alexandr Arkhipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494097#comment-16494097 ] Alexandr Arkhipov commented on FLINK-6977: -- Is there someone working on this? If not, would you

[jira] [Created] (FLINK-9471) Job ending exceptions being logged at Info level

2018-05-29 Thread SUBRAMANYA SURESH (JIRA)
SUBRAMANYA SURESH created FLINK-9471: Summary: Job ending exceptions being logged at Info level Key: FLINK-9471 URL: https://issues.apache.org/jira/browse/FLINK-9471 Project: Flink Issue

[jira] [Commented] (FLINK-9470) Allow querying the key in KeyedProcessFunction

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494025#comment-16494025 ] ASF GitHub Bot commented on FLINK-9470: --- Github user alpinegizmo commented on the issue:

[GitHub] flink issue #6097: [FLINK-9470] Allow querying the key in KeyedProcessFuncti...

2018-05-29 Thread alpinegizmo
Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/6097 +1 Nice! ---

[jira] [Commented] (FLINK-9470) Allow querying the key in KeyedProcessFunction

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

[GitHub] flink issue #6097: [FLINK-9470] Allow querying the key in KeyedProcessFuncti...

2018-05-29 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/6097 +1. I might forget to add the interfaces back then, would be good to have them ---

[jira] [Commented] (FLINK-9451) End-to-end test: Scala Quickstarts

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493895#comment-16493895 ] ASF GitHub Bot commented on FLINK-9451: --- Github user medcv commented on the issue:

[GitHub] flink issue #6089: [FLINK-9451]End-to-end test: Scala Quickstarts

2018-05-29 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6089 @zentol sure! I will update the PR with your requested changes. ---

[jira] [Closed] (FLINK-9356) Improve error message for when queryable state not ready / reachable

2018-05-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9356. - Resolution: Fixed Merged on master with 0fd497a7bf00694302a71ccf4b3ddd214942a228 and on 1.5

[jira] [Commented] (FLINK-9356) Improve error message for when queryable state not ready / reachable

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

[GitHub] flink pull request #6028: [FLINK-9356] Improve error message for when querya...

2018-05-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6028 ---

[jira] [Commented] (FLINK-9451) End-to-end test: Scala Quickstarts

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

[GitHub] flink issue #6089: [FLINK-9451]End-to-end test: Scala Quickstarts

2018-05-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6089 Let's not mix concerns here. Re-using examples can lead to situations where the quickstart tests fail because an example was modified, which by all means shouldn't happen. The examples should

[jira] [Reopened] (FLINK-9466) LocalRecoveryRocksDBFullITCase failed on Travis

2018-05-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-9466: - reopen to change fixVersion > LocalRecoveryRocksDBFullITCase failed on Travis >

[jira] [Closed] (FLINK-9466) LocalRecoveryRocksDBFullITCase failed on Travis

2018-05-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9466. --- Resolution: Cannot Reproduce > LocalRecoveryRocksDBFullITCase failed on Travis >

[jira] [Updated] (FLINK-9466) LocalRecoveryRocksDBFullITCase failed on Travis

2018-05-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9466: Fix Version/s: (was: 1.6.0) > LocalRecoveryRocksDBFullITCase failed on Travis >

[jira] [Commented] (FLINK-7836) specifying node label for flink job to run on yarn

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

[GitHub] flink issue #5593: [FLINK-7836][Client] specifying node label for flink job ...

2018-05-29 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5593 hi @tillrohrmann can this PR been merged into master branch, so that we can close it? ---

[jira] [Commented] (FLINK-7836) specifying node label for flink job to run on yarn

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

[GitHub] flink issue #5593: [FLINK-7836][Client] specifying node label for flink job ...

2018-05-29 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5593 hi @tillrohrmann can this PR been merged into master branch, so that we can close it? ---

[jira] [Commented] (FLINK-9470) Allow querying the key in KeyedProcessFunction

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

[jira] [Commented] (FLINK-9470) Allow querying the key in KeyedProcessFunction

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

[GitHub] flink pull request #6097: [FLINK-9470] Allow querying the key in KeyedProces...

2018-05-29 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6097#discussion_r191460728 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java --- @@ -50,6 +52,30 @@ @Rule

[GitHub] flink pull request #6097: [FLINK-9470] Allow querying the key in KeyedProces...

2018-05-29 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6097#discussion_r191460316 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java --- @@ -50,6 +52,30 @@ @Rule

[jira] [Commented] (FLINK-8353) Add support for timezones

2018-05-29 Thread Weike Dong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493639#comment-16493639 ] Weike Dong commented on FLINK-8353: --- I strongly support these features, preferably there could be a way

[jira] [Commented] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables

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

[GitHub] flink pull request #5959: [FLINK-9258][metrics] Thread-safe initialization o...

2018-05-29 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/5959 ---

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

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

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

2018-05-29 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r191454466 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,511 @@ +/* + *

[jira] [Commented] (FLINK-9470) Allow querying the key in KeyedProcessFunction

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493633#comment-16493633 ] ASF GitHub Bot commented on FLINK-9470: --- GitHub user aljoscha opened a pull request:

[jira] [Closed] (FLINK-9466) LocalRecoveryRocksDBFullITCase failed on Travis

2018-05-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9466. Resolution: Fixed Accidentally overwrote the Travis log file. Closing until seeing this issue

[jira] [Commented] (FLINK-8790) Improve performance for recovery from incremental checkpoint

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493631#comment-16493631 ] ASF GitHub Bot commented on FLINK-8790: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #6097: [FLINK-9470] Allow querying the key in KeyedProces...

2018-05-29 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/6097 [FLINK-9470] Allow querying the key in KeyedProcessFunction R: @kl0u @zentol You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink

[GitHub] flink pull request #5582: [FLINK-8790][State] Improve performance for recove...

2018-05-29 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5582#discussion_r191453657 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeySerializationUtils.java --- @@

[jira] [Created] (FLINK-9470) Allow querying the key in KeyedProcessFunction

2018-05-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-9470: --- Summary: Allow querying the key in KeyedProcessFunction Key: FLINK-9470 URL: https://issues.apache.org/jira/browse/FLINK-9470 Project: Flink Issue

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493615#comment-16493615 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493621#comment-16493621 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493609#comment-16493609 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493605#comment-16493605 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493603#comment-16493603 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493599#comment-16493599 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493617#comment-16493617 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493616#comment-16493616 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493602#comment-16493602 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493607#comment-16493607 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493604#comment-16493604 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493620#comment-16493620 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493618#comment-16493618 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493614#comment-16493614 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493611#comment-16493611 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493613#comment-16493613 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493612#comment-16493612 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493619#comment-16493619 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493610#comment-16493610 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493606#comment-16493606 ] ASF GitHub Bot commented on FLINK-9423: --- Github user tillrohrmann commented on a diff in the pull

  1   2   3   >