[jira] [Created] (FLINK-26601) Flink HBase HBaseRowDataAsyncLookupFunction threadPool not close cause container has so many 'hbase-async-lookup-worker' thread

2022-03-10 Thread zhisheng (Jira)
zhisheng created FLINK-26601: Summary: Flink HBase HBaseRowDataAsyncLookupFunction threadPool not close cause container has so many 'hbase-async-lookup-worker' thread Key: FLINK-26601 URL:

[jira] [Created] (FLINK-26600) PerJobMiniClusterFactoryTest.testJobClientSavepoint failed on azure

2022-03-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-26600: --- Summary: PerJobMiniClusterFactoryTest.testJobClientSavepoint failed on azure Key: FLINK-26600 URL: https://issues.apache.org/jira/browse/FLINK-26600 Project: Flink

[jira] [Created] (FLINK-26599) CheckpointCoordinatorTest.testMinCheckpointPause failed on azure

2022-03-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-26599: --- Summary: CheckpointCoordinatorTest.testMinCheckpointPause failed on azure Key: FLINK-26599 URL: https://issues.apache.org/jira/browse/FLINK-26599 Project: Flink

[jira] [Created] (FLINK-26598) OracleTableSinkITCase failed on azure due to container failed to startup

2022-03-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-26598: --- Summary: OracleTableSinkITCase failed on azure due to container failed to startup Key: FLINK-26598 URL: https://issues.apache.org/jira/browse/FLINK-26598 Project: Flink

[jira] [Created] (FLINK-26597) OracleTableSinkITCase failed on azure due to container failed to startup

2022-03-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-26597: --- Summary: OracleTableSinkITCase failed on azure due to container failed to startup Key: FLINK-26597 URL: https://issues.apache.org/jira/browse/FLINK-26597 Project: Flink

[jira] [Created] (FLINK-26596) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

2022-03-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-26596: --- Summary: ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure Key: FLINK-26596 URL:

[jira] [Created] (FLINK-26595) Improve the PostgresDialect method for getting upsert statements.

2022-03-10 Thread wuguihu (Jira)
wuguihu created FLINK-26595: --- Summary: Improve the PostgresDialect method for getting upsert statements. Key: FLINK-26595 URL: https://issues.apache.org/jira/browse/FLINK-26595 Project: Flink

[jira] [Created] (FLINK-26594) Helm: Replace Values.operatorNamespace with built-in Release.Namespace

2022-03-10 Thread Xin Hao (Jira)
Xin Hao created FLINK-26594: --- Summary: Helm: Replace Values.operatorNamespace with built-in Release.Namespace Key: FLINK-26594 URL: https://issues.apache.org/jira/browse/FLINK-26594 Project: Flink

[jira] [Created] (FLINK-26593) task manager can not free memory when jobs are finished caused the linux out of memory

2022-03-10 Thread ren shangtao (Jira)
ren shangtao created FLINK-26593: Summary: task manager can not free memory when jobs are finished caused the linux out of memory Key: FLINK-26593 URL: https://issues.apache.org/jira/browse/FLINK-26593

[jira] [Created] (FLINK-26592) [Changelog] Deadlock in FsStateChangelogWriter

2022-03-10 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-26592: - Summary: [Changelog] Deadlock in FsStateChangelogWriter Key: FLINK-26592 URL: https://issues.apache.org/jira/browse/FLINK-26592 Project: Flink

[jira] [Created] (FLINK-26591) Compilation fails due to RawToBinaryCastRule

2022-03-10 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-26591: - Summary: Compilation fails due to RawToBinaryCastRule Key: FLINK-26591 URL: https://issues.apache.org/jira/browse/FLINK-26591 Project: Flink Issue

[jira] [Created] (FLINK-26590) Triggered checkpoints can be delayed by discarding shared state

2022-03-10 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-26590: - Summary: Triggered checkpoints can be delayed by discarding shared state Key: FLINK-26590 URL: https://issues.apache.org/jira/browse/FLINK-26590 Project:

[jira] [Created] (FLINK-26589) Update the logging level of Kinesis Streams and Firehose sinks

2022-03-10 Thread Zichen Liu (Jira)
Zichen Liu created FLINK-26589: -- Summary: Update the logging level of Kinesis Streams and Firehose sinks Key: FLINK-26589 URL: https://issues.apache.org/jira/browse/FLINK-26589 Project: Flink

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

2022-03-10 Thread yu'an huang
Congrats, Martijn! Best Yuan > On 3 Mar 2022, at 11:49 PM, Robert Metzger wrote: > > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Martijn Visser as a new > Flink committer. > > Martijn is a very active Flink community member, driving a lot of efforts > on the dev@flink

[jira] [Created] (FLINK-26588) Translate the new CAST documentation to Chinese

2022-03-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26588: -- Summary: Translate the new CAST documentation to Chinese Key: FLINK-26588 URL: https://issues.apache.org/jira/browse/FLINK-26588 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink Committer - David Morávek

2022-03-10 Thread yu'an huang
Congratulations, David! Best Yuan > On 9 Mar 2022, at 2:42 PM, Jiangang Liu wrote: > > Congratulations, David. > > Best > Liu Jiangang > > Yu Li 于2022年3月9日周三 14:23写道: > >> Congrats, David! >> >> Best Regards, >> Yu >> >> >> On Tue, 8 Mar 2022 at 16:11, Johannes Moser wrote: >> >>>

[jira] [Created] (FLINK-26587) Replace Configuration arg of RichFunction#open with ReadableConfig

2022-03-10 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-26587: --- Summary: Replace Configuration arg of RichFunction#open with ReadableConfig Key: FLINK-26587 URL: https://issues.apache.org/jira/browse/FLINK-26587 Project:

Cutting the 1.15 branch and releasing RC0

2022-03-10 Thread Johannes Moser
Dear Apache Flink community, It looks like we are closing in on the blockers. [1] We talked today to the contributors working on the issues and it looks like we can get them done this week. There are still some issues for manual testing in progress. [2] Please complete that as soon as possible

[jira] [Created] (FLINK-26586) FileSystem uses unbuffered read I/O

2022-03-10 Thread Matthias Schwalbe (Jira)
Matthias Schwalbe created FLINK-26586: - Summary: FileSystem uses unbuffered read I/O Key: FLINK-26586 URL: https://issues.apache.org/jira/browse/FLINK-26586 Project: Flink Issue Type:

[jira] [Created] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

2022-03-10 Thread Matthias Schwalbe (Jira)
Matthias Schwalbe created FLINK-26585: - Summary: State Processor API: Loading a state set buffers the whole state set in memory before starting to process Key: FLINK-26585 URL:

[jira] [Created] (FLINK-26584) State Processor API fails to write savepoints exceeding 5MB

2022-03-10 Thread Matthias Schwalbe (Jira)
Matthias Schwalbe created FLINK-26584: - Summary: State Processor API fails to write savepoints exceeding 5MB Key: FLINK-26584 URL: https://issues.apache.org/jira/browse/FLINK-26584 Project: Flink

[jira] [Created] (FLINK-26583) Yarn's Application Mode does not fail when submitting a job with a ID that's listed in the JobResultStore

2022-03-10 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26583: - Summary: Yarn's Application Mode does not fail when submitting a job with a ID that's listed in the JobResultStore Key: FLINK-26583 URL:

Re: Fwd: [DISCUSS] Flink's supported APIs and Hive query syntax

2022-03-10 Thread Jark Wu
Hi Francesco, Yes. The Hive syntax is a syntax plugin provided by Hive connector. > But right now I don't think It's a good idea adding new features on top, as it will create only more maintenance burden both for Hive developers and for table developers. We are not adding new Hive features, but

[jira] [Created] (FLINK-26582) Run the assertj conversion script to convert assertions in flink-table

2022-03-10 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-26582: --- Summary: Run the assertj conversion script to convert assertions in flink-table Key: FLINK-26582 URL: https://issues.apache.org/jira/browse/FLINK-26582

[jira] [Created] (FLINK-26581) Job supports the specified HADOOP_USER_NAME

2022-03-10 Thread Bo Cui (Jira)
Bo Cui created FLINK-26581: -- Summary: Job supports the specified HADOOP_USER_NAME Key: FLINK-26581 URL: https://issues.apache.org/jira/browse/FLINK-26581 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26580) FileSink CompactCoordinator add illegal committable as toCompacted.

2022-03-10 Thread Gen Luo (Jira)
Gen Luo created FLINK-26580: --- Summary: FileSink CompactCoordinator add illegal committable as toCompacted. Key: FLINK-26580 URL: https://issues.apache.org/jira/browse/FLINK-26580 Project: Flink

Re: [DISCUSS] Enable scala formatting check

2022-03-10 Thread Chesnay Schepler
Just merge it to master & release-1.15 after 1.15.0 is released. No impact on the current release, but also no issues with backports. On 10/03/2022 07:33, Jark Wu wrote: I also have some concerns because it's a huge change and the 1.15 will be released soon. I remember the last time when we

[jira] [Created] (FLINK-26579) The default source parallelism configuration in adaptive batch scheduling does not take effect

2022-03-10 Thread kangTwang (Jira)
kangTwang created FLINK-26579: - Summary: The default source parallelism configuration in adaptive batch scheduling does not take effect Key: FLINK-26579 URL: https://issues.apache.org/jira/browse/FLINK-26579

[jira] [Created] (FLINK-26578) Translate new Project Configuration section to Chinese

2022-03-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26578: -- Summary: Translate new Project Configuration section to Chinese Key: FLINK-26578 URL: https://issues.apache.org/jira/browse/FLINK-26578 Project: Flink

[jira] [Created] (FLINK-26577) Avoid state loss when switching to last-state upgrade mode

2022-03-10 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26577: -- Summary: Avoid state loss when switching to last-state upgrade mode Key: FLINK-26577 URL: https://issues.apache.org/jira/browse/FLINK-26577 Project: Flink Issue

[jira] [Created] (FLINK-26576) The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong

2022-03-10 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-26576: -- Summary: The value of 'readerParallelism' passed to ContinuousFileMonitoringFunction is wrong Key: FLINK-26576 URL: https://issues.apache.org/jira/browse/FLINK-26576