[jira] [Created] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

Jingsong Lee created FLINK-19916: Summary: Hadoop3 ShutdownHookManager visit closed ClassLoader Key: FLINK-19916 URL: https://issues.apache.org/jira/browse/FLINK-19916 Project: Flink Issue Ty

[jira] [Created] (FLINK-19917) RocksDBInitTest.testTempLibFolderDeletedOnFail fails on Windows

Andrey Zagrebin created FLINK-19917: --- Summary: RocksDBInitTest.testTempLibFolderDeletedOnFail fails on Windows Key: FLINK-19917 URL: https://issues.apache.org/jira/browse/FLINK-19917 Project: Flink

[jira] [Created] (FLINK-19918) RocksIncrementalCheckpointRescalingTest.testScalingDown fails on Windows

Andrey Zagrebin created FLINK-19918: --- Summary: RocksIncrementalCheckpointRescalingTest.testScalingDown fails on Windows Key: FLINK-19918 URL: https://issues.apache.org/jira/browse/FLINK-19918 Projec

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

Congratulations Congxian! Matthias Pohl 于2020年11月2日周一 下午3:57写道： > Yup, congratulations Congxian! > > On Mon, Nov 2, 2020 at 8:46 AM Danny Chan wrote: > > > Congrats, Doctor Qiu! Well deserved! > > > > Congxian Qiu 于2020年10月31日周六 下午9:45写道： > > > > > Thanks all for the support. It's a great hono

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

Congrats Congxian! Thanks, Zhu Pengcheng Liu 于2020年11月2日周一 下午5:01写道： > Congratulations Congxian! > > Matthias Pohl 于2020年11月2日周一 下午3:57写道： > > > Yup, congratulations Congxian! > > > > On Mon, Nov 2, 2020 at 8:46 AM Danny Chan wrote: > > > > > Congrats, Doctor Qiu! Well deserved! > > > > > > C

[jira] [Created] (FLINK-19919) Remove legacy scheduling in ExecutionGraph components

Zhu Zhu created FLINK-19919: --- Summary: Remove legacy scheduling in ExecutionGraph components Key: FLINK-19919 URL: https://issues.apache.org/jira/browse/FLINK-19919 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-19920) Remove legacy FailoverStrategy

Zhu Zhu created FLINK-19920: --- Summary: Remove legacy FailoverStrategy Key: FLINK-19920 URL: https://issues.apache.org/jira/browse/FLINK-19920 Project: Flink Issue Type: Sub-task Component

[jira] [Created] (FLINK-19921) Remove legacy RestartStrategy

Zhu Zhu created FLINK-19921: --- Summary: Remove legacy RestartStrategy Key: FLINK-19921 URL: https://issues.apache.org/jira/browse/FLINK-19921 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-19922) Remove SlotProvider from SchedulerNG

Zhu Zhu created FLINK-19922: --- Summary: Remove SlotProvider from SchedulerNG Key: FLINK-19922 URL: https://issues.apache.org/jira/browse/FLINK-19922 Project: Flink Issue Type: Sub-task Com

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

Congratulations Congxian! Best, Yang Zhu Zhu 于2020年11月2日周一 下午5:14写道： > Congrats Congxian! > > Thanks, > Zhu > > Pengcheng Liu 于2020年11月2日周一 下午5:01写道： > > > Congratulations Congxian! > > > > Matthias Pohl 于2020年11月2日周一 下午3:57写道： > > > > > Yup, congratulations Congxian! > > > > > > On Mon, Nov

[jira] [Created] (FLINK-19923) Remove BulkSlotProvider, its implementation and tests

Andrey Zagrebin created FLINK-19923: --- Summary: Remove BulkSlotProvider, its implementation and tests Key: FLINK-19923 URL: https://issues.apache.org/jira/browse/FLINK-19923 Project: Flink I

[jira] [Created] (FLINK-19924) Disallow unaligned checkpoints for iterative jobs

Roman Khachatryan created FLINK-19924: - Summary: Disallow unaligned checkpoints for iterative jobs Key: FLINK-19924 URL: https://issues.apache.org/jira/browse/FLINK-19924 Project: Flink I

[jira] [Created] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

godfrey he created FLINK-19925: -- Summary: Errors$NativeIoException: readAddress(..) failed: Connection reset by peer Key: FLINK-19925 URL: https://issues.apache.org/jira/browse/FLINK-19925 Project: Flink

[jira] [Created] (FLINK-19926) Wrong results for join post tumble grouping

Satyam Shekhar created FLINK-19926: -- Summary: Wrong results for join post tumble grouping Key: FLINK-19926 URL: https://issues.apache.org/jira/browse/FLINK-19926 Project: Flink Issue Type: B

[jira] [Created] (FLINK-19927) ExecutionStateUpdateListener is only updated when legacy scheduling is enabled

Robert Metzger created FLINK-19927: -- Summary: ExecutionStateUpdateListener is only updated when legacy scheduling is enabled Key: FLINK-19927 URL: https://issues.apache.org/jira/browse/FLINK-19927 Pr

[DISCUSS] Releasing StateFun hotfix version 2.2.1

Hi, We’re currently thinking about releasing StateFun 2.2.1, to address a critical bug that causes restores from checkpoints / savepoints to fail under certain circumstances [1]. To provide a bit more context, the full fix for this issue is two-fold: 1. *Fix restoring from checkpoints / savep

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

Congrats Congxian! Cheers, Fabian Am Mo., 2. Nov. 2020 um 10:33 Uhr schrieb Yang Wang : > Congratulations Congxian! > > Best, > Yang > > Zhu Zhu 于2020年11月2日周一 下午5:14写道： > > > Congrats Congxian! > > > > Thanks, > > Zhu > > > > Pengcheng Liu 于2020年11月2日周一 下午5:01写道： > > > > > Congratulations Cong

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Hi Steven! So far there are no plans to pick back the file system connector code. This is still evolving and not finalized for 1.12, so I don't feel it is a good candidate to be backported. However, with the base connector changes backported, you should be able to run the file connector code from

[jira] [Created] (FLINK-19928) Introduce test configuration to detect instabilities better

Robert Metzger created FLINK-19928: -- Summary: Introduce test configuration to detect instabilities better Key: FLINK-19928 URL: https://issues.apache.org/jira/browse/FLINK-19928 Project: Flink

[jira] [Created] (FLINK-19929) Upgrade Kinesis dependencies to avoid protobuf 2.6.1

Chesnay Schepler created FLINK-19929: Summary: Upgrade Kinesis dependencies to avoid protobuf 2.6.1 Key: FLINK-19929 URL: https://issues.apache.org/jira/browse/FLINK-19929 Project: Flink

[jira] [Created] (FLINK-19930) Upgrade cassandra-driver-core to 4.X

Chesnay Schepler created FLINK-19930: Summary: Upgrade cassandra-driver-core to 4.X Key: FLINK-19930 URL: https://issues.apache.org/jira/browse/FLINK-19930 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-19931) Do not emit intermediate results for reduce operation BATCH execution mode

Dawid Wysakowicz created FLINK-19931: Summary: Do not emit intermediate results for reduce operation BATCH execution mode Key: FLINK-19931 URL: https://issues.apache.org/jira/browse/FLINK-19931 Pr

[jira] [Created] (FLINK-19932) Add integration test for BATCH execution on DataStream API

Aljoscha Krettek created FLINK-19932: Summary: Add integration test for BATCH execution on DataStream API Key: FLINK-19932 URL: https://issues.apache.org/jira/browse/FLINK-19932 Project: Flink

[jira] [Created] (FLINK-19933) Execute and collect with limit fails on bounded datastream jobs

Seth Wiesman created FLINK-19933: Summary: Execute and collect with limit fails on bounded datastream jobs Key: FLINK-19933 URL: https://issues.apache.org/jira/browse/FLINK-19933 Project: Flink

Re: [DISCUSS] Releasing Apache Flink 1.11.3

Stephan, thanks a lot for explaining the file connector. that makes sense. I was asking because we were trying to reuse some of the implementations in the file source for Iceberg source. Flink Iceberg source lives in the Iceberg repo, which is not possible to code against the master branch of the

[jira] [Created] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable)

Steven Zhen Wu created FLINK-19934: -- Summary: [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable) Key: FLINK-19934 URL: https://issues.apache.org/jira/browse/FLINK-19934 Project: F

Dependency injection and flink.

Hi, I'm trying to integrate a dependency injection framework with flink. When I searched the user-mailing list, I found the following thread in flink which discussed this in the past: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dependency-Injection-and-Flink-td18880.html S

[jira] [Created] (FLINK-19935) OOM error occur for sql-client sumit job without JVM heap setting

harold.miao created FLINK-19935: --- Summary: OOM error occur for sql-client sumit job without JVM heap setting Key: FLINK-19935 URL: https://issues.apache.org/jira/browse/FLINK-19935 Project: Flink

Could someone please take a look at mr PR, thanks

Here I fix a potential NPE and contributed my patch, but no one reviewed after several months (https://github.com/apache/flink/pull/12702), this PR has conflicts, so I pull a new one ( https://github.com/apache/flink/pull/13836), would someone be nice to take a look at this? Regards! Aron Tao

[jira] [Created] (FLINK-19936) Make SinkITCase more stable

Guowei Ma created FLINK-19936: - Summary: Make SinkITCase more stable Key: FLINK-19936 URL: https://issues.apache.org/jira/browse/FLINK-19936 Project: Flink Issue Type: Sub-task Componen

[jira] [Created] (FLINK-19937) Support sink parallelism for all connectors

Lsw_aka_laplace created FLINK-19937: --- Summary: Support sink parallelism for all connectors Key: FLINK-19937 URL: https://issues.apache.org/jira/browse/FLINK-19937 Project: Flink Issue Type:

[jira] [Created] (FLINK-19938) Implement shuffle data read scheduling for sort-merge blocking shuffle

Yingjie Cao created FLINK-19938: --- Summary: Implement shuffle data read scheduling for sort-merge blocking shuffle Key: FLINK-19938 URL: https://issues.apache.org/jira/browse/FLINK-19938 Project: Flink

[jira] [Created] (FLINK-19939) Remove redundant union from multiple input node

Caizhi Weng created FLINK-19939: --- Summary: Remove redundant union from multiple input node Key: FLINK-19939 URL: https://issues.apache.org/jira/browse/FLINK-19939 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

Caizhi Weng created FLINK-19940: --- Summary: Task names on web UI should change when an operator chain is chained with sources Key: FLINK-19940 URL: https://issues.apache.org/jira/browse/FLINK-19940 Proje

Re: Could someone please take a look at mr PR, thanks

Sorry for the late reviewing. The community is busy preparing for 1.12 release. I guess this is the reason that this PR was missed to review. I will help to review this PR later. Thanks for the contribution! Best, Jark On Tue, 3 Nov 2020 at 10:36, JiaTao Tao wrote: > Here I fix a potential NPE

[jira] [Created] (FLINK-19941) Support sink parallelism configuration to Kafka connector

CloseRiver created FLINK-19941: -- Summary: Support sink parallelism configuration to Kafka connector Key: FLINK-19941 URL: https://issues.apache.org/jira/browse/FLINK-19941 Project: Flink Issue T

[jira] [Created] (FLINK-19942) Support sink parallelism configuration to JDBC connector

CloseRiver created FLINK-19942: -- Summary: Support sink parallelism configuration to JDBC connector Key: FLINK-19942 URL: https://issues.apache.org/jira/browse/FLINK-19942 Project: Flink Issue Ty

[jira] [Created] (FLINK-19943) Support sink parallelism configuration to ElasticSearch connector

CloseRiver created FLINK-19943: -- Summary: Support sink parallelism configuration to ElasticSearch connector Key: FLINK-19943 URL: https://issues.apache.org/jira/browse/FLINK-19943 Project: Flink

[jira] [Created] (FLINK-19944) Support sink parallelism configuration to Hive connector

CloseRiver created FLINK-19944: -- Summary: Support sink parallelism configuration to Hive connector Key: FLINK-19944 URL: https://issues.apache.org/jira/browse/FLINK-19944 Project: Flink Issue Ty

[jira] [Created] (FLINK-19945) Support sink parallelism configuration to FileSystem connector

CloseRiver created FLINK-19945: -- Summary: Support sink parallelism configuration to FileSystem connector Key: FLINK-19945 URL: https://issues.apache.org/jira/browse/FLINK-19945 Project: Flink I

[jira] [Created] (FLINK-19946) Support sink parallelism configuration to Hbase connector

CloseRiver created FLINK-19946: -- Summary: Support sink parallelism configuration to Hbase connector Key: FLINK-19946 URL: https://issues.apache.org/jira/browse/FLINK-19946 Project: Flink Issue T

[jira] [Created] (FLINK-19947) Support sink parallelism configuration to Print connector

CloseRiver created FLINK-19947: -- Summary: Support sink parallelism configuration to Print connector Key: FLINK-19947 URL: https://issues.apache.org/jira/browse/FLINK-19947 Project: Flink Issue T

Re: Could someone please take a look at mr PR, thanks

Hi Jark Thanks a lot! Regards! Aron Tao Jark Wu 于2020年11月3日周二 下午2:45写道： > Sorry for the late reviewing. The community is busy preparing for 1.12 > release. > I guess this is the reason that this PR was missed to review. > I will help to review this PR later. > > Thanks for the contribution!