[jira] [Comment Edited] (FLINK-8161) Flakey YARNSessionCapacitySchedulerITCase on Travis

2018-05-18 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480216#comment-16480216 ] Sergey Nuyanzin edited comment on FLINK-8161 at 5/18/18 6:21 AM: - Looks

[GitHub] flink issue #6040: [FLINK-9349][Kafka Connector] KafkaConnector Exception wh...

2018-05-18 Thread snuyanzin
Github user snuyanzin commented on the issue: https://github.com/apache/flink/pull/6040 @tzulitai, @tedyu thnk you for your review, comments and contribution tips I did updates which includes moving test into AbstractFetcherTest and making it kafka connector version independent

[jira] [Commented] (FLINK-9349) KafkaConnector Exception while fetching from multiple kafka topics

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

[GitHub] flink issue #6040: [FLINK-9349][Kafka Connector] KafkaConnector Exception wh...

2018-05-18 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/6040 @snuyanzin the failing `YARNSessionCapacitySchedulerITCase` is known to be bit flaky, so you can safely ignore that for now. I'll take another look at your changes soon. Thanks! ---

[GitHub] flink pull request #5863: [FLINK-8985][e2etest] initial support for End-to-e...

2018-05-18 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5863#discussion_r189185689 --- Diff: flink-end-to-end-tests/test-scripts/test_cli_api.sh --- @@ -0,0 +1,155 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

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

[GitHub] flink pull request #5863: [FLINK-8985][e2etest] initial support for End-to-e...

2018-05-18 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5863#discussion_r189185232 --- Diff: flink-end-to-end-tests/test-scripts/test_cli_api.sh --- @@ -0,0 +1,155 @@ +#!/usr/bin/env bash

[GitHub] flink pull request #5863: [FLINK-8985][e2etest] initial support for End-to-e...

2018-05-18 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5863#discussion_r189185140 --- Diff: flink-end-to-end-tests/test-scripts/test_cli_api.sh --- @@ -0,0 +1,155 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

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

[GitHub] flink pull request #5863: [FLINK-8985][e2etest] initial support for End-to-e...

2018-05-18 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5863#discussion_r189185253 --- Diff: flink-end-to-end-tests/test-scripts/test_cli_api.sh --- @@ -0,0 +1,155 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

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

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

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

[jira] [Commented] (FLINK-9387) Several log message errors in queryable-state module

2018-05-18 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480296#comment-16480296 ] vinoyang commented on FLINK-9387: - this change added a log variable placeholder forĀ future.cause(), the

[GitHub] flink pull request #5863: [FLINK-8985][e2etest] initial support for End-to-e...

2018-05-18 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5863#discussion_r189185047 --- Diff: flink-end-to-end-tests/test-scripts/test_cli_api.sh --- @@ -0,0 +1,155 @@ +#!/usr/bin/env bash

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

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

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

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

[jira] [Commented] (FLINK-9387) Several log message errors in queryable-state module

2018-05-18 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480284#comment-16480284 ] Kostas Kloudas commented on FLINK-9387: --- Well there is no change apart from the message wording

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

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

[jira] [Closed] (FLINK-9397) Individual Buffer Timeout of 0 incorrectly leads to default timeout

2018-05-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9397. --- > Individual Buffer Timeout of 0 incorrectly leads to default timeout >

[jira] [Resolved] (FLINK-9397) Individual Buffer Timeout of 0 incorrectly leads to default timeout

2018-05-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-9397. - Resolution: Fixed Fixed in - 1.4.3 via 611ead023ff0be995a4cebb42d579e7e39442c3c - 1.5.0 via

[jira] [Reopened] (FLINK-8161) Flakey YARNSessionCapacitySchedulerITCase on Travis

2018-05-18 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reopened FLINK-8161: Looks like it happened again Also I downloaded logs mentioned in failed travis job {quote}

[jira] [Closed] (FLINK-8267) update Kinesis Producer example for setting Region key

2018-05-18 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-8267. --- Resolution: Later > update Kinesis Producer example for setting Region key >

[jira] [Commented] (FLINK-8554) Upgrade AWS SDK

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

[GitHub] flink issue #5995: [FLINK-9337] Implemented AvroDeserializationSchema

2018-05-18 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/5995 @StephanEwen could you have another look? ---

[jira] [Commented] (FLINK-8554) Upgrade AWS SDK

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

[GitHub] flink issue #5978: [FLINK-8554] Upgrade AWS SDK

2018-05-18 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5978 Are there anything in `1.11.325` we desperately need? If not, I would oppose upgrading AWS SDK too frequently. Highly likely that we don't need any of the new changes in `1.11.325`. As you

[jira] [Commented] (FLINK-9337) Implement AvroDeserializationSchema

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

[jira] [Commented] (FLINK-9337) Implement AvroDeserializationSchema

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

[jira] [Commented] (FLINK-8986) End-to-end test: REST

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

[GitHub] flink issue #5849: [FLINK-8986][e2e-test][WIP] Flink end to end test REST AP...

2018-05-18 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5849 Hi @walterddr, what is the status of this PR? Would be nice if we can move forward with this PR (and also the CLI e2e test PR that also you opened.) ---

[jira] [Resolved] (FLINK-9392) Add @FunctionalInterface annotations to all core functional interfaces

2018-05-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-9392. - Resolution: Fixed Fix Version/s: 1.6.0 Fixed in fafef15eaca1f4277ac1dddb018a8e01eca22817

[jira] [Closed] (FLINK-9392) Add @FunctionalInterface annotations to all core functional interfaces

2018-05-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9392. --- > Add @FunctionalInterface annotations to all core functional interfaces >

[jira] [Commented] (FLINK-9337) Implement AvroDeserializationSchema

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

[jira] [Commented] (FLINK-9349) KafkaConnector Exception while fetching from multiple kafka topics

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

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

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

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

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

[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

2018-05-18 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/6021#discussion_r189177308 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -326,6

[jira] [Commented] (FLINK-9337) Implement AvroDeserializationSchema

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

[GitHub] flink issue #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer Backpr...

2018-05-18 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/6021 @tzulitai adding docs to educate users on tuning KPL performance would be good. I has quite some experience on it (as you may have know :) Ping me if you start working on it before I do, and I'll

[GitHub] flink issue #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ (Transp...

2018-05-18 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5374 @cjolif since we have now reached a conclusion on where the Elasticsearch connector should be improved in the future, could you maybe close this PR? I assume a new PR will be opened that subsumes

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

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

[GitHub] flink issue #5823: [FLINK-9008] [e2e] Implements quickstarts end to end test

2018-05-18 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5823 Thanks @zhangminglei. This looks good to merge, will proceed to merge this. ---

[GitHub] flink pull request #6039: [hotfix] [docs] Add Release Notes for Flink 1.5.

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

[jira] [Commented] (FLINK-9393) LocatableInputSplit#hashCode should take hostnames into account

2018-05-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480310#comment-16480310 ] Stephan Ewen commented on FLINK-9393: - The leaking of the hostnames array make {{equals()}}

[GitHub] flink pull request #5995: [FLINK-9337] Implemented AvroDeserializationSchema

2018-05-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5995#discussion_r189195014 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java --- @@ -0,0 +1,87 @@ +/*

[GitHub] flink issue #5995: [FLINK-9337] Implemented AvroDeserializationSchema

2018-05-18 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5995 Added a few more comment, most importantly around exception wrapping. Otherwise, looking good... ---

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

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

[jira] [Updated] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

2018-05-18 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9398: Description: See:

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

2018-05-18 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/6041 [FLINK-9326] TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode ## What is the purpose of the change *This pull request fixed the num slot config value override

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

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

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

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

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

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

[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

2018-05-18 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6021#discussion_r189174902 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -326,6

[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

2018-05-18 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6021#discussion_r189175770 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -326,6

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

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

[GitHub] flink issue #6041: [FLINK-9326] TaskManagerOptions.NUM_TASK_SLOTS does not w...

2018-05-18 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6041 cc @tillrohrmann ---

[GitHub] flink issue #5978: [FLINK-8554] Upgrade AWS SDK

2018-05-18 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5978 @StephanEwen here is test error in the [build job](https://travis-ci.org/apache/flink/jobs/380523257), and it seems the aws sdk is under license "Apache 2.0", so should I do the second item you

[jira] [Updated] (FLINK-8161) Flakey YARNSessionCapacitySchedulerITCase on Travis

2018-05-18 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-8161: --- Attachment: 24547.10.tar.gz > Flakey YARNSessionCapacitySchedulerITCase on Travis >

[jira] [Updated] (FLINK-8161) Flakey YARNSessionCapacitySchedulerITCase on Travis

2018-05-18 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-8161: --- Attachment: api.travis-ci.org_v3_job_380488917_log.tar.xz > Flakey

[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

2018-05-18 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6021#discussion_r189176708 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -326,6

[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

2018-05-18 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6021#discussion_r189176320 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -326,6

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

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

[GitHub] flink issue #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ (Transp...

2018-05-18 Thread cjolif
Github user cjolif commented on the issue: https://github.com/apache/flink/pull/5374 @tzulitai sure. done. ---

[GitHub] flink pull request #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ ...

2018-05-18 Thread cjolif
Github user cjolif closed the pull request at: https://github.com/apache/flink/pull/5374 ---

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

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

[GitHub] flink pull request #5995: [FLINK-9337] Implemented AvroDeserializationSchema

2018-05-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5995#discussion_r189185186 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java --- @@ -0,0 +1,215 @@ +/* + *

[jira] [Commented] (FLINK-9337) Implement AvroDeserializationSchema

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

[GitHub] flink pull request #5995: [FLINK-9337] Implemented AvroDeserializationSchema

2018-05-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5995#discussion_r189185420 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java --- @@ -0,0 +1,176 @@ +/* + *

[GitHub] flink issue #5798: [FLINK-7917] The return of taskInformationOrBlobKey shoul...

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

[jira] [Commented] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex

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

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

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

[GitHub] flink issue #6039: [hotfix] [docs] Add Release Notes for Flink 1.5.

2018-05-18 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/6039 Thanks, I'll also commit an empty release notes page to the 1.6 / master docs. ---

[GitHub] flink pull request #5995: [FLINK-9337] Implemented AvroDeserializationSchema

2018-05-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5995#discussion_r189197633 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java --- @@ -0,0 +1,176 @@ +/* + *

[jira] [Commented] (FLINK-9337) Implement AvroDeserializationSchema

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

[jira] [Commented] (FLINK-9337) Implement AvroDeserializationSchema

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

[GitHub] flink issue #5823: [FLINK-9008] [e2e] Implements quickstarts end to end test

2018-05-18 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5823 Thank you very much to @tzulitai and @zentol review this PR. ---

[GitHub] flink pull request #5995: [FLINK-9337] Implemented AvroDeserializationSchema

2018-05-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5995#discussion_r189197766 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java --- @@ -0,0 +1,176 @@ +/* + *

[jira] [Updated] (FLINK-9395) Outer Joins with array types on the outer join input fail

2018-05-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9395: - Summary: Outer Joins with array types on the outer join input fail (was: multiple left outer

[jira] [Commented] (FLINK-9395) multiple left outer joins to subqueries with array values fail

2018-05-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480447#comment-16480447 ] Fabian Hueske commented on FLINK-9395: -- Hi [~kgeis], your analysis is correct. The problem is caused

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

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

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

2018-05-18 Thread kisimple
Github user kisimple commented on a diff in the pull request: https://github.com/apache/flink/pull/5983#discussion_r189250250 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/TimeoutAwareAsyncFunction.java --- @@ -0,0 +1,41 @@ +/*

[jira] [Assigned] (FLINK-8511) Remove legacy code for the TableType annotation

2018-05-18 Thread blues zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] blues zheng reassigned FLINK-8511: -- Assignee: blues zheng (was: vinoyang) > Remove legacy code for the TableType annotation >

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

2018-05-18 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5983#discussion_r189244151 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/TimeoutAwareAsyncFunction.java --- @@ -0,0 +1,41 @@ +/*

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

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

[jira] [Updated] (FLINK-9395) Outer Joins with array types on the outer join input fail

2018-05-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9395: - Description: Given a table {{a}} with a single column {{id}}, the following query {code:sql}

[GitHub] flink pull request #5979: [FLINK-9070][state]improve the performance of Rock...

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

[jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module

2018-05-18 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480463#comment-16480463 ] Timo Walther commented on FLINK-9091: - It seems that the versions declared in the

[jira] [Comment Edited] (FLINK-9091) Failure while enforcing releasability in building flink-json module

2018-05-18 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480463#comment-16480463 ] Timo Walther edited comment on FLINK-9091 at 5/18/18 10:20 AM: --- It seems

[GitHub] flink issue #5958: [FLINK-8500] Get the timestamp of the Kafka message from ...

2018-05-18 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5958 @FredTing we had some offline discussion on how to proceed with this. @aljoscha, @twalthr, or @StephanEwen can probably comment more here if I missed anything. The conflict that Stephan

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

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

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

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

[jira] [Commented] (FLINK-1044) Website: Offer a zip archive with a pre-setup user project

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

[jira] [Commented] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

2018-05-18 Thread Triones Deng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481438#comment-16481438 ] Triones Deng commented on FLINK-9390: - [~StephanEwen] notice that now flink make use of

[jira] [Commented] (FLINK-8654) Extend quickstart docs on how to submit jobs

2018-05-18 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481456#comment-16481456 ] Yazdan Shirvany commented on FLINK-8654: [~Zentol] is this still valid? If yes I would like to

[GitHub] flink issue #6044: [FLINK-1044] Website: Offer a zip archive with a pre-setu...

2018-05-18 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6044 @StephanEwen I would appreciate if you review this ---

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

2018-05-18 Thread Yazdan Shirvany (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481458#comment-16481458 ] Yazdan Shirvany commented on FLINK-8983: [~till.rohrmann] is it ok to assign this to myself? >

[GitHub] flink issue #5863: [FLINK-8985][e2etest] initial support for End-to-end CLI ...

2018-05-18 Thread walterddr
Github user walterddr commented on the issue: https://github.com/apache/flink/pull/5863 Thanks @tzulitai for the review. I will update asap. I am not 100% sure whether I should verify the CLI return but I would definitely add them. ---

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

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

[jira] [Created] (FLINK-9400) change import statement for flink-scala

2018-05-18 Thread thinkerou (JIRA)
thinkerou created FLINK-9400: Summary: change import statement for flink-scala Key: FLINK-9400 URL: https://issues.apache.org/jira/browse/FLINK-9400 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9399) TPCHQuery3 example fails due to Serialization issues

2018-05-18 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480822#comment-16480822 ] Timo Walther commented on FLINK-9399: - This is related to a couple of wrong type extraction checks. I

  1   2   >