[jira] [Created] (FLINK-23773) KafkaPartitionSplitReader should remove empty splits from fetcher

2021-08-13 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-23773: - Summary: KafkaPartitionSplitReader should remove empty splits from fetcher Key: FLINK-23773 URL: https://issues.apache.org/jira/browse/FLINK-23773 Project: Flink

[jira] [Created] (FLINK-23772) Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery

2021-08-13 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-23772: -- Summary: Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery Key: FLINK-23772 URL: https://issues.apache.org/jira/

[jira] [Created] (FLINK-23771) FLIP-147 Checkpoint N has not been started at all

2021-08-13 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-23771: -- Summary: FLIP-147 Checkpoint N has not been started at all Key: FLINK-23771 URL: https://issues.apache.org/jira/browse/FLINK-23771 Project: Flink Issue T

[jira] [Created] (FLINK-23770) Unable to recover after source fully finished

2021-08-13 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-23770: - Summary: Unable to recover after source fully finished Key: FLINK-23770 URL: https://issues.apache.org/jira/browse/FLINK-23770 Project: Flink Issue

[jira] [Created] (FLINK-23769) [doc]Delete the superfluous Chinese text for the English page "deployment/reaource-providers/yarn"

2021-08-13 Thread wuguihu (Jira)
wuguihu created FLINK-23769: --- Summary: [doc]Delete the superfluous Chinese text for the English page "deployment/reaource-providers/yarn" Key: FLINK-23769 URL: https://issues.apache.org/jira/browse/FLINK-23769

[jira] [Created] (FLINK-23768) Test StreamTableEnvironment batch mode in Python

2021-08-13 Thread Timo Walther (Jira)
Timo Walther created FLINK-23768: Summary: Test StreamTableEnvironment batch mode in Python Key: FLINK-23768 URL: https://issues.apache.org/jira/browse/FLINK-23768 Project: Flink Issue Type:

[jira] [Created] (FLINK-23767) FLIP-180: Adjust StreamStatus and Idleness definition

2021-08-13 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-23767: --- Summary: FLIP-180: Adjust StreamStatus and Idleness definition Key: FLINK-23767 URL: https://issues.apache.org/jira/browse/FLINK-23767 Project: Flink Issue Typ

[RESULT][VOTE] FLIP-180: Adjust StreamStatus and Idleness definition

2021-08-13 Thread Arvid Heise
Dear devs, I'm happy to announce that we have unanimously approved this FLIP. There are 4 approving votes of which 4 are binding: Till Rohrmann (binding) Stephan Ewen (binding) Piotr Nowojski (binding) Tzu-Li (Gordon) Tai (binding) Best, Arvid On Mon, Aug 9, 2021 at 6:46 PM Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-23766) test_data_stream.py failed with flake8 checks

2021-08-13 Thread Xintong Song (Jira)
Xintong Song created FLINK-23766: Summary: test_data_stream.py failed with flake8 checks Key: FLINK-23766 URL: https://issues.apache.org/jira/browse/FLINK-23766 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23765) PythonTableFunctionOperatorTestBase

2021-08-13 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-23765: Summary: PythonTableFunctionOperatorTestBase Key: FLINK-23765 URL: https://issues.apache.org/jira/browse/FLINK-23765 Project: Flink Issue Type: Bug Repor

[jira] [Created] (FLINK-23764) add RuntimeContext to SourceReaderContext

2021-08-13 Thread Hang Ruan (Jira)
Hang Ruan created FLINK-23764: - Summary: add RuntimeContext to SourceReaderContext Key: FLINK-23764 URL: https://issues.apache.org/jira/browse/FLINK-23764 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23763) Use yarn config in sql but not yarn magic properties file

2021-08-13 Thread wangzeyu (Jira)
wangzeyu created FLINK-23763: Summary: Use yarn config in sql but not yarn magic properties file Key: FLINK-23763 URL: https://issues.apache.org/jira/browse/FLINK-23763 Project: Flink Issue Type:

[jira] [Created] (FLINK-23762) Revisit RequestReplyFunctionTest unit tests

2021-08-13 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-23762: --- Summary: Revisit RequestReplyFunctionTest unit tests Key: FLINK-23762 URL: https://issues.apache.org/jira/browse/FLINK-23762 Project: Flink Iss

[jira] [Created] (FLINK-23761) FlinkSQL1.12 BatchMode Group By with INT type can not produce the correct result

2021-08-13 Thread zhengjiewen (Jira)
zhengjiewen created FLINK-23761: --- Summary: FlinkSQL1.12 BatchMode Group By with INT type can not produce the correct result Key: FLINK-23761 URL: https://issues.apache.org/jira/browse/FLINK-23761 Projec

[jira] [Created] (FLINK-23760) Static methods in interface require -target:jvm-1.8

2021-08-13 Thread liyongguang (Jira)
liyongguang created FLINK-23760: --- Summary: Static methods in interface require -target:jvm-1.8 Key: FLINK-23760 URL: https://issues.apache.org/jira/browse/FLINK-23760 Project: Flink Issue Type:

[jira] [Created] (FLINK-23759) notifyCheckpointComplete without corresponding snapshotState

2021-08-13 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-23759: --- Summary: notifyCheckpointComplete without corresponding snapshotState Key: FLINK-23759 URL: https://issues.apache.org/jira/browse/FLINK-23759 Project: Flink I

[jira] [Created] (FLINK-23758) PyFlink __invert__ has wrong semantics

2021-08-13 Thread Jira
Ingo Bürk created FLINK-23758: - Summary: PyFlink __invert__ has wrong semantics Key: FLINK-23758 URL: https://issues.apache.org/jira/browse/FLINK-23758 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-23757) Support JSON methods in pyFlink

2021-08-13 Thread Jira
Ingo Bürk created FLINK-23757: - Summary: Support JSON methods in pyFlink Key: FLINK-23757 URL: https://issues.apache.org/jira/browse/FLINK-23757 Project: Flink Issue Type: Sub-task Comp