[jira] [Created] (FLINK-12773) Unstable kafka e2e test

Dawid Wysakowicz created FLINK-12773: Summary: Unstable kafka e2e test Key: FLINK-12773 URL: https://issues.apache.org/jira/browse/FLINK-12773 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-12772) Support mapping ARRAY, MAP, ROW (STRUCT) between Flink and Hive in HiveCatalog

Bowen Li created FLINK-12772: Summary: Support mapping ARRAY, MAP, ROW (STRUCT) between Flink and Hive in HiveCatalog Key: FLINK-12772 URL: https://issues.apache.org/jira/browse/FLINK-12772 Project: Flink

[jira] [Created] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

Bowen Li created FLINK-12771: Summary: Support ConnectorCatalogTable in HiveCatalog Key: FLINK-12771 URL: https://issues.apache.org/jira/browse/FLINK-12771 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Features for Apache Flink 1.9.0

For features I'm involved in: - FLIP-30 unified catalogs APIs [1]: close to be done. On track - hive integration - HiveCatalog for persisting Flink/Hive metadata [2]: close to be done. On track - hive data connector [3]: input/output format are close to be done. Was blocked on source/s

Re: [DISCUSS] FLIP-41: Unify Keyed State Snapshot Binary Format for Savepoints

Btw, I think this FLIP is a very good effort, we just need to reframe the effort a tiny bit. +1 > On 6. Jun 2019, at 13:41, Aljoscha Krettek wrote: > > Hi, > > I had a brief discussion with Stephan that helped me sort my thoughts on the > broader topics of checkpoints, savepoints, binary form

Re: [DISCUSS] FLIP-41: Unify Keyed State Snapshot Binary Format for Savepoints

Hi, I had a brief discussion with Stephan that helped me sort my thoughts on the broader topics of checkpoints, savepoints, binary formats, user-triggered checkpoints, and periodic savepoints. I’ll try to summarise my stance on this and also comment with the same message on the other relevant J

[jira] [Created] (FLINK-12770) Make number of bulk concurrentRequests configurable

Suxing Lee created FLINK-12770: -- Summary: Make number of bulk concurrentRequests configurable Key: FLINK-12770 URL: https://issues.apache.org/jira/browse/FLINK-12770 Project: Flink Issue Type: I

[jira] [Created] (FLINK-12769) Simplify expression design for symbols

Timo Walther created FLINK-12769: Summary: Simplify expression design for symbols Key: FLINK-12769 URL: https://issues.apache.org/jira/browse/FLINK-12769 Project: Flink Issue Type: New Featur

[jira] [Created] (FLINK-12768) FlinkKinesisConsumerTest.testSourceSynchronization unstable on Travis

Till Rohrmann created FLINK-12768: - Summary: FlinkKinesisConsumerTest.testSourceSynchronization unstable on Travis Key: FLINK-12768 URL: https://issues.apache.org/jira/browse/FLINK-12768 Project: Flin

Re: Re: [DISCUSS] Support Local Aggregation in Flink

> > hi +1 nice work best forwardxu

Re: Re: [DISCUSS] Support Local Aggregation in Flink

hi +1，nice work best forwardxu boshu Zheng 于2019年6月6日周四 下午4:30写道： > Hi, > > > +1 from my side. Looking forward to this must-have feature :) > > > Best, > boshu > > At 2019-06-05 16:33:13, "vino yang" wrote: > >Hi Aljoscha, > > > >What do you think about this feature and design document? > >

Re:Re: [DISCUSS] Support Local Aggregation in Flink

Hi, +1 from my side. Looking forward to this must-have feature :) Best, boshu At 2019-06-05 16:33:13, "vino yang" wrote: >Hi Aljoscha, > >What do you think about this feature and design document? > >Best, >Vino > >vino yang 于2019年6月5日周三 下午4:18写道： > >> Hi Dian, >> >> I still think your imp

Request for Permission

Hello, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is lemony.

[jira] [Created] (FLINK-12767) Support user defined connectors/format

Dian Fu created FLINK-12767: --- Summary: Support user defined connectors/format Key: FLINK-12767 URL: https://issues.apache.org/jira/browse/FLINK-12767 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-12766) Dynamically allocate TaskExecutor’s managed memory to slots. This step is a temporal workaround for release 1.9 to meet the basic usability requirements of batch functio

Tony Xintong Song created FLINK-12766: - Summary: Dynamically allocate TaskExecutor’s managed memory to slots. This step is a temporal workaround for release 1.9 to meet the basic usability requirements of batch functions from Blink.

[jira] [Created] (FLINK-12765) JobMaster calculates resource needs and requests slot for the entire slot sharing group.

Tony Xintong Song created FLINK-12765: - Summary: JobMaster calculates resource needs and requests slot for the entire slot sharing group. Key: FLINK-12765 URL: https://issues.apache.org/jira/browse/FLINK-12765

[jira] [Created] (FLINK-12764) Launch customized TaskExecutor for tasks whose resource needs cannot be satisfied by existing TaskExecutor-s in active container mode.

Tony Xintong Song created FLINK-12764: - Summary: Launch customized TaskExecutor for tasks whose resource needs cannot be satisfied by existing TaskExecutor-s in active container mode. Key: FLINK-12764 URL: htt

[jira] [Created] (FLINK-12763) Fail job immediately if tasks’ resource needs can not be satisfied in reactive container mode.

Tony Xintong Song created FLINK-12763: - Summary: Fail job immediately if tasks’ resource needs can not be satisfied in reactive container mode. Key: FLINK-12763 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-12762) Memory configuration implementation

Tony Xintong Song created FLINK-12762: - Summary: Memory configuration implementation Key: FLINK-12762 URL: https://issues.apache.org/jira/browse/FLINK-12762 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-12761) Fine grained resource managedment

Tony Xintong Song created FLINK-12761: - Summary: Fine grained resource managedment Key: FLINK-12761 URL: https://issues.apache.org/jira/browse/FLINK-12761 Project: Flink Issue Type: Impro