[jira] [Created] (FLINK-17605) Consolidate flink.version in Stateful Functions POM files

2020-05-10 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-17605: --- Summary: Consolidate flink.version in Stateful Functions POM files Key: FLINK-17605 URL: https://issues.apache.org/jira/browse/FLINK-17605 Project:

Re: [DISCUSS] Align the behavior of internal return result of MapState#entries, keys, values and iterator.

2020-05-10 Thread Congxian Qiu
+1 to align the behavior to returning empty iterator. and I think this is what's the code style[1] said. Best, Congxian Yu Li 于2020年5月11日周一 上午11:42写道： > +1 to align the behavior to returning empty iterator. There's no `Nullable` > annotation on the `MapState` interfaces, either. > > Best

Re: [DISCUSS] Align the behavior of internal return result of MapState#entries, keys, values and iterator.

2020-05-10 Thread Yu Li
+1 to align the behavior to returning empty iterator. There's no `Nullable` annotation on the `MapState` interfaces, either. Best Regards, Yu On Mon, 11 May 2020 at 11:21, Pengfei Li wrote: > +1 to align the behavior > > Jark Wu 于2020年5月9日周六 下午9:36写道： > > > +1 to return emty iterator and

Re: [DISCUSS] Align the behavior of internal return result of MapState#entries, keys, values and iterator.

2020-05-10 Thread Pengfei Li
+1 to align the behavior Jark Wu 于2020年5月9日周六 下午9:36写道： > +1 to return emty iterator and align the implementations. > > Best, > Jark > > On Sat, 9 May 2020 at 19:18, SteNicholas wrote: > > > Hi Tang Yun, > > I agree with the point you mentioned that align these internal > > behavior > >

sql topN ArrayIndexOutOfBoundsException

2020-05-10 Thread 1101300123
我的flink SQL 的时候使用了topN语法，在程序运行一段时间后出现了如下错误： [flink-akka.actor.default-dispatcher-8695] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Rank(strategy=[AppendFastStrategy], rankType=[ROW_NUMBER], rankRange=[rankStart=1, rankEnd=1], partitionBy=[contact_id, service_no],

[jira] [Created] (FLINK-17604) Implement format factory for CSV serialization and deseriazation schema of RowData type

2020-05-10 Thread Danny Chen (Jira)
Danny Chen created FLINK-17604: -- Summary: Implement format factory for CSV serialization and deseriazation schema of RowData type Key: FLINK-17604 URL: https://issues.apache.org/jira/browse/FLINK-17604

[jira] [Created] (FLINK-17603) Prepare Hive partitioned streaming source

2020-05-10 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17603: Summary: Prepare Hive partitioned streaming source Key: FLINK-17603 URL: https://issues.apache.org/jira/browse/FLINK-17603 Project: Flink Issue Type:

[jira] [Created] (FLINK-17602) Document broadcast state correction

2020-05-10 Thread Mans Singh (Jira)
Mans Singh created FLINK-17602: -- Summary: Document broadcast state correction Key: FLINK-17602 URL: https://issues.apache.org/jira/browse/FLINK-17602 Project: Flink Issue Type: Improvement

serialize Kafka messages with confluent registry under Flink 1.9.1

2020-05-10 Thread Akhlaq Malik
is it possible to publish message to Kafka serialized with KafkaAvroSerializer by Confluent. I’m using Flink 1.9.1 have saw that some development is going on newer version of flink-avro (1.11.0) but I’m stick to the version. I would like to use the newly introduced KafkaSerializationSchema for

[ANNOUNCE] Weekly Community Update 2020/19

2020-05-10 Thread Konstantin Knauf
Dear community, with only a few days left until the planned feature freeze for Flink 1.11 the dev@ mailing list is getting pretty quite while everyone is working on their final features. Hence, this week only a short update. Flink Development == * [releases] Yu has published RC #3

[jira] [Created] (FLINK-17601) TableEnvironmentITCase.testStatementSet fails on travis

2020-05-10 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-17601: Summary: TableEnvironmentITCase.testStatementSet fails on travis Key: FLINK-17601 URL: https://issues.apache.org/jira/browse/FLINK-17601 Project: Flink

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

2020-05-10 Thread Dian Fu
+1 (non-binding) - checked the dependency changes since 1.10.0 1) kafka was bumped from 0.10.2.1 to 0.10.2.2 for flink-connector-kafka-0.10 and it has been reflected in the notice file 2) amazon-kinesis-producer was bumped from 0.13.1 to 0.14.0 and it has been reflected in the notice file

[jira] [Created] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

2020-05-10 Thread Yuval Itzchakov (Jira)
Yuval Itzchakov created FLINK-17600: --- Summary: Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation Key: FLINK-17600 URL:

[jira] [Created] (FLINK-17599) Update documents due to FLIP-84

2020-05-10 Thread Kurt Young (Jira)
Kurt Young created FLINK-17599: -- Summary: Update documents due to FLIP-84 Key: FLINK-17599 URL: https://issues.apache.org/jira/browse/FLINK-17599 Project: Flink Issue Type: Sub-task