Re: [DISCUSS] Split PyFlink packages into two packages: apache-flink and apache-flink-libraries

gt;> >>> Am I reading this correctly that we publish 7 different artifacts just >>> for python? >>> What does the release matrix look like? >>> >>> On 3/16/2021 3:45 AM, Dian Fu wrote: >>>> Hi Xingbo, >>>> >>>>

Re: [DISCUSS] Split PyFlink packages into two packages: apache-flink and apache-flink-libraries

Hi Xingbo, Thanks a lot for bringing up this discussion. Actually the size limit already becomes an issue during releasing 1.11.3 and 1.12.1. It blocks us to publish PyFlink packages to PyPI during the release as there is no enough space left (PS: already published the packages after

[jira] [Created] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

Dian Fu created FLINK-21552: --- Summary: The managed memory was not released if exception was thrown in createPythonExecutionEnvironment Key: FLINK-21552 URL: https://issues.apache.org/jira/browse/FLINK-21552

[ANNOUNCE] New Apache Flink Committers - Wei Zhong and Xingbo Huang

Hi all, On behalf of the PMC, I’m very happy to announce that Wei Zhong and Xingbo Huang have accepted the invitation to become Flink committers. - Wei Zhong mainly works on PyFlink and has driven several important features in PyFlink, e.g. Python UDF dependency management (FLIP-78), Python

Re: [ANNOUNCE] Welcome Roman Khachatryan a new Apache Flink Committer

Congratulations, Roman! Regards, Dian > 在 2021年2月16日，下午5:56，Yuan Mei 写道： > > Well deserved! Congrats Roman! > > Best, > Yuan > > On Tue, Feb 16, 2021 at 5:10 PM Guowei Ma wrote: > >> Congratulations Roman! >> Best, >> Guowei >> >> >> On Thu, Feb 11, 2021 at 3:37 PM Yun Tang wrote: >>

[jira] [Created] (FLINK-21238) Support to close PythonFunctionFactory manually

Dian Fu created FLINK-21238: --- Summary: Support to close PythonFunctionFactory manually Key: FLINK-21238 URL: https://issues.apache.org/jira/browse/FLINK-21238 Project: Flink Issue Type

[jira] [Created] (FLINK-21223) Support to specify the input/output types of Python UDFs via string

Dian Fu created FLINK-21223: --- Summary: Support to specify the input/output types of Python UDFs via string Key: FLINK-21223 URL: https://issues.apache.org/jira/browse/FLINK-21223 Project: Flink

[jira] [Created] (FLINK-21222) Support loopback mode to allow Python UDF worker and client reuse the same Python VM

Dian Fu created FLINK-21222: --- Summary: Support loopback mode to allow Python UDF worker and client reuse the same Python VM Key: FLINK-21222 URL: https://issues.apache.org/jira/browse/FLINK-21222 Project

Re: [ANNOUNCE] Apache Flink 1.10.3 released

Thanks Xintong for driving this release! Regards, Dian > 在 2021年1月29日，下午5:24，Till Rohrmann 写道： > > Thanks Xintong for being our release manager. Well done! > > Cheers, > Till > > On Fri, Jan 29, 2021 at 9:50 AM Yang Wang > wrote: > Thanks Xintong for driving

Re: [VOTE] Release 1.10.3, release candidate #1

+1 (binding) - checked the changes since 1.10.2 and it looks good to me as there are no dependency changes - checked the website PR, have left a minor comment - verified the signatures and checksums Thanks, Dian > 在 2021年1月28日，下午2:39，Xingbo Huang 写道： > > +1 (non-binding) > > - verified

[jira] [Created] (FLINK-21163) Python dependencies specified via CLI should not override the dependencies specified in configuration

Dian Fu created FLINK-21163: --- Summary: Python dependencies specified via CLI should not override the dependencies specified in configuration Key: FLINK-21163 URL: https://issues.apache.org/jira/browse/FLINK-21163

[jira] [Created] (FLINK-21140) Extract zip file dependencies before adding to PYTHONPATH

Dian Fu created FLINK-21140: --- Summary: Extract zip file dependencies before adding to PYTHONPATH Key: FLINK-21140 URL: https://issues.apache.org/jira/browse/FLINK-21140 Project: Flink Issue Type

Re: [ANNOUNCE] Welcome Guowei Ma as a new Apache Flink Committer

Congratulations Guowei! Well deserved! Regards, Dian > 在 2021年1月20日，下午1:42，Yuan Mei 写道： > > Congrats Guowei :-) > > Best, > Yuan > > On Wed, Jan 20, 2021 at 1:36 PM tison wrote: > >> Congrats Guowei! >> >> Best, >> tison. >> >> >> Kurt Young 于2021年1月20日周三 下午1:34写道： >> >>> Hi everyone,

[jira] [Created] (FLINK-21021) Bump Beam to 2.27.0

Dian Fu created FLINK-21021: --- Summary: Bump Beam to 2.27.0 Key: FLINK-21021 URL: https://issues.apache.org/jira/browse/FLINK-21021 Project: Flink Issue Type: Improvement Components: API

[jira] [Created] (FLINK-21019) Bump Netty 4 to 4.1.58

Dian Fu created FLINK-21019: --- Summary: Bump Netty 4 to 4.1.58 Key: FLINK-21019 URL: https://issues.apache.org/jira/browse/FLINK-21019 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-21020) Bump Jackson to 2.12.1

Dian Fu created FLINK-21020: --- Summary: Bump Jackson to 2.12.1 Key: FLINK-21020 URL: https://issues.apache.org/jira/browse/FLINK-21020 Project: Flink Issue Type: Improvement Components

Re: [Vote] FLIP-157 Migrate Flink Documentation from Jekyll to Hugo

+1 > 在 2021年1月19日，上午11:34，Jark Wu 写道： > > +1 > > On Tue, 19 Jan 2021 at 01:59, Till Rohrmann wrote: > >> +1, >> >> Cheers, >> Till >> >> On Mon, Jan 18, 2021 at 4:12 PM Chesnay Schepler >> wrote: >> >>> +1 >>> On 1/18/2021 3:50 PM, Seth Wiesman wrote: Addendum, 72 hours from now is

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

Congratulations, Danny! Regards, Dian > 在 2021年1月12日，下午5:40，Till Rohrmann 写道： > > Congrats and welcome Danny! > > Cheers, > Till > > On Tue, Jan 12, 2021 at 10:09 AM Dawid Wysakowicz > wrote: > >> Congratulations, Danny! >> >> Best, >> >> Dawid >> >> On 12/01/2021 09:52, Paul Lam wrote:

Re: [VOTE] FLIP-153: Support state access in Python DataStream API

+1 (binding) > 在 2021年1月6日，下午1:12，Shuiqiang Chen 写道： > > Hi devs, > > The discussion of the FLIP-153 [1] seems has reached a consensus through > the mailing thread [2]. I would like to start a vote for it. > > The vote will be opened until 11th January (72h), unless there is an > objection or

Re: [DISCUSS] FLIP-155: Introduce a few convenient operations in Table API

Hi all, I have updated the FLIP about temporal join, sql hints and window TVF. Regards, Dian > 在 2021年1月5日，上午11:58，Dian Fu 写道： > > Thanks a lot for your comments! > > Regarding to Python Table API examples: I thought it should be > straightforward about how to use these op

Re: [DISCUSS] FLIP-153: Support state access in Python DataStream API

Thanks Shuiqiang for driving this. The design looks good to me. +1 to start the vote if there are no more comments. Regards, Dian > 在 2021年1月4日，下午7:40，Shuiqiang Chen 写道： > > Hi Yu, > > Thanks a lot for your suggestions. > > I have addressed your inlined comments in the FLIP and also added a

Re: [DISCUSS] FLIP-155: Introduce a few convenient operations in Table API

s already precedent >> for this sort of thing, `GroupedTable#aggregate` can only be followed by >> `select`. >> Seth >> On Mon, Jan 4, 2021 at 6:27 AM Wei Zhong wrote: >>> Hi Dian, >>> >>> Big +1 for making the Table API easier to use. Java users and Pyth

[DISCUSS] FLIP-155: Introduce a few convenient operations in Table API

Hi all, I'd like to start a discussion about introducing a few convenient operations in Table API from the perspective of ease of use. Currently some tasks are not easy to express in Table API e.g. deduplication, topn, etc, or not easy to express when there are hundreds of columns in a

[jira] [Created] (FLINK-20796) Support unnest in the Table API

Dian Fu created FLINK-20796: --- Summary: Support unnest in the Table API Key: FLINK-20796 URL: https://issues.apache.org/jira/browse/FLINK-20796 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20794) Support to select distinct columns in the Table API

Dian Fu created FLINK-20794: --- Summary: Support to select distinct columns in the Table API Key: FLINK-20794 URL: https://issues.apache.org/jira/browse/FLINK-20794 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

Dian Fu created FLINK-20788: --- Summary: It doesn't support to use cube/rollup/grouping sets in the Table API Key: FLINK-20788 URL: https://issues.apache.org/jira/browse/FLINK-20788 Project: Flink

[jira] [Created] (FLINK-20787) Improve the Table API to make it usable

Dian Fu created FLINK-20787: --- Summary: Improve the Table API to make it usable Key: FLINK-20787 URL: https://issues.apache.org/jira/browse/FLINK-20787 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20779) Add documentation for row-based operation in Python Table API

Dian Fu created FLINK-20779: --- Summary: Add documentation for row-based operation in Python Table API Key: FLINK-20779 URL: https://issues.apache.org/jira/browse/FLINK-20779 Project: Flink Issue

Re: [VOTE] Apache Flink Stateful Functions 2.2.2, release candidate #2

Thanks a lot for driving this, Gordon! +1 (binding) - verified the checksum and signature - looked through the changes since 2.2.1 for license changes, verified the NOTICE file of statefun-flink-datastream and it looks good to me - the website PR LGTM Regards, Dian > 在

Re: [VOTE] Release 1.11.3, release candidate #2

+1 (binding) - Verified the checksum and signature - Checked the pom changes since 1.11.2 for the dependencies changes and it looks good to me - Checked the website PR and left one minor comment Thanks, Dian > 在 2020年12月16日，下午3:00，Xintong Song 写道： > > +1 (non-binding) > > - Verified

[jira] [Created] (FLINK-20536) Update migration tests in master to cover migration from release-1.12

Dian Fu created FLINK-20536: --- Summary: Update migration tests in master to cover migration from release-1.12 Key: FLINK-20536 URL: https://issues.apache.org/jira/browse/FLINK-20536 Project: Flink

[jira] [Created] (FLINK-20534) Add Flink 1.12 MigrationVersion

Dian Fu created FLINK-20534: --- Summary: Add Flink 1.12 MigrationVersion Key: FLINK-20534 URL: https://issues.apache.org/jira/browse/FLINK-20534 Project: Flink Issue Type: Task Components

[jira] [Created] (FLINK-20529) Publish Dockerfiles for release 1.12.0

Dian Fu created FLINK-20529: --- Summary: Publish Dockerfiles for release 1.12.0 Key: FLINK-20529 URL: https://issues.apache.org/jira/browse/FLINK-20529 Project: Flink Issue Type: Task

[RESULT][VOTE] Release 1.12.0, release candidate #3

I'm happy to announce that we have unanimously approved 1.12.0 release. There are 12 approving votes, 4 of which are binding: * Robert (binding) * Till (binding) * Zhuzhu (binding) * Dawid (binding) * Xingbo, Huang (non-binding) * Rui, Li (non-binding) * Xintong, Song (non-binding) * Yang, Wang

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

Thank you all for the votes. Regarding to the license issue reported by Dawid, Chesnay's point sounds reasonable for me. It should not be a blocker issue. Since the voting time has passed, I will conclude the vote result in a separate thread. > 在 2020年12月7日，下午9:45，Chesnay Schepler 写道： > >

[jira] [Created] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

Dian Fu created FLINK-20457: --- Summary: Fix the handling of timestamp in DataStream.from_collection Key: FLINK-20457 URL: https://issues.apache.org/jira/browse/FLINK-20457 Project: Flink Issue

[jira] [Created] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds"

Dian Fu created FLINK-20433: --- Summary: UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds" Key: FLINK-20433 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-20432) SQLClientSchemaRegistryITCase hangs

Dian Fu created FLINK-20432: --- Summary: SQLClientSchemaRegistryITCase hangs Key: FLINK-20432 URL: https://issues.apache.org/jira/browse/FLINK-20432 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20429) KafkaTableITCase.testKafkaTemporalJoinChangelog failed with unexpected results

Dian Fu created FLINK-20429: --- Summary: KafkaTableITCase.testKafkaTemporalJoinChangelog failed with unexpected results Key: FLINK-20429 URL: https://issues.apache.org/jira/browse/FLINK-20429 Project: Flink

[jira] [Created] (FLINK-20428) ZooKeeperLeaderElectionConnectionHandlingTest.testConnectionSuspendedHandlingDuringInitialization failed with "No result is expected since there was no leader elected be

Dian Fu created FLINK-20428: --- Summary: ZooKeeperLeaderElectionConnectionHandlingTest.testConnectionSuspendedHandlingDuringInitialization failed with "No result is expected since there was no leader elected before stopping the server

[jira] [Created] (FLINK-20410) SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401"

Dian Fu created FLINK-20410: --- Summary: SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401" Key: FLINK-20410 URL: https://issues.apache.org/jira/br

[ANNOUNCE] release-1.12 branch cut

Hi all, We have already cut the release-1.12 branch from the master branch based on c008907d2a629449c8d0ad9725d13b0604fc2141 commit. Please make sure that the PR is merged to both master and release-1.12 branch if you want it to be present in 1.12.0. Please also set the correct fix version in

[jira] [Created] (FLINK-20363) "Batch SQL end-to-end test" failed during shutdown

Dian Fu created FLINK-20363: --- Summary: "Batch SQL end-to-end test" failed during shutdown Key: FLINK-20363 URL: https://issues.apache.org/jira/browse/FLINK-20363 Project: Flink Issue

[jira] [Created] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)"

Dian Fu created FLINK-20331: --- Summary: UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)" Key: FLINK-20331

[jira] [Created] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

Dian Fu created FLINK-20329: --- Summary: Elasticsearch7DynamicSinkITCase hangs Key: FLINK-20329 URL: https://issues.apache.org/jira/browse/FLINK-20329 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20328) UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available"

Dian Fu created FLINK-20328: --- Summary: UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available" Key: FLINK-20328 URL: https://issues.apach

[jira] [Created] (FLINK-20280) Support batch mode for Python DataStream API

Dian Fu created FLINK-20280: --- Summary: Support batch mode for Python DataStream API Key: FLINK-20280 URL: https://issues.apache.org/jira/browse/FLINK-20280 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-20278) Throw a meaningful exception if the Python DataStream API job executes in batch mode

Dian Fu created FLINK-20278: --- Summary: Throw a meaningful exception if the Python DataStream API job executes in batch mode Key: FLINK-20278 URL: https://issues.apache.org/jira/browse/FLINK-20278 Project

[jira] [Created] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page

Dian Fu created FLINK-20246: --- Summary: Add documentation on Python worker memory tuning in the memory tuning page Key: FLINK-20246 URL: https://issues.apache.org/jira/browse/FLINK-20246 Project: Flink

[jira] [Created] (FLINK-20232) Handle object reuse properly in the operators of Python DataStream API

Dian Fu created FLINK-20232: --- Summary: Handle object reuse properly in the operators of Python DataStream API Key: FLINK-20232 URL: https://issues.apache.org/jira/browse/FLINK-20232 Project: Flink

[jira] [Created] (FLINK-20216) Move "Configuration" and "Environment Variables" under "Python API"

Dian Fu created FLINK-20216: --- Summary: Move "Configuration" and "Environment Variables" under "Python API" Key: FLINK-20216 URL: https://issues.apache.org/jira/browse/FLINK-202

[jira] [Created] (FLINK-20178) Remote file does not exist -- broken link!!!

Dian Fu created FLINK-20178: --- Summary: Remote file does not exist -- broken link!!! Key: FLINK-20178 URL: https://issues.apache.org/jira/browse/FLINK-20178 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20166) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with "CheckpointException: Could not complete snapshot 1 for operator MockTask (1/1)#0. Failure reason: Ch

Dian Fu created FLINK-20166: --- Summary: FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with "CheckpointException: Could not complete snapshot 1 for operator MockTask (1/1)#0. Failure reason: Checkpoint was dec

[jira] [Created] (FLINK-20165) YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initialize

Dian Fu created FLINK-20165: --- Summary: YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initialized Key: FLINK-20165

[jira] [Created] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

Dian Fu created FLINK-20149: --- Summary: SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout." Key: FLINK-20149 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-20140) Add documentation of TableResult.collect for Python Table API

Dian Fu created FLINK-20140: --- Summary: Add documentation of TableResult.collect for Python Table API Key: FLINK-20140 URL: https://issues.apache.org/jira/browse/FLINK-20140 Project: Flink Issue

[jira] [Created] (FLINK-20136) Test all other aspects of new features added in PyFlink

Dian Fu created FLINK-20136: --- Summary: Test all other aspects of new features added in PyFlink Key: FLINK-20136 URL: https://issues.apache.org/jira/browse/FLINK-20136 Project: Flink Issue Type

[jira] [Created] (FLINK-20135) Test Python DataStream API

Dian Fu created FLINK-20135: --- Summary: Test Python DataStream API Key: FLINK-20135 URL: https://issues.apache.org/jira/browse/FLINK-20135 Project: Flink Issue Type: Task Components: API

[jira] [Created] (FLINK-20134) Test non-vectorized Python UDAF

Dian Fu created FLINK-20134: --- Summary: Test non-vectorized Python UDAF Key: FLINK-20134 URL: https://issues.apache.org/jira/browse/FLINK-20134 Project: Flink Issue Type: Task Components

[jira] [Created] (FLINK-20133) Test Pandas UDAF

Dian Fu created FLINK-20133: --- Summary: Test Pandas UDAF Key: FLINK-20133 URL: https://issues.apache.org/jira/browse/FLINK-20133 Project: Flink Issue Type: Task Components: API / Python

[jira] [Created] (FLINK-20132) Test PyFlink new features

Dian Fu created FLINK-20132: --- Summary: Test PyFlink new features Key: FLINK-20132 URL: https://issues.apache.org/jira/browse/FLINK-20132 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-20086) Add documentation for the open method in UserDefinedFunction

Dian Fu created FLINK-20086: --- Summary: Add documentation for the open method in UserDefinedFunction Key: FLINK-20086 URL: https://issues.apache.org/jira/browse/FLINK-20086 Project: Flink Issue

[jira] [Created] (FLINK-20071) Add a dedicated stage to build the PyFlink wheel packges in azure-pipelines.yml

Dian Fu created FLINK-20071: --- Summary: Add a dedicated stage to build the PyFlink wheel packges in azure-pipelines.yml Key: FLINK-20071 URL: https://issues.apache.org/jira/browse/FLINK-20071 Project: Flink

Re: [reminder] Build and check the documentation when reviewing

c02e5c-5865-5c6a-c6c5-92d598e3fc43 > > On Tue, Nov 10, 2020 at 2:50 AM Dian Fu wrote: > >> Thanks a lot for the reminder, Seth. >> >> What about integrating this script in the azure pipeline? There is a >> "Documentation links check" in travis b

[jira] [Created] (FLINK-20069) docs_404_check doesn't work properly

Dian Fu created FLINK-20069: --- Summary: docs_404_check doesn't work properly Key: FLINK-20069 URL: https://issues.apache.org/jira/browse/FLINK-20069 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

Dian Fu created FLINK-20068: --- Summary: KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results Key: FLINK-20068 URL: https://issues.apache.org/jira/browse/FLINK-20068 Project: Flink

[jira] [Created] (FLINK-20067) "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job"

Dian Fu created FLINK-20067: --- Summary: "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job" Key: FLINK-20067 URL: https://issues.apache.o

[jira] [Created] (FLINK-20066) BatchPandasUDAFITTests.test_group_aggregate_with_aux_group unstable

Dian Fu created FLINK-20066: --- Summary: BatchPandasUDAFITTests.test_group_aggregate_with_aux_group unstable Key: FLINK-20066 URL: https://issues.apache.org/jira/browse/FLINK-20066 Project: Flink

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Hi Xintong, I want to bring one more issue to your attention [1]. The test case UnalignedCheckpointCompatibilityITCase.test failed several times in the last nightly test of release-1.11. We need to figure out if it's just an instable test or caused by recent changes. [1]

[jira] [Created] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

Dian Fu created FLINK-20065: --- Summary: UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException Key: FLINK-20065 URL: https://issues.apache.org/jira/browse/FLINK-20065 Project: Flink

Re: [reminder] Build and check the documentation when reviewing

Thanks a lot for the reminder, Seth. What about integrating this script in the azure pipeline? There is a "Documentation links check" in travis before: https://travis-ci.org/github/apache/flink/jobs/742553633 Thanks, Dian > 在

[ANNOUNCE] Apache Flink 1.12.0, release candidate #1

Hi all, The RC1 for Apache Flink 1.12.0 has been created. This is still a preview-only release candidate to drive the current testing efforts and so no official votes will take place. It has all the artifacts that we would typically have for a release, except for the release note and the

Re: [ANNOUNCE] Feature Freeze of Flink 1.12

FYI: we are starting to prepare the first release candidate(preview-only and only for test purpose). Regards, Dian > 在 2020年11月9日，下午1:21，Robert Metzger 写道： > > Hi all, > > Just a quick note that the deadline for merging new features to the master > branch for Flink 1.12 has passed: From now

[jira] [Created] (FLINK-20051) SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException

Dian Fu created FLINK-20051: --- Summary: SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException Key: FLINK-20051 URL: https://issues.apache.org/jira/browse/FLINK-20051 Project

[jira] [Created] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException

Dian Fu created FLINK-20050: --- Summary: SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException Key: FLINK-20050 URL: https://issues.apache.org/jira/browse/FLINK-20050 Project

[jira] [Created] (FLINK-20046) StreamTableAggregateTests.test_map_view_iterate is instable

Dian Fu created FLINK-20046: --- Summary: StreamTableAggregateTests.test_map_view_iterate is instable Key: FLINK-20046 URL: https://issues.apache.org/jira/browse/FLINK-20046 Project: Flink Issue

[jira] [Created] (FLINK-20045) ZooKeeperLeaderElectionTest.testZooKeeperLeaderElectionRetrieval failed with "TimeoutException: Contender was not elected as the leader within 200000ms"

Dian Fu created FLINK-20045: --- Summary: ZooKeeperLeaderElectionTest.testZooKeeperLeaderElectionRetrieval failed with "TimeoutException: Contender was not elected as the leader within 20ms" Key: FLINK-20045

[jira] [Created] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

Dian Fu created FLINK-20011: --- Summary: PageRankITCase.testPrintWithRMatGraph hangs Key: FLINK-20011 URL: https://issues.apache.org/jira/browse/FLINK-20011 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19989) Add collect operation in Python DataStream API

Dian Fu created FLINK-19989: --- Summary: Add collect operation in Python DataStream API Key: FLINK-19989 URL: https://issues.apache.org/jira/browse/FLINK-19989 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19987) HBaseDynamicTableFactoryTest.testTableSourceFactory failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Obje

Dian Fu created FLINK-19987: --- Summary: HBaseDynamicTableFactoryTest.testTableSourceFactory failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V" Key: F

[jira] [Created] (FLINK-19986) The automatic license check failed

Dian Fu created FLINK-19986: --- Summary: The automatic license check failed Key: FLINK-19986 URL: https://issues.apache.org/jira/browse/FLINK-19986 Project: Flink Issue Type: Bug

Re: [DISCUSS][Release 1.12] Stale blockers and build instabilities

failing with "Failed to send data to Kafka: This server >> does not host this topic-partition"" >> https://issues.apache.org/jira/browse/FLINK-18444 >>>> "KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 >> expected:&l

[jira] [Created] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

Dian Fu created FLINK-19914: --- Summary: TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable Key: FLINK-19914 URL: https://issues.apache.org/jira/browse/FLINK-19914 Project

Re: [ANNOUNCE] New Apache Flink Committer - Congxian Qiu

Congratulations Congxian! Regards, Dian > 在 2020年10月29日，下午2:35，Yangze Guo 写道： > > Congratulations! > > Best, > Yangze Guo > > On Thu, Oct 29, 2020 at 2:31 PM Jark Wu wrote: >> >> Congrats Congxian! >> >> Best, >> Jark >> >> On Thu, 29 Oct 2020 at 14:28, Yu Li wrote: >> >>> Hi all, >>>

[jira] [Created] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_LOG

Dian Fu created FLINK-19865: --- Summary: YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"&quo

[jira] [Created] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

Dian Fu created FLINK-19864: --- Summary: TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>" Key: FLINK-19864 URL: https://issues.apache.org/j

[jira] [Created] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

Dian Fu created FLINK-19863: --- Summary: SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout" Key: FLINK-19863 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-19844) Add documentation for Python UDAF

Dian Fu created FLINK-19844: --- Summary: Add documentation for Python UDAF Key: FLINK-19844 URL: https://issues.apache.org/jira/browse/FLINK-19844 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

Dian Fu created FLINK-19843: --- Summary: ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader" Key: FLINK-19843 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-19805) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is instable

Dian Fu created FLINK-19805: --- Summary: LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is instable Key: FLINK-19805 URL: https://issues.apache.org/jira/browse/FLINK-19805 Project: Flink

[jira] [Created] (FLINK-19775) SystemProcessingTimeServiceTest.testImmediateShutdown is instable

Dian Fu created FLINK-19775: --- Summary: SystemProcessingTimeServiceTest.testImmediateShutdown is instable Key: FLINK-19775 URL: https://issues.apache.org/jira/browse/FLINK-19775 Project: Flink

[jira] [Created] (FLINK-19759) DeadlockBreakupTest.testSubplanReuse_AddSingletonExchange is instable

Dian Fu created FLINK-19759: --- Summary: DeadlockBreakupTest.testSubplanReuse_AddSingletonExchange is instable Key: FLINK-19759 URL: https://issues.apache.org/jira/browse/FLINK-19759 Project: Flink

[jira] [Created] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

Dian Fu created FLINK-19728: --- Summary: YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified" Key: FLINK-19728

[jira] [Created] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143

Dian Fu created FLINK-19699: --- Summary: PrometheusReporterEndToEndITCase crashes with exit code 143 Key: FLINK-19699 URL: https://issues.apache.org/jira/browse/FLINK-19699 Project: Flink Issue

[jira] [Created] (FLINK-19690) ParquetStreamingFileSinkITCase.testWriteParquetAvroReflect failed with "expected:<1> but was:<2>"

Dian Fu created FLINK-19690: --- Summary: ParquetStreamingFileSinkITCase.testWriteParquetAvroReflect failed with "expected:<1> but was:<2>" Key: FLINK-19690 URL: https://issues.apache.org/j

[jira] [Created] (FLINK-19675) The plan of is incorrect when Calc contains WHERE clause, composite fields access and Python UDF at the same time

Dian Fu created FLINK-19675: --- Summary: The plan of is incorrect when Calc contains WHERE clause, composite fields access and Python UDF at the same time Key: FLINK-19675 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-19654) Improve the execution time of PyFlink end-to-end tests

Dian Fu created FLINK-19654: --- Summary: Improve the execution time of PyFlink end-to-end tests Key: FLINK-19654 URL: https://issues.apache.org/jira/browse/FLINK-19654 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

Dian Fu created FLINK-19645: --- Summary: ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable Key: FLINK-19645 URL: https://issues.apache.org/jira/browse/FLINK-19645 Project: Flink

[jira] [Created] (FLINK-19642) RocksDBListStatePerformanceTest.testRocksDbListStateAPIs is instable

Dian Fu created FLINK-19642: --- Summary: RocksDBListStatePerformanceTest.testRocksDbListStateAPIs is instable Key: FLINK-19642 URL: https://issues.apache.org/jira/browse/FLINK-19642 Project: Flink

[jira] [Created] (FLINK-19615) HBaseConnectorITCase.testTableSink is instable

Dian Fu created FLINK-19615: --- Summary: HBaseConnectorITCase.testTableSink is instable Key: FLINK-19615 URL: https://issues.apache.org/jira/browse/FLINK-19615 Project: Flink Issue Type: Bug

<    1   2   3   4   5   6   7   8   >