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

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

[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

[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-8944) Use ListShards for shard discovery in the flink kinesis connector

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

[GitHub] flink pull request #5992: [FLINK-8944] [Kinesis Connector] Use listShards in...

2018-05-18 Thread kailashhd
Github user kailashhd commented on a diff in the pull request: https://github.com/apache/flink/pull/5992#discussion_r189417750 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java --- @@ -181,6

[jira] [Closed] (FLINK-9401) Data lost when rescaling the job from incremental checkpoint

2018-05-18 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou closed FLINK-9401. - Resolution: Invalid > Data lost when rescaling the job from incremental checkpoint >

[jira] [Created] (FLINK-9401) Data lost when rescaling the job from incremental checkpoint

2018-05-18 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9401: - Summary: Data lost when rescaling the job from incremental checkpoint Key: FLINK-9401 URL: https://issues.apache.org/jira/browse/FLINK-9401 Project: Flink Issue

[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=16481354#comment-16481354 ] vinoyang commented on FLINK-9387: - [~Zentol] sorry, it really did not miss a placeholder, so how it fix

[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=16481317#comment-16481317 ] ASF GitHub Bot commented on FLINK-1044: --- GitHub user medcv opened a pull request:

[GitHub] flink pull request #6044: [FLINK-1044] Website: Offer a zip archive with a p...

2018-05-18 Thread medcv
GitHub user medcv opened a pull request: https://github.com/apache/flink/pull/6044 [FLINK-1044] Website: Offer a zip archive with a pre-setup user project ## What is the purpose of the change This PR will run two tests to build Java and Scala quickstart packages. After

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

2018-05-18 Thread cjolif
GitHub user cjolif opened a pull request: https://github.com/apache/flink/pull/6043 [FLINK-7386] evolve RequestIndexer API to make it working with Elastic 5.3+, evolve ElasticsearchApiCallBridge API to make it compatible with a possible RestHighLevelClient implementation ## What

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

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

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

2018-05-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481092#comment-16481092 ] Chesnay Schepler commented on FLINK-9387: - No, it didn't miss a placeholder. There's an implicit

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

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

[GitHub] flink pull request #6042: [FLINK-9400] change import statement for flink-sca...

2018-05-18 Thread thinkerou
GitHub user thinkerou opened a pull request: https://github.com/apache/flink/pull/6042 [FLINK-9400] change import statement for flink-scala **(The sections below can be removed for hotfixes of typos)** ## What is the purpose of the change When I read `flink-scala`

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

2018-05-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480842#comment-16480842 ] Ted Yu commented on FLINK-9091: --- Hit the above error when running tests for 1.5.0 RC. > Failure while

[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

[jira] [Assigned] (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:all-tabpanel ] Timo Walther reassigned FLINK-9399: --- Assignee: Timo Walther > TPCHQuery3 example fails due to Serialization issues >

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

2018-05-18 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-9398: Assignee: Rong Rong > Flink CLI list running job returns all jobs except in CREATE state >

[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] [Updated] (FLINK-9399) TPCHQuery3 example fails due to Serialization issues

2018-05-18 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9399: Summary: TPCHQuery3 example fails due to Serialization issues (was: TPCHQuery3 fails due to Serialization

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

2018-05-18 Thread Gary Yao (JIRA)
Gary Yao created FLINK-9399: --- Summary: TPCHQuery3 fails due to Serialization issues Key: FLINK-9399 URL: https://issues.apache.org/jira/browse/FLINK-9399 Project: Flink Issue Type: Bug

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

2018-05-18 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9398: --- Assignee: (was: vinoyang) > Flink CLI list running job returns all jobs except in CREATE state >

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

2018-05-18 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480791#comment-16480791 ] vinoyang commented on FLINK-9398: - hi [~walterddr] I have not started this issue, I have released it, you

[jira] [Commented] (FLINK-8659) Add migration tests for Broadcast state.

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

[jira] [Closed] (FLINK-8659) Add migration tests for Broadcast state.

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

[GitHub] flink pull request #5955: [FLINK-8659] Add migration itcases for broadcast s...

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

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

2018-05-18 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480670#comment-16480670 ] Rong Rong commented on FLINK-9398: -- Hi [~yanghua], have you started working on this task? I was hoping

[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=16480666#comment-16480666 ] ASF GitHub Bot commented on FLINK-8986: --- Github user walterddr commented on the issue:

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

2018-05-18 Thread walterddr
Github user walterddr commented on the issue: https://github.com/apache/flink/pull/5849 Hi @tzulitai . I've actually created a new version of the test based on @zentol 's comment on this PR: https://github.com/walterddr/flink/compare/FLINK-8985...walterddr:FLINK-8986-test

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

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

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

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

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

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

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

[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-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 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] [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 @@ +/* + *

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

[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 @@ +/*

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

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

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

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

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

[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

[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

[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

[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 @@ +/* + *

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

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

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

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

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

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

  1   2   >