[jira] [Created] (FLINK-18821) Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely

Caizhi Weng created FLINK-18821: --- Summary: Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely Key: FLINK-18821 URL: https://issues.apache.org/jira/br

[jira] [Created] (FLINK-18820) SourceOperator should send MAX_WATERMARK to downstream operator when closed

Xuannan Su created FLINK-18820: -- Summary: SourceOperator should send MAX_WATERMARK to downstream operator when closed Key: FLINK-18820 URL: https://issues.apache.org/jira/browse/FLINK-18820 Project: Flin

[jira] [Created] (FLINK-18819) All the PubSub tests are failing

Dian Fu created FLINK-18819: --- Summary: All the PubSub tests are failing Key: FLINK-18819 URL: https://issues.apache.org/jira/browse/FLINK-18819 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

Dian Fu created FLINK-18818: --- Summary: HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed" Key: FLINK-18818 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-18817) 'Kerberized YARN per-job on Docker test' failed

Hequn Cheng created FLINK-18817: --- Summary: 'Kerberized YARN per-job on Docker test' failed Key: FLINK-18817 URL: https://issues.apache.org/jira/browse/FLINK-18817 Project: Flink Issue Type: Tes

[jira] [Created] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

sunjincheng created FLINK-18816: --- Summary: Correct API usage in Pyflink Dependency Management page Key: FLINK-18816 URL: https://issues.apache.org/jira/browse/FLINK-18816 Project: Flink Issue T

Re: [DISCUSS] Planning Flink 1.12

The end of October sounds good from my side, unless it collides with some holidays that affect many committers. Feature-wise, I believe we can definitely make good use of the time to wrap up some critical threads (like finishing the FLIP-27 source efforts). So +1 to the end of October from my sid

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

I'm delighted to see energy going into improving the documentation. With the current documentation, I get a lot of questions that I believe reflect two fundamental problems with what we currently provide: (1) We have a lot of contextual information in our heads about how Flink works, and we are a

[jira] [Created] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

Robert Metzger created FLINK-18815: -- Summary: AbstractCloseableRegistryTest.testClose unstable Key: FLINK-18815 URL: https://issues.apache.org/jira/browse/FLINK-18815 Project: Flink Issue Ty

[jira] [Created] (FLINK-18814) Translate 'Side Outputs' page of 'DataStream API' into Chinese

Roc Marshal created FLINK-18814: --- Summary: Translate 'Side Outputs' page of 'DataStream API' into Chinese Key: FLINK-18814 URL: https://issues.apache.org/jira/browse/FLINK-18814 Project: Flink

[jira] [Created] (FLINK-18813) Translate 'Local Installation' page of 'Try Flink' into Chinese

Roc Marshal created FLINK-18813: --- Summary: Translate 'Local Installation' page of 'Try Flink' into Chinese Key: FLINK-18813 URL: https://issues.apache.org/jira/browse/FLINK-18813 Project: Flink

[jira] [Created] (FLINK-18812) Upgrade StateFun to Flink 1.11.1

Seth Wiesman created FLINK-18812: Summary: Upgrade StateFun to Flink 1.11.1 Key: FLINK-18812 URL: https://issues.apache.org/jira/browse/FLINK-18812 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-132: Temporal Table DDL

Hi, all I’ve updated the FLIP[1] with the terminology `ChangelogTime`. Best Leonard [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-132+Temporal+Table+DDL > 在 2020年8月4日，20:58，Leonard Xu 写道： > > Hi, Ti

Re: [DISCUSS] FLIP-132: Temporal Table DDL

Hi, Timo Thanks for you response. > 1) Naming: Is operation time a good term for this concept? If I read "The > operation time is the time when the changes happened in system." or "The > system time of DML execution in database", why don't we call it > `ChangelogTime` or `SystemTime`? Introduc

[jira] [Created] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

Kai Chen created FLINK-18811: Summary: if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again Key: FLINK-18811

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

Hi Seth and David, I'm very happy to have your reply and suggestions. I would like to share my thoughts here: The main motivation we want to refactor the PyFlink doc is that we want to make sure that the Python users could find all they want starting from the PyFlink documentation mainpage. That’

[jira] [Created] (FLINK-18810) Golang remote functions SDK

Francesco Guardiani created FLINK-18810: --- Summary: Golang remote functions SDK Key: FLINK-18810 URL: https://issues.apache.org/jira/browse/FLINK-18810 Project: Flink Issue Type: New Fea

Status of FLIPs

Hi all, When going through the status of existing FLIPs[1], I found that the status of quite a few of FLIPs are out of date. 1) For the FLIPs which I'm pretty sure that are already finished(the umbrella JIRA has been resolved), I have updated the status of them by moving them from "Adopted/Acc

Re: [DISCUSS] Introduce SupportsParallelismReport and SupportsStatisticsReport for Hive and Filesystem

Hi Kurt, thanks for response, I got your points, they are reasonable, but let me explain more: ## Parallelism setting for source and sink Except `SupportsParallelismReport`, the options are: 1.Support multi transformations If we support multi transformations, yeah, DataStream back again. Persona

[jira] [Created] (FLINK-18809) Update internal aggregate functions to new type system

Timo Walther created FLINK-18809: Summary: Update internal aggregate functions to new type system Key: FLINK-18809 URL: https://issues.apache.org/jira/browse/FLINK-18809 Project: Flink Issue

Re: [DISCUSS] FLIP-132: Temporal Table DDL

Hi Leonard, sorry for jumping into the discussion so late. But I have two questions: 1) Naming: Is operation time a good term for this concept? If I read "The operation time is the time when the changes happened in system." or "The system time of DML execution in database", why don't we call i