[jira] [Created] (FLINK-10923) Make SlotPool Status Machine-Readable

Konstantin Knauf created FLINK-10923: Summary: Make SlotPool Status Machine-Readable Key: FLINK-10923 URL: https://issues.apache.org/jira/browse/FLINK-10923 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module

vinoyang created FLINK-10922: Summary: Refactor the placement of the Flink Kafka connector end to end test module Key: FLINK-10922 URL: https://issues.apache.org/jira/browse/FLINK-10922 Project: Flink

Re: [DISCUSS] Task speculative execution for Flink batch

Thanks Xiaowei for the inspiring comments! Yes, we could increase the granularity of speculation from a single task to a bundle of successive tasks especially for the pipelined channel. Xiaowei Jiang 于2018年11月18日周日 下午2:24写道： > Thanks Yangyu for the nice design doc! One thing to consider is the >

Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem

Hi Xiaowei, Thanks for bringing up the question. In the current design, the properties for meta objects are meant to cover anything that's specific to a particular catalog and agnostic to Flink. Anything that is common (such as schema for tables, query text for views, and udf classname) are abs

[jira] [Created] (FLINK-10921) Prioritize shard consumers in Kinesis Consumer by event time

Thomas Weise created FLINK-10921: Summary: Prioritize shard consumers in Kinesis Consumer by event time Key: FLINK-10921 URL: https://issues.apache.org/jira/browse/FLINK-10921 Project: Flink

[jira] [Created] (FLINK-10920) Remove Kafka examples from binary distribution

Till Rohrmann created FLINK-10920: - Summary: Remove Kafka examples from binary distribution Key: FLINK-10920 URL: https://issues.apache.org/jira/browse/FLINK-10920 Project: Flink Issue Type:

[jira] [Created] (FLINK-10919) Flink binary distribution too large

Till Rohrmann created FLINK-10919: - Summary: Flink binary distribution too large Key: FLINK-10919 URL: https://issues.apache.org/jira/browse/FLINK-10919 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Table API Enhancement Outline

Hi Fabian & Piotr, thanks for the feedback! I appreciate your concerns, both on timestamp attributes as well as on implicit group keys. At the same time, I'm also concerned with the proposed approach of allowing Expression* as parameters, especially for flatMap/flatAgg. So far, we never allowed a

Re: [DISCUSS] FLIP-27: Refactor Source Interface

Hi community, Thank you guys for sharing ideas. The thing I really concern is about the thread mode. Actually in Alibaba, we have implemented our "split reader" based source two years ago. That's based on "SourceFunction", it's just an extension not a refactoring. It's almost same with the versio

[jira] [Created] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

Amit created FLINK-10918: Summary: incremental Keyed state with RocksDB throws cannot create directory error in windows Key: FLINK-10918 URL: https://issues.apache.org/jira/browse/FLINK-10918 Project: Flink

[jira] [Created] (FLINK-10917) Bump up the version of codahale's metrics-core to 3.2.3 or higher

Dongwon Kim created FLINK-10917: --- Summary: Bump up the version of codahale's metrics-core to 3.2.3 or higher Key: FLINK-10917 URL: https://issues.apache.org/jira/browse/FLINK-10917 Project: Flink

[jira] [Created] (FLINK-10916) Include duplicated user-specified uid into error message

Kirill Mikheev created FLINK-10916: -- Summary: Include duplicated user-specified uid into error message Key: FLINK-10916 URL: https://issues.apache.org/jira/browse/FLINK-10916 Project: Flink