退订

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

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

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: > > > > > Congra

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

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., 1

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

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

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 importa

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

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 Type

[DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2

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? D

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

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: I

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

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

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

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

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

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: Flin

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

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

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

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 t

Re: [DISCUSS] FLIP-171: Async Sink

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 pro

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

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: Impr

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

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

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