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

Rong Rong created FLINK-9398: Summary: Flink CLI list running job returns all jobs except in CREATE state Key: FLINK-9398 URL: https://issues.apache.org/jira/browse/FLINK-9398 Project: Flink

[VOTE] Release 1.5.0, release candidate #4

Hi everyone, Please review and vote on the release candidate #4 for the version 1.5.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1],

[jira] [Created] (FLINK-9396) Allow streaming sources (especially Files, Kafka) to set max queued input elements

Josh Lemer created FLINK-9396: - Summary: Allow streaming sources (especially Files, Kafka) to set max queued input elements Key: FLINK-9396 URL: https://issues.apache.org/jira/browse/FLINK-9396 Project:

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

Ken Geis created FLINK-9395: --- Summary: multiple left outer joins to subqueries with array values fail Key: FLINK-9395 URL: https://issues.apache.org/jira/browse/FLINK-9395 Project: Flink Issue

[jira] [Created] (FLINK-9394) Let externalized checkpoint resume e2e also test rescaling

Tzu-Li (Gordon) Tai created FLINK-9394: -- Summary: Let externalized checkpoint resume e2e also test rescaling Key: FLINK-9394 URL: https://issues.apache.org/jira/browse/FLINK-9394 Project: Flink

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

Ted Yu created FLINK-9393: - Summary: LocatableInputSplit#hashCode should take hostnames into account Key: FLINK-9393 URL: https://issues.apache.org/jira/browse/FLINK-9393 Project: Flink Issue Type:

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

Stephan Ewen created FLINK-9392: --- Summary: Add @FunctionalInterface annotations to all core functional interfaces Key: FLINK-9392 URL: https://issues.apache.org/jira/browse/FLINK-9392 Project: Flink

[jira] [Created] (FLINK-9391) Support UNNEST in Table API

Timo Walther created FLINK-9391: --- Summary: Support UNNEST in Table API Key: FLINK-9391 URL: https://issues.apache.org/jira/browse/FLINK-9391 Project: Flink Issue Type: New Feature

Re: Field Grouping in Flink

Hi Garvit, you can use the `keyBy()` method[1] to partition a stream like the field grouping in Storm. Best, Xingcan [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/#datastream-transformations > On May 17, 2018, at 4:04 PM, Garvit Sharma

Re: [VOTE] Release 1.5.0, release candidate #3

I will update the PR immediately once I finish the dinner. Best, Sihua | | sihua zhou 邮箱：summerle...@163.com | 签名由 网易邮箱大师 定制 在2018年05月17日 18:29，Till Rohrmann 写道： Hi Sihua, thanks for making me aware. This sounds indeed like a problem which might cause the data loss. I think it's worth

Field Grouping in Flink

Hi, How to do field grouping in Flink similar to what we have in storm. Please let me know. Thanks, -- Garvit Sharma github.com/garvitlnmiit/ No Body is a Scholar by birth, its only hard work and strong determination that makes him master.

Re: [VOTE] Release 1.5.0, release candidate #3

Hi Sihua, thanks for making me aware. This sounds indeed like a problem which might cause the data loss. I think it's worth fixing since it does not look like a big thing. I'll postpone the RC until we've fixed this issue. Hopefully we get it in in the next couple of hours. Cheers, Till On Thu,

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

Stefan Richter created FLINK-9390: - Summary: Shutdown of KafkaProducer causes confusing log message Key: FLINK-9390 URL: https://issues.apache.org/jira/browse/FLINK-9390 Project: Flink Issue

[jira] [Created] (FLINK-9389) Improve error message when cancelling job in state canceled via REST API

Ufuk Celebi created FLINK-9389: -- Summary: Improve error message when cancelling job in state canceled via REST API Key: FLINK-9389 URL: https://issues.apache.org/jira/browse/FLINK-9389 Project: Flink

[jira] [Created] (FLINK-9388) Inconsistency in job shutdown produces confusing log message

Stefan Richter created FLINK-9388: - Summary: Inconsistency in job shutdown produces confusing log message Key: FLINK-9388 URL: https://issues.apache.org/jira/browse/FLINK-9388 Project: Flink

Re: [VOTE] Release 1.5.0, release candidate #3

Hi, And we found this one[1]. It is an issue that could lead to data losing(checkpoint & restoring) when people using the RocksDBBackend, cause by the not so nice APIs of RocksIterator...had a hard time to believe it, but this seems to affect all the release versions, so I'm not sure whether

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

vinoyang created FLINK-9387: --- Summary: Several log message errors in queryable-state module Key: FLINK-9387 URL: https://issues.apache.org/jira/browse/FLINK-9387 Project: Flink Issue Type:

Re: [DISCUSS] GitBox

+1 for using Gitbox Timo Am 16.05.18 um 17:43 schrieb Kenneth Knowles: Actually, GitHub has a feature so you do not require picture-perfect commits: https://help.github.com/articles/allowing-changes-to-a-pull-request-branch-created-from-a-fork/ If the owner of the PR checks the box, it will