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

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 i

[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

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

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,

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

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 fi

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 wrote: > > Hi, > > H

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

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

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

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

Stephan Ewen created FLINK-9397: --- Summary: Individual Buffer Timeout of 0 incorrectly leads to default timeout Key: FLINK-9397 URL: https://issues.apache.org/jira/browse/FLINK-9397 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-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 Iss