退订

2021-06-18 Thread 伟波
退订 | | 伟波 | | weib...@126.com | 签名由网易邮箱大师定制

Re: Re: [ANNOUNCE] New PMC member: Xintong Song

2021-06-18 Thread Roman Khachatryan
Congratulations! Regards, Roman On Fri, Jun 18, 2021 at 4:40 AM Yu Li wrote: > > Congratulations, Xintong! > > Best Regards, > Yu > > > On Thu, 17 Jun 2021 at 15:23, Yuan Mei wrote: > > > Congratulations, Xintong :-) > > > > On Thu, Jun 17, 2021 at 11:57 AM Xingbo Huang wrote: > > > > >

Re: [DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2

2021-06-18 Thread Piotr Nowojski
Hi, Thanks for bringing this up. I think before releasing 1.12.x/1.13.x/1.14.x, it would be good to decide what to do with FLINK-23011 [1] and if there is a relatively easy fix, I would wait for it before releasing. Best, Piotrek [1] with https://issues.apache.org/jira/browse/FLINK-23011 pt.,

[jira] [Created] (FLINK-23041) Change local alignment timeout back to the global time out

2021-06-18 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23041: - Summary: Change local alignment timeout back to the global time out Key: FLINK-23041 URL: https://issues.apache.org/jira/browse/FLINK-23041 Project: Flink

Re: [DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2

2021-06-18 Thread Konstantin Knauf
Hi Dawid, Thank you for starting the discussion. I'd like to add https://issues.apache.org/jira/browse/FLINK-23025 to the list for Flink 1.13.2. Cheers, Konstantin On Fri, Jun 18, 2021 at 3:26 PM Dawid Wysakowicz wrote: > Hi devs, > > Quite recently we pushed, in our opinion, quite an

[jira] [Created] (FLINK-23040) Consider ConfigOption fallback keys in FactoryUtil

2021-06-18 Thread Timo Walther (Jira)
Timo Walther created FLINK-23040: Summary: Consider ConfigOption fallback keys in FactoryUtil Key: FLINK-23040 URL: https://issues.apache.org/jira/browse/FLINK-23040 Project: Flink Issue

[DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2

2021-06-18 Thread Dawid Wysakowicz
Hi devs, Quite recently we pushed, in our opinion, quite an important fix[1] for unaligned checkpoints which disables UC for broadcast partitioning. Without the fix there might be some broadcast state corruption. Therefore we think it would be beneficial to release it soonish. What do you think?

[jira] [Created] (FLINK-23039) Support pluggable transports for HTTP endpoints

2021-06-18 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-23039: Summary: Support pluggable transports for HTTP endpoints Key: FLINK-23039 URL: https://issues.apache.org/jira/browse/FLINK-23039 Project: Flink Issue Type:

[jira] [Created] (FLINK-23038) Broken link in Documentation Style Guide

2021-06-18 Thread Daisy Tsang (Jira)
Daisy Tsang created FLINK-23038: --- Summary: Broken link in Documentation Style Guide Key: FLINK-23038 URL: https://issues.apache.org/jira/browse/FLINK-23038 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23037) Document limitations of UC

2021-06-18 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-23037: Summary: Document limitations of UC Key: FLINK-23037 URL: https://issues.apache.org/jira/browse/FLINK-23037 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23036) org.apache.flink.util.FlinkRuntimeException: Error while adding data to RocksDB

2021-06-18 Thread guxiang (Jira)
guxiang created FLINK-23036: --- Summary: org.apache.flink.util.FlinkRuntimeException: Error while adding data to RocksDB Key: FLINK-23036 URL: https://issues.apache.org/jira/browse/FLINK-23036 Project: Flink

Change in accumutors semantics with jobClient

2021-06-18 Thread Etienne Chauchot
Hi all, I did a fix some time ago regarding accumulators: the/JobClient.getAccumulators()/ was infinitely  blocking in local environment for a streaming job (1). The change (2) consisted of giving the current accumulators value for the running job. And when fixing this in the PR, it appeared

[jira] [Created] (FLINK-23035) Add explicit method to StateChangelogWriter to write metadata

2021-06-18 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-23035: - Summary: Add explicit method to StateChangelogWriter to write metadata Key: FLINK-23035 URL: https://issues.apache.org/jira/browse/FLINK-23035 Project:

[jira] [Created] (FLINK-23034) NPE in JobDetailsDeserializer during the reading old version of ExecutionState

2021-06-18 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23034: - Summary: NPE in JobDetailsDeserializer during the reading old version of ExecutionState Key: FLINK-23034 URL: https://issues.apache.org/jira/browse/FLINK-23034

[jira] [Created] (FLINK-23033) Support object array in Python DataStream API

2021-06-18 Thread Dian Fu (Jira)
Dian Fu created FLINK-23033: --- Summary: Support object array in Python DataStream API Key: FLINK-23033 URL: https://issues.apache.org/jira/browse/FLINK-23033 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-129 (Update): Registering sources/sinks on Table API without SQL

2021-06-18 Thread Ingo Bürk
Thanks everyone for the feedback! Since there haven't been any questions/discussions, I'll be moving this to a vote thread next week. Regards Ingo On Tue, Jun 15, 2021 at 5:36 PM JING ZHANG wrote: > Thanks Ingo for starting this discussion. > > > > Big +1 for this feature. Looking forward to

Re: [DISCUSS] FLIP-171: Async Sink

2021-06-18 Thread Arvid Heise
Hi Danny, to add I'd propose to use the flink-connector-base package which has the rough equivalent on source-side SourceReaderBase [1]. Since it's such a handy base implementation, I'd like to see it directly in the main flink repository. For the actual connectors, I'm currently working on a

[jira] [Created] (FLINK-23032) Refactor HiveSource to make it usable in data stream job

2021-06-18 Thread Rui Li (Jira)
Rui Li created FLINK-23032: -- Summary: Refactor HiveSource to make it usable in data stream job Key: FLINK-23032 URL: https://issues.apache.org/jira/browse/FLINK-23032 Project: Flink Issue Type:

[jira] [Created] (FLINK-23031) Support to emit window result with periodic or non_periodic

2021-06-18 Thread Aitozi (Jira)
Aitozi created FLINK-23031: -- Summary: Support to emit window result with periodic or non_periodic Key: FLINK-23031 URL: https://issues.apache.org/jira/browse/FLINK-23031 Project: Flink Issue Type:

[jira] [Created] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

2021-06-18 Thread Jin Xing (Jira)
Jin Xing created FLINK-23030: Summary: PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure Key: FLINK-23030 URL: https://issues.apache.org/jira/browse/FLINK-23030

[jira] [Created] (FLINK-23029) Extend PluginLoader to allow closing of backing ClassLoader

2021-06-18 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23029: Summary: Extend PluginLoader to allow closing of backing ClassLoader Key: FLINK-23029 URL: https://issues.apache.org/jira/browse/FLINK-23029 Project: Flink

[jira] [Created] (FLINK-23028) Improve documentation for pages of SQL.

2021-06-18 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-23028: --- Summary: Improve documentation for pages of SQL. Key: FLINK-23028 URL: https://issues.apache.org/jira/browse/FLINK-23028 Project: Flink Issue Type:

[jira] [Created] (FLINK-23027) Move chill dependency to flink-scala

2021-06-18 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23027: Summary: Move chill dependency to flink-scala Key: FLINK-23027 URL: https://issues.apache.org/jira/browse/FLINK-23027 Project: Flink Issue Type: