[jira] [Commented] (FLINK-8921) Split code generated call expression

2018-06-19 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517268#comment-16517268 ] Timo Walther commented on FLINK-8921: - [~RuidongLi] what is the status of this issue. Will you find

[jira] [Commented] (FLINK-4542) Add MULTISET operations

2018-06-19 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517283#comment-16517283 ] Timo Walther commented on FLINK-4542: - Hi [~Sergey Nuyanzin], I thought Calcite has support (at

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

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

[GitHub] flink issue #6092: [FLINK-9352] In Standalone checkpoint recover mode many j...

2018-06-19 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6092 cc @zentol @kl0u ---

[GitHub] flink issue #5777: [FLINK-7897] Consider using nio.Files for file deletion i...

2018-06-19 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5777 @StefanRRichter , does this PR look good to you? ---

[jira] [Commented] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196452418 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java --- @@ -116,5 +136,16 @@ private void reset() {

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196560163 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java --- @@ -0,0 +1,471 @@ +/* + * Licensed to the

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196555487 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java --- @@ -0,0 +1,136 @@ +/* + * Licensed to the

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196455211 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/AbstractHandler.java --- @@ -103,77 +104,74 @@ protected void

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r19670 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java --- @@ -0,0 +1,136 @@ +/* + * Licensed to the

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196558949 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageHeaders.java --- @@ -63,4 +63,13 @@ * @return description

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196559093 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java --- @@ -0,0 +1,471 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196556101 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/FileUploadsTest.java --- @@ -0,0 +1,124 @@ +/* + * Licensed to the

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196453980 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java --- @@ -129,4 +137,9 @@ public R getRequestBody() {

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196452755 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java --- @@ -95,14 +107,22 @@ protected void channelRead0(final

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196452583 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java --- @@ -116,5 +136,16 @@ private void reset() {

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196554025 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/AbstractHandler.java --- @@ -103,77 +104,74 @@ protected void

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196557260 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java --- @@ -39,15 +41,21 @@ public class

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196453584 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java --- @@ -0,0 +1,136 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196452024 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java --- @@ -95,14 +107,22 @@ protected void channelRead0(final

[jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest

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

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196453235 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java --- @@ -95,14 +107,22 @@ protected void channelRead0(final

[GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ...

2018-06-19 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6178#discussion_r196559335 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java --- @@ -0,0 +1,471 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-9612) Add option for minimal artifacts being pulled in Mesos

2018-06-19 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517525#comment-16517525 ] Eron Wright commented on FLINK-9612: - Yes it makes sense that the overlays would be selective and

[jira] [Commented] (FLINK-9611) Allow for user-defined artifacts to be specified as part of a mesos overlay

2018-06-19 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517528#comment-16517528 ] Eron Wright commented on FLINK-9611: - I really like this idea, except for the proposed name because

[jira] [Commented] (FLINK-9618) NullPointerException in FlinkKinesisProducer when aws.region is not set and aws.endpoint is set

2018-06-19 Thread Aaron Langford (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517645#comment-16517645 ] Aaron Langford commented on FLINK-9618: --- I would be happy to take the work to fix this. >

[jira] [Created] (FLINK-9618) NullPointerException in FlinkKinesisProducer when aws.region is not set and aws.endpoint is set

2018-06-19 Thread Aaron Langford (JIRA)
Aaron Langford created FLINK-9618: - Summary: NullPointerException in FlinkKinesisProducer when aws.region is not set and aws.endpoint is set Key: FLINK-9618 URL: https://issues.apache.org/jira/browse/FLINK-9618

[jira] [Resolved] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang resolved FLINK-9614. - Resolution: Not A Problem > Improve the error message for Compiler#compile >

[jira] [Closed] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang closed FLINK-9614. --- > Improve the error message for Compiler#compile > -- > >

[jira] [Updated] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-9614: Description: When the below sql has too long. Like case when case when . when host in

[GitHub] flink pull request #6181: [FLINK-9610] [flink-connector-kafka-base] Add Kafk...

2018-06-19 Thread nielsbasjes
Github user nielsbasjes commented on a diff in the pull request: https://github.com/apache/flink/pull/6181#discussion_r196435400 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkKeyHashPartitioner.java

[jira] [Commented] (FLINK-9610) Add Kafka partitioner that uses the key to partition by

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

[GitHub] flink pull request #6182: [FLINK-8795] Fixed local scala shell for Flip6

2018-06-19 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/6182 [FLINK-8795] Fixed local scala shell for Flip6 ## What is the purpose of the change Enable to run scala-shell in local mode with new runtime mode. ## Brief change log -

[jira] [Commented] (FLINK-8795) Scala shell broken for Flip6

2018-06-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517150#comment-16517150 ] ASF GitHub Bot commented on FLINK-8795: --- GitHub user dawidwys opened a pull request:

[jira] [Issue Comment Deleted] (FLINK-9615) Add possibility to use Connectors as Sinks in SQL Client

2018-06-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dominik Wosiński updated FLINK-9615: Comment: was deleted (was: I can take care of that :) It's not a big improvement to be

[GitHub] flink pull request #6183: [FLINK-9616][metrics] Fix datadog to include shade...

2018-06-19 Thread addisonj
GitHub user addisonj opened a pull request: https://github.com/apache/flink/pull/6183 [FLINK-9616][metrics] Fix datadog to include shaded deps ## What is the purpose of the change This fixes a broken build that wasn't properly including a shaded in the jar it builds.

[jira] [Updated] (FLINK-9615) Add possibility to use Connectors as Sinks in SQL Client

2018-06-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dominik Wosiński updated FLINK-9615: Summary: Add possibility to use Connectors as Sinks in SQL Client (was: Add) > Add

[jira] [Created] (FLINK-9615) Add

2018-06-19 Thread JIRA
Dominik Wosiński created FLINK-9615: --- Summary: Add Key: FLINK-9615 URL: https://issues.apache.org/jira/browse/FLINK-9615 Project: Flink Issue Type: Improvement Reporter:

[jira] [Created] (FLINK-9616) DatadogHttpReporter fails to be created due to missing shaded dependency

2018-06-19 Thread Addison Higham (JIRA)
Addison Higham created FLINK-9616: - Summary: DatadogHttpReporter fails to be created due to missing shaded dependency Key: FLINK-9616 URL: https://issues.apache.org/jira/browse/FLINK-9616 Project:

[jira] [Commented] (FLINK-9616) DatadogHttpReporter fails to be created due to missing shaded dependency

2018-06-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517205#comment-16517205 ] ASF GitHub Bot commented on FLINK-9616: --- GitHub user addisonj opened a pull request:

[jira] [Created] (FLINK-9617) Provide alias for whole records in Table API

2018-06-19 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-9617: - Summary: Provide alias for whole records in Table API Key: FLINK-9617 URL: https://issues.apache.org/jira/browse/FLINK-9617 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9615) Add possibility to use Connectors as Sinks in SQL Client

2018-06-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517095#comment-16517095 ] Dominik Wosiński commented on FLINK-9615: - I can take care of that :) It's not a big improvement

[jira] [Commented] (FLINK-9615) Add possibility to use Connectors as Sinks in SQL Client

2018-06-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517128#comment-16517128 ] Fabian Hueske commented on FLINK-9615: -- Thanks for opening this issue! This is (partially) a

[jira] [Created] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
mingleizhang created FLINK-9614: --- Summary: Improve the error message for Compiler#compile Key: FLINK-9614 URL: https://issues.apache.org/jira/browse/FLINK-9614 Project: Flink Issue Type:

[jira] [Updated] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-9614: Component/s: Table API & SQL > Improve the error message for Compiler#compile >

[jira] [Commented] (FLINK-9563) Migrate integration tests for CEP

2018-06-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517717#comment-16517717 ] ASF GitHub Bot commented on FLINK-9563: --- Github user deepaks4077 commented on the issue:

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

2018-06-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517760#comment-16517760 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on the issue:

[GitHub] flink issue #6170: [FLINK-9563]: Using a custom sink function for tests in C...

2018-06-19 Thread deepaks4077
Github user deepaks4077 commented on the issue: https://github.com/apache/flink/pull/6170 Hi @zentol, just a friendly reminder about this pull request :) ---

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

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

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

2018-06-19 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5982 Could anybody have a look at this? ---

[jira] [Commented] (FLINK-9380) Failing end-to-end tests should not clean up logs

2018-06-19 Thread Deepak Sharma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517718#comment-16517718 ] Deepak Sharma commented on FLINK-9380: -- Hi [~till.rohrmann], just a friendly reminder of this Jira

[GitHub] flink pull request #6184: add prometheus pushgateway reporter

2018-06-19 Thread lamber-ken
GitHub user lamber-ken opened a pull request: https://github.com/apache/flink/pull/6184 add prometheus pushgateway reporter ## What is the purpose of the change This pull request makes flink system can send metrics to prometheus via pushgateway. it may be useful. ##

[jira] [Created] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

2018-06-19 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9619: - Summary: Always close the task manager connection when the container is completed in YarnResourceManager Key: FLINK-9619 URL: https://issues.apache.org/jira/browse/FLINK-9619

[GitHub] flink issue #6168: [FLINK-9588][CEP]Reused context with same computation sta...

2018-06-19 Thread Aitozi
Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/6168 Is it ok now ? @dawidwys ---

[jira] [Commented] (FLINK-9588) Reuse the same conditionContext with in a same computationState

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

[GitHub] flink issue #5857: [FLINK-9187][METRICS] add prometheus pushgateway reporter

2018-06-19 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/5857 sorry, I reforked `flink` project, do I need to start a new PR? ![image](https://user-images.githubusercontent.com/20113411/41635822-76271486-747d-11e8-9ad3-c6447c1b930c.png) ---

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

2018-06-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517789#comment-16517789 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on the issue:

[jira] [Commented] (FLINK-9614) Improve the error message for Compiler#compile

2018-06-19 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517679#comment-16517679 ] mingleizhang commented on FLINK-9614: - I close this since we catch a throwable. stackoverflowerror is

[GitHub] flink issue #6184: [FLINK-9187][METRICS] add prometheus pushgateway reporter

2018-06-19 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/6184 Please click here for details [old-flink-9187](https://github.com/apache/flink/pull/5857) ---

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

2018-06-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517788#comment-16517788 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken closed the pull request at:

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

2018-06-19 Thread lamber-ken
Github user lamber-ken closed the pull request at: https://github.com/apache/flink/pull/5857 ---

[jira] [Commented] (FLINK-9417) Send heartbeat requests from RPC endpoint's main thread

2018-06-19 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517790#comment-16517790 ] Sihua Zhou commented on FLINK-9417: --- Hi [~till.rohrmann] One thing come to my mind, If we send

[GitHub] flink pull request #6185: [FLINK-9619][YARN] Eagerly close the connection wi...

2018-06-19 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/6185 [FLINK-9619][YARN] Eagerly close the connection with task manager when the container is completed ## What is the purpose of the change *We should always eagerly close the connection with

[jira] [Commented] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

2018-06-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517794#comment-16517794 ] ASF GitHub Bot commented on FLINK-9619: --- GitHub user sihuazhou opened a pull request:

[GitHub] flink issue #6185: [FLINK-9619][YARN] Eagerly close the connection with task...

2018-06-19 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/6185 CC @tillrohrmann ---

[jira] [Commented] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

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

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

2018-06-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516760#comment-16516760 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on the issue:

[GitHub] flink issue #5857: [FLINK-9187][METRICS] add prometheus pushgateway reporter

2018-06-19 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/5857 @zentol, @tillrohrmann, cc I don't think there is a relationship between `FLINK-9543` and `FLINK-9187`. At present, the focus of our discussion is on the job name of pushgateway.

[GitHub] flink issue #5857: [FLINK-9187][METRICS] add prometheus pushgateway reporter

2018-06-19 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/5857 @zentol , thanks for review. first, there is a small point that the IDs may be duplicated when use JM/TM actual unique ID to compose the job name of pushgateway, like the picture below.

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

2018-06-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516863#comment-16516863 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on the issue:

[jira] [Commented] (FLINK-9612) Add option for minimal artifacts being pulled in Mesos

2018-06-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516771#comment-16516771 ] Till Rohrmann commented on FLINK-9612: -- I guess that this issue and FLINK-9611 can be both solved by

[jira] [Updated] (FLINK-9612) Add option for minimal artifacts being pulled in Mesos

2018-06-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9612: - Summary: Add option for minimal artifacts being pulled in Mesos (was: Add option for minimal

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

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

[GitHub] flink issue #5857: [FLINK-9187][METRICS] add prometheus pushgateway reporter

2018-06-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5857 Why do you prefer random ID's to differentiate between JM/TM than their actual unique ID? ---

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

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

[jira] [Commented] (FLINK-9569) Confusing construction of AvroSerializers for generic records

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

[GitHub] flink pull request #6151: [FLINK-9569] [avro] Fix confusing construction of ...

2018-06-19 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6151#discussion_r196366033 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java --- @@ -105,41 +108,54 @@ /** The

[GitHub] flink issue #5857: [FLINK-9187][METRICS] add prometheus pushgateway reporter

2018-06-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5857 I I see the value of a `cluster_id` but you're mixing concerns here. It is not the responsibility of a `reporter` to introduce a `cluster_id` tag. Reporters are to faithfully report the metrics and

[jira] [Commented] (FLINK-9610) Add Kafka partitioner that uses the key to partition by

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

[jira] [Commented] (FLINK-9367) Truncate() in BucketingSink is only allowed after hadoop2.7

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

[GitHub] flink pull request #6108: [FLINK-9367] [Streaming Connectors] Allow to do tr...

2018-06-19 Thread zhangxinyu1
Github user zhangxinyu1 closed the pull request at: https://github.com/apache/flink/pull/6108 ---

[jira] [Commented] (FLINK-9567) Flink does not release resource in Yarn Cluster mode

2018-06-19 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516972#comment-16516972 ] Shimin Yang commented on FLINK-9567: Thanks for assigning the issue to me, I will do my best to fix

[GitHub] flink pull request #6147: [FLINK-9280][rest] Rework JobSubmitHandler to acce...

2018-06-19 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/6147 ---

  1   2   >