Re: Looking for Maintainers for Flink on YARN

Hi All, Just arrived back from holiday and seen this thread. Aug 11 works for me too, Till please add me to the meeting too. Thanks Miklos On Thu, Aug 5, 2021 at 4:55 PM Till Rohrmann wrote: > Great to hear from everybody. I've created an invite for Thu, Aug 11, 9am > CEST and invited Gabor an

Re: [ANNOUNCE] RocksDB Version Upgrade and Performance

Hi Yun, Thanks for your detailed description about the progress of Flink and RocksDB's community. There're more than 1,200 jobs using RocksDB as the state backend at Bytedance, and we do met several problems mentioned in the JIRA issues you referred: (1) Memory Management: for large-scale jobs(10

[jira] [Created] (FLINK-23685) Translate "Java Lambda Expressions" page into Chinese

wuguihu created FLINK-23685: --- Summary: Translate "Java Lambda Expressions" page into Chinese Key: FLINK-23685 URL: https://issues.apache.org/jira/browse/FLINK-23685 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-23684) KafkaITCase.testAutoOffsetRetrievalAndCommitToKafka fails with NoSuchElementException

Xintong Song created FLINK-23684: Summary: KafkaITCase.testAutoOffsetRetrievalAndCommitToKafka fails with NoSuchElementException Key: FLINK-23684 URL: https://issues.apache.org/jira/browse/FLINK-23684

[jira] [Created] (FLINK-23683) KafkaSinkITCase hangs on azure

Xintong Song created FLINK-23683: Summary: KafkaSinkITCase hangs on azure Key: FLINK-23683 URL: https://issues.apache.org/jira/browse/FLINK-23683 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-23682) HAQueryableStateFsBackendITCase.testCustomKryoSerializerHandling fails due to AskTimeoutException

Xintong Song created FLINK-23682: Summary: HAQueryableStateFsBackendITCase.testCustomKryoSerializerHandling fails due to AskTimeoutException Key: FLINK-23682 URL: https://issues.apache.org/jira/browse/FLINK-23682

[jira] [Created] (FLINK-23681) Rename the field name of OperatorIDPair to avoid the confusion

Yun Gao created FLINK-23681: --- Summary: Rename the field name of OperatorIDPair to avoid the confusion Key: FLINK-23681 URL: https://issues.apache.org/jira/browse/FLINK-23681 Project: Flink Issue T

[jira] [Created] (FLINK-23680) StreamTaskTimerTest.testOpenCloseAndTimestamps fails on azure

Xintong Song created FLINK-23680: Summary: StreamTaskTimerTest.testOpenCloseAndTimestamps fails on azure Key: FLINK-23680 URL: https://issues.apache.org/jira/browse/FLINK-23680 Project: Flink

[jira] [Created] (FLINK-23679) PyFlink end-to-end test fail due to test script contains errors

Xintong Song created FLINK-23679: Summary: PyFlink end-to-end test fail due to test script contains errors Key: FLINK-23679 URL: https://issues.apache.org/jira/browse/FLINK-23679 Project: Flink

[jira] [Created] (FLINK-23678) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure

Xintong Song created FLINK-23678: Summary: KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure Key: FLINK-23678 URL: https://issues.apache.org/jira/browse/FLINK-23678 Projec

[jira] [Created] (FLINK-23677) KafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue fails due to timeout

Xintong Song created FLINK-23677: Summary: KafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue fails due to timeout Key: FLINK-23677 URL: https://issues.apache.org/jira/browse/FLINK-23677 Proje

[jira] [Created] (FLINK-23676) ReduceOnNeighborMethodsITCase.testSumOfOutNeighborsNoValue fails due to AskTimeoutException

Xintong Song created FLINK-23676: Summary: ReduceOnNeighborMethodsITCase.testSumOfOutNeighborsNoValue fails due to AskTimeoutException Key: FLINK-23676 URL: https://issues.apache.org/jira/browse/FLINK-23676

[jira] [Created] (FLINK-23675) flink1.13 cumulate 函数不能和部分比较函数连用

lihangfei created FLINK-23675: - Summary: flink1.13 cumulate 函数不能和部分比较函数连用 Key: FLINK-23675 URL: https://issues.apache.org/jira/browse/FLINK-23675 Project: Flink Issue Type: Bug Componen