[GitHub] flink issue #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-29 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5448 hi @dawidwys thanks for your review suggestion, I have refactored the PR code except the `MANAGED_MEMORY_SIZE `. The problem you concerned is exists, the key is suitable for this PR, and it seems we

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

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

[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

[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?

[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=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 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-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:

[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

[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

[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 >

[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=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:

[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 #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

[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] [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] [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] [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_r191578999 --- 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=16494297#comment-16494297 ] ASF GitHub Bot commented on FLINK-9187: --- Github user zentol commented on a diff in the pull

[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:

[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 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] [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:

[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 pull-request-available (was: documentation easyfix) > Maven

[jira] [Commented] (FLINK-7789) Add handler for Async IO operator timeouts

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

[jira] [Created] (FLINK-9463) Setting taskmanager.network.netty.transport to epoll

2018-05-29 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-9463: - Summary: Setting taskmanager.network.netty.transport to epoll Key: FLINK-9463 URL: https://issues.apache.org/jira/browse/FLINK-9463 Project: Flink Issue

[GitHub] flink issue #6043: [FLINK-7386] evolve RequestIndexer API to make it working...

2018-05-29 Thread cjolif
Github user cjolif commented on the issue: https://github.com/apache/flink/pull/6043 What I could do if that can help making progress, is to create a second PR based on this one and introducing the RestHighLevelClient implementation based on those APIs? This would allow to get an

[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=16493256#comment-16493256 ] 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_r191346124 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79 @@

[jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

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

[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_r191345794 --- 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_r191325180 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79 @@

[GitHub] flink pull request #6091: [FLINK-7789][DataStream API] Add handler for Async...

2018-05-29 Thread kisimple
GitHub user kisimple opened a pull request: https://github.com/apache/flink/pull/6091 [FLINK-7789][DataStream API] Add handler for Async IO operator timeouts ## What is the purpose of the change Currently Async IO operator does not provide a mechanism to handle timeouts.

[jira] [Updated] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

2018-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9326: Fix Version/s: 1.5.1 1.6.0 > TaskManagerOptions.NUM_TASK_SLOTS does not

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

2018-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493194#comment-16493194 ] Chesnay Schepler commented on FLINK-9461: - The cassandra connector has the same issue. >

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

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

[GitHub] flink pull request #6092: [FLINK-9352] In Standalone checkpoint recover mode...

2018-05-29 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/6092 [FLINK-9352] In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure ## What is the purpose of the change *This pull request fixed a problem : In

[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_r191335598 --- 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=16493210#comment-16493210 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on a diff in the pull

[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=16493259#comment-16493259 ] ASF GitHub Bot commented on FLINK-9187: --- Github user zentol commented on a diff in the pull

[jira] [Created] (FLINK-9462) Disentangle flink-json and flink-table

2018-05-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9462: Summary: Disentangle flink-json and flink-table Key: FLINK-9462 URL: https://issues.apache.org/jira/browse/FLINK-9462 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

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

[GitHub] flink pull request #6092: [FLINK-9352] In Standalone checkpoint recover mode...

2018-05-29 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6092#discussion_r191341746 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -1173,9 +1179,10 @@ public void

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[GitHub] flink issue #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-05-29 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/6071 @zentol I have also fixed added a test to cover https://github.com/apache/flink-shaded/issues/30 in the second commit ---

[jira] [Created] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

2018-05-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9461: Summary: Disentangle flink-connector-kafka from flink-table and flink-json Key: FLINK-9461 URL: https://issues.apache.org/jira/browse/FLINK-9461 Project: Flink

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

2018-05-29 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-8873: Fix Version/s: (was: 1.5.1) 1.6.0 > move unit tests of KeyedStream

[jira] [Commented] (FLINK-7789) Add handler for Async IO operator timeouts

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

[GitHub] flink pull request #5983: [FLINK-7789][DataStream API] Add handler for Async...

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

[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=16493175#comment-16493175 ] ASF GitHub Bot commented on FLINK-9187: --- Github user zentol commented on a diff in the pull

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

2018-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493186#comment-16493186 ] Chesnay Schepler commented on FLINK-9258: - 1.5: 3cdba864e7c979125bb0460025f1a5bbe749cbaf 1.4:

[jira] [Commented] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

2018-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493187#comment-16493187 ] Chesnay Schepler commented on FLINK-9326: - 1.5: cbf2c8f785b6a8b620d9aeeb702fdb81b7c8bbfa >

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

2018-05-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493214#comment-16493214 ] Fabian Hueske commented on FLINK-9461: -- I think this (and similar) issues should be discussed on the

[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=16493219#comment-16493219 ] 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_r191336445 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79

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

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

[GitHub] flink issue #5649: [FLINK-8873] [DataStream API] [Tests] move unit tests of ...

2018-05-29 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/5649 I am not sure about the value of those changes. The keying and the `KeyedProcessFunction`s are applied onto `DataStream` plus tests in `DataStreamTest` cover checks if the resulting stream is keyed

[jira] [Commented] (FLINK-9463) Setting taskmanager.network.netty.transport to epoll

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

[GitHub] flink pull request #6092: [FLINK-9352] In Standalone checkpoint recover mode...

2018-05-29 Thread yuqi1129
Github user yuqi1129 commented on a diff in the pull request: https://github.com/apache/flink/pull/6092#discussion_r191340849 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -1173,9 +1179,10 @@ public void

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

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

[GitHub] flink issue #6028: [FLINK-9356] Improve error message for when queryable sta...

2018-05-29 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6028 cc @kl0u @zentol ---

[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] [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:

[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] [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_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=16494606#comment-16494606 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on a diff in the pull

[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 ---

[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? ---

[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:

[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] [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] [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] [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] [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-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] [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] [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=16493281#comment-16493281 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on a diff in the pull

[jira] [Updated] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-05-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9280: - Fix Version/s: 1.5.1 1.6.0 > Extend JobSubmitHandler to accept jar files >

[jira] [Updated] (FLINK-9280) Extend JobSubmitHandler to accept jar files

2018-05-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9280: - Priority: Critical (was: Major) > Extend JobSubmitHandler to accept jar files >

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

2018-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493324#comment-16493324 ] Chesnay Schepler commented on FLINK-9461: - IMO the dependency on flink-table isn't the core

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

2018-05-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9460: - Priority: Minor (was: Major) > Redundant output in table & upsert semantics >

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

2018-05-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493345#comment-16493345 ] Fabian Hueske commented on FLINK-9460: -- First of all, the result is correct. The semantics of the

[jira] [Updated] (FLINK-9061) add entropy to s3 path for better scalability

2018-05-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9061: - Affects Version/s: 1.5.0 > add entropy to s3 path for better scalability >

[GitHub] flink pull request #5840: [FLINK-7850] [build system] Give each maven profil...

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

[jira] [Closed] (FLINK-7850) Given each maven profile an activation property

2018-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7850. --- Resolution: Fixed Fix Version/s: 1.6.0 master:

[GitHub] flink pull request #6041: [FLINK-9326] TaskManagerOptions.NUM_TASK_SLOTS doe...

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

  1   2   3   >