[jira] [Created] (FLINK-22286) Fix the state doesn't support custom python class

Huang Xingbo created FLINK-22286: Summary: Fix the state doesn't support custom python class Key: FLINK-22286 URL: https://issues.apache.org/jira/browse/FLINK-22286 Project: Flink Issue Type:

[jira] [Created] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after()

Svend Vanderveken created FLINK-22287: - Summary: Java documentation of mini cluster should mention usage of before() and after() Key: FLINK-22287 URL: https://issues.apache.org/jira/browse/FLINK-22287

[jira] [Created] (FLINK-22288) Remove unnecesary argument from JdbcSink.exactlyOnceSink

Roman Khachatryan created FLINK-22288: - Summary: Remove unnecesary argument from JdbcSink.exactlyOnceSink Key: FLINK-22288 URL: https://issues.apache.org/jira/browse/FLINK-22288 Project: Flink

[jira] [Created] (FLINK-22289) Update JDBC XA sink docs

Roman Khachatryan created FLINK-22289: - Summary: Update JDBC XA sink docs Key: FLINK-22289 URL: https://issues.apache.org/jira/browse/FLINK-22289 Project: Flink Issue Type: Improvement

Welcome to create Pulsar + Flink solutions at Pulsar Hackathon!

Hi Flink community members, I would like to share that the first-ever Apache Pulsar Hackathon (Virtual) is open for registration[1], until April 28, 2021. The goal of this event is to engage the open source community, drive contributions, and generate ideas to enhance Pulsar and its Big Data ecosy

[jira] [Created] (FLINK-22290) Add new unaligned checkpiont options to Python API.

Arvid Heise created FLINK-22290: --- Summary: Add new unaligned checkpiont options to Python API. Key: FLINK-22290 URL: https://issues.apache.org/jira/browse/FLINK-22290 Project: Flink Issue Type:

[jira] [Created] (FLINK-22291) Fix split switching in HiveInputFormatPartitionReader

Miklos Gergely created FLINK-22291: -- Summary: Fix split switching in HiveInputFormatPartitionReader Key: FLINK-22291 URL: https://issues.apache.org/jira/browse/FLINK-22291 Project: Flink Iss

[jira] [Created] (FLINK-22292) Add documentation about state access in Python DataStream API

Dian Fu created FLINK-22292: --- Summary: Add documentation about state access in Python DataStream API Key: FLINK-22292 URL: https://issues.apache.org/jira/browse/FLINK-22292 Project: Flink Issue Ty

Please submit talk proposals for the ApacheCons as soon as possilbe

Hi Flink folks, As the chair of the IoT Track for the NA/EU ApacheCon and Co-Chair of the Asia, I regularly review the submissions for the IoT tracks. I have noticed that there aren't any submissions from your project. If you plan on submitting something, I strongly ask to you do it soon ... by

[jira] [Created] (FLINK-22293) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

Junfan Zhang created FLINK-22293: Summary: Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices Key: FLINK-22293 URL: https://issues.apache.org/jira/browse/FLINK-22293

[jira] [Created] (FLINK-22294) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

Junfan Zhang created FLINK-22294: Summary: Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices Key: FLINK-22294 URL: https://issues.apache.org/jira/browse/FLINK-22294

[jira] [Created] (FLINK-22295) Document sort-merge blocking shuffle

Till Rohrmann created FLINK-22295: - Summary: Document sort-merge blocking shuffle Key: FLINK-22295 URL: https://issues.apache.org/jira/browse/FLINK-22295 Project: Flink Issue Type: Sub-task

[ANNOUNCE] Apache Flink Stateful Functions 3.0.0 released

The Apache Flink community is very happy to announce the release of Apache Flink Stateful Functions (StateFun) 3.0.0. StateFun is a cross-platform stack for building Stateful Serverless applications, making it radically simpler to develop scalable, consistent, and elastic distributed applications.

Re: [VOTE] Deprecating Mesos support

+1 (non-binding) BR, Wanqiang Ji On Thu, Apr 15, 2021 at 9:57 AM Yang Wang wrote: > +1 > > Best, > Yang > > Robert Metzger 于2021年4月15日周四 上午2:49写道： > > > +1 > > > > On Wed, Apr 14, 2021 at 11:32 AM Arvid Heise wrote: > > > > > +1 > > > > > > On Wed, Apr 14, 2021 at 11:21 AM Xintong Song > > >

Re: [DISCUSS]FLIP-150: Introduce Hybrid Source

Hi Stephan, Thanks for the feedback! I agree with the approach of starting with a simple implementation that can address a well understood, significant portion of use cases. I'm planning to continue work on the prototype that I had shared. There is production level usage waiting for it fairly so

[jira] [Created] (FLINK-22296) Introduce Preconditions-util into Python API

Roc Marshal created FLINK-22296: --- Summary: Introduce Preconditions-util into Python API Key: FLINK-22296 URL: https://issues.apache.org/jira/browse/FLINK-22296 Project: Flink Issue Type: Improv

Re: handle SUSPENDED in ZooKeeperLeaderRetrievalService

Hi there, Thanks for providing points to related changes and jira. Some updates from our side, we applied a path by merging FLINK-10052 with master as well as only handling lost state leveraging SessionConnectionStateErrorPolicy FLINK-10052

Re: handle SUSPENDED in ZooKeeperLeaderRetrievalService

Thanks for trying the unfinished PR and sharing the testing results. Glad to here that it could work and really hope the result of more stringent load testing. After then I think we could revive this ticket. Best, Yang Chen Qin 于2021年4月16日周五 上午2:01写道： > Hi there, > > Thanks for providing poin

[jira] [Created] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

Dian Fu created FLINK-22297: --- Summary: Perform early check to ensure that the length of the result is the same as the input for Pandas UDF Key: FLINK-22297 URL: https://issues.apache.org/jira/browse/FLINK-22297

[jira] [Created] (FLINK-22298) The ExecNode's id should always start from 1 in json plan test

godfrey he created FLINK-22298: -- Summary: The ExecNode's id should always start from 1 in json plan test Key: FLINK-22298 URL: https://issues.apache.org/jira/browse/FLINK-22298 Project: Flink I

[jira] [Created] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed

Jingsong Lee created FLINK-22299: Summary: should remind users to ignoreParseErrors option when parser failed Key: FLINK-22299 URL: https://issues.apache.org/jira/browse/FLINK-22299 Project: Flink

[jira] [Created] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

Bo Huang created FLINK-22300: Summary: Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic Key: FLINK-22300 URL: https://issues.apache.org/jira/browse/FLINK-22300

[jira] [Created] (FLINK-22301) Statebackend and CheckpointStorage type is not shown in the Web UI

Yun Gao created FLINK-22301: --- Summary: Statebackend and CheckpointStorage type is not shown in the Web UI Key: FLINK-22301 URL: https://issues.apache.org/jira/browse/FLINK-22301 Project: Flink Iss