[jira] [Closed] (FLINK-32647) Support config catalog store in python table environment

[ https://issues.apache.org/jira/browse/FLINK-32647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-32647. Fix Version/s: 2.0.0 Assignee: xuyang (was: Feng Jin) Resolution: Resolved Merged

[jira] [Closed] (FLINK-36175) Remove `register_table_source` and `register_table_sink` in python module

[ https://issues.apache.org/jira/browse/FLINK-36175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-36175. Resolution: Done Merged into master via f393270f2114c26c3f3fc6e000b6d27a64d3b180 > Remove `regist

[jira] [Closed] (FLINK-34616) python dist doesn't clean when open method construct resource

[ https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-34616. Fix Version/s: 1.19.1 1.18.2 Assignee: Jacky Lau Resolution: Fix

[jira] [Updated] (FLINK-34616) python dist doesn't clean when open method construct resource

[ https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34616: - Affects Version/s: 1.18.1 1.19.0 (was: 1.20.0)

[jira] [Updated] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34582: - Fix Version/s: 1.19.0 > release build tools lost the newly added py3.11 packages for mac > -

[jira] [Closed] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-34582. Resolution: Fixed Merged into master via a9d9bab47a6b2a9520f7d2b6f3791690df50e214 Merged into rel

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818269#comment-17818269 ] Xingbo Huang commented on FLINK-34202: -- I reviewed all the stages where timeouts oc

[jira] [Assigned] (FLINK-34202) python tests take suspiciously long in some of the cases

[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-34202: Assignee: Xingbo Huang > python tests take suspiciously long in some of the cases > -

[jira] [Commented] (FLINK-34195) PythonEnvUtils creates python environment instead of python3

[ https://issues.apache.org/jira/browse/FLINK-34195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809826#comment-17809826 ] Xingbo Huang commented on FLINK-34195: -- [~mapohl] Thanks for the great work. Since

[jira] [Updated] (FLINK-34077) Python Sphinx version error

[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34077: - Issue Type: Technical Debt (was: Bug) > Python Sphinx version error > -

[jira] [Updated] (FLINK-34077) Python Sphinx version error

[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34077: - Summary: Python Sphinx version error (was: Sphinx version needs upgrade) > Python Sphinx versio

[jira] [Resolved] (FLINK-34077) Sphinx version needs upgrade

[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang resolved FLINK-34077. -- Resolution: Fixed Merged into master via d2fbe464b1a353a7eb35926299d5c048647a3073 > Sphinx ve

[jira] [Commented] (FLINK-34077) Sphinx version needs upgrade

[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806595#comment-17806595 ] Xingbo Huang commented on FLINK-34077: -- Some sphinxcontrib(sphinxcontrib-applehelp,

[jira] [Assigned] (FLINK-34077) Sphinx version needs upgrade

[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-34077: Assignee: Xingbo Huang > Sphinx version needs upgrade > > >

[jira] [Closed] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-34012. Resolution: Fixed Merged into master via 639deeca33757c7380d474d43b8a70bacb84dd20 > Flink python

[jira] [Updated] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34012: - Issue Type: Technical Debt (was: Bug) > Flink python fails with can't read file > '/__w/2/s/f

[jira] [Assigned] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-34012: Assignee: Xingbo Huang > Flink python fails with can't read file > '/__w/2/s/flink-pyth

[jira] [Updated] (FLINK-33531) Nightly Python fails with NPE at metadataHandlerProvider on AZP (StreamDependencyTests.test_add_python_archive)

[ https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-33531: - Issue Type: Technical Debt (was: Bug) > Nightly Python fails with NPE at metadataHandlerProvide

[jira] [Resolved] (FLINK-33531) Nightly Python fails with NPE at metadataHandlerProvider on AZP (StreamDependencyTests.test_add_python_archive)

[ https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang resolved FLINK-33531. -- Fix Version/s: 1.19.0 Resolution: Fixed Merged into master via 942d23636b13df7a1182

[jira] [Commented] (FLINK-33531) Nightly Python fails with NPE at metadataHandlerProvider on AZP (StreamDependencyTests.test_add_python_archive)

[ https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787824#comment-17787824 ] Xingbo Huang commented on FLINK-33531: -- After doing some experiments, I came to the

[jira] [Assigned] (FLINK-33531) Nightly Python fails with NPE at metadataHandlerProvider on AZP (StreamDependencyTests.test_add_python_archive)

[ https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-33531: Assignee: Xingbo Huang > Nightly Python fails with NPE at metadataHandlerProvider on AZP

[jira] [Commented] (FLINK-33531) Nightly Python fails with NPE at metadataHandlerProvider on AZP (StreamDependencyTests.test_add_python_archive)

[ https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786676#comment-17786676 ] Xingbo Huang commented on FLINK-33531: -- I will take a look. This case only fails on

[jira] [Updated] (FLINK-32110) TM native memory leak when using time window in Pyflink ThreadMode

[ https://issues.apache.org/jira/browse/FLINK-32110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-32110: - Affects Version/s: (was: 1.16.1) > TM native memory leak when using time window in Pyflink T

[jira] [Closed] (FLINK-32110) TM native memory leak when using time window in Pyflink ThreadMode

[ https://issues.apache.org/jira/browse/FLINK-32110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-32110. Fix Version/s: 1.17.2 Resolution: Fixed Merged into master via 2f015eb899feb6e60a379a33baab

[jira] [Assigned] (FLINK-32110) TM native memory leak when using time window in Pyflink ThreadMode

[ https://issues.apache.org/jira/browse/FLINK-32110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-32110: Assignee: Yunjun Luo > TM native memory leak when using time window in Pyflink ThreadMode

[jira] [Closed] (FLINK-31726) PyFlink module java.base does not "opens java.lang" to unnamed module

[ https://issues.apache.org/jira/browse/FLINK-31726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-31726. Resolution: Not A Problem Flink doesn't support JDK 19, you can try to use jdk 8 or jdk 11. > PyF

[jira] [Updated] (FLINK-29421) Support python 3.10

[ https://issues.apache.org/jira/browse/FLINK-29421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29421: - Release Note: PyFlink 1.17 will support Python 3.10 and remove the support of Python 3.6 > Supp

[jira] [Commented] (FLINK-29421) Support python 3.10

[ https://issues.apache.org/jira/browse/FLINK-29421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703083#comment-17703083 ] Xingbo Huang commented on FLINK-29421: -- [~Peter_Howe] apache beam hasn't supported

[jira] [Updated] (FLINK-31524) StreamDependencyTests.test_add_python_file failed

[ https://issues.apache.org/jira/browse/FLINK-31524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-31524: - Issue Type: Technical Debt (was: Bug) > StreamDependencyTests.test_add_python_file failed > ---

[jira] [Assigned] (FLINK-31524) StreamDependencyTests.test_add_python_file failed

[ https://issues.apache.org/jira/browse/FLINK-31524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-31524: Assignee: Xingbo Huang > StreamDependencyTests.test_add_python_file failed >

[jira] [Updated] (FLINK-31524) StreamDependencyTests.test_add_python_file failed

[ https://issues.apache.org/jira/browse/FLINK-31524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-31524: - Priority: Major (was: Blocker) > StreamDependencyTests.test_add_python_file failed > --

[jira] [Commented] (FLINK-31524) StreamDependencyTests.test_add_python_file failed

[ https://issues.apache.org/jira/browse/FLINK-31524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17702985#comment-17702985 ] Xingbo Huang commented on FLINK-31524: -- [~mapohl] Thanks a lot for reporting this i

[jira] [Updated] (FLINK-30277) Allow PYTHONPATH of Python Worker configurable

[ https://issues.apache.org/jira/browse/FLINK-30277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-30277: - Issue Type: New Feature (was: Improvement) > Allow PYTHONPATH of Python Worker configurable > -

[jira] [Updated] (FLINK-30277) Allow PYTHONPATH of Python Worker configurable

[ https://issues.apache.org/jira/browse/FLINK-30277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-30277: - Affects Version/s: 1.18.0 (was: 1.16.0) > Allow PYTHONPATH of Python

[jira] [Closed] (FLINK-30277) Allow PYTHONPATH of Python Worker configurable

[ https://issues.apache.org/jira/browse/FLINK-30277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-30277. Fix Version/s: 1.18.0 Resolution: Fixed Merged into master via 2e0efe4e0723429e26ca04e2f61f

[jira] [Commented] (FLINK-30886) Content area is too narrow to show all content

[ https://issues.apache.org/jira/browse/FLINK-30886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685000#comment-17685000 ] Xingbo Huang commented on FLINK-30886: -- T he content that is too long needs to be v

[jira] [Updated] (FLINK-30886) Content area is too narrow to show all content

[ https://issues.apache.org/jira/browse/FLINK-30886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-30886: - Attachment: image-2023-02-07-10-12-09-237.png > Content area is too narrow to show all content >

[jira] [Commented] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653944#comment-17653944 ] Xingbo Huang commented on FLINK-26974: -- [~mapohl] Sure. I will take a look. > Pyth

[jira] [Closed] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29461. Fix Version/s: 1.17.0 1.16.1 Resolution: Fixed Merged into master via 4d

[jira] [Closed] (FLINK-30366) Python Group Agg failed in cleaning the idle state

[ https://issues.apache.org/jira/browse/FLINK-30366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-30366. Resolution: Fixed Merged into master via 72a70313b59352736514b4927a1dfadc2e8e4232 Merged into rel

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646050#comment-17646050 ] Xingbo Huang commented on FLINK-29461: -- [~mapohl] I have prepared a PR to make the

[jira] [Created] (FLINK-30366) Python Group Agg failed in cleaning the idle state

Xingbo Huang created FLINK-30366: Summary: Python Group Agg failed in cleaning the idle state Key: FLINK-30366 URL: https://issues.apache.org/jira/browse/FLINK-30366 Project: Flink Issue Type

[jira] [Closed] (FLINK-21223) Support to specify the input/output types of Python UDFs via string

[ https://issues.apache.org/jira/browse/FLINK-21223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-21223. Fix Version/s: 1.17.0 Resolution: Done Merged into master via 6cc00a707b238facbf5bf88a9fd72

[jira] [Closed] (FLINK-29155) Improve default config of grpcServer in Process Mode

[ https://issues.apache.org/jira/browse/FLINK-29155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29155. Fix Version/s: 1.17.0 1.16.1 1.15.4 Resolution: Fixed

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640473#comment-17640473 ] Xingbo Huang commented on FLINK-29461: -- [~mapohl] Sorry for the late reply, I will

[jira] [Created] (FLINK-30169) Adds version switcher in PyFlink API doc

Xingbo Huang created FLINK-30169: Summary: Adds version switcher in PyFlink API doc Key: FLINK-30169 URL: https://issues.apache.org/jira/browse/FLINK-30169 Project: Flink Issue Type: Sub-task

[jira] [Reopened] (FLINK-29833) Improve PyFlink support in Windows

[ https://issues.apache.org/jira/browse/FLINK-29833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reopened FLINK-29833: -- > Improve PyFlink support in Windows > -- > > Key:

[jira] [Closed] (FLINK-29833) Improve PyFlink support in Windows

[ https://issues.apache.org/jira/browse/FLINK-29833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29833. Resolution: Fixed > Improve PyFlink support in Windows > -- > >

[jira] [Updated] (FLINK-29421) Support python 3.10

[ https://issues.apache.org/jira/browse/FLINK-29421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29421: - Issue Type: New Feature (was: Bug) > Support python 3.10 > --- > >

[jira] [Assigned] (FLINK-30097) CachedDataStream java example in the document is not correct

[ https://issues.apache.org/jira/browse/FLINK-30097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-30097: Assignee: Xuannan Su > CachedDataStream java example in the document is not correct > ---

[jira] [Resolved] (FLINK-29479) Support whether using system PythonPath for PyFlink jobs

[ https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang resolved FLINK-29479. -- Fix Version/s: 1.15.3 1.16.1 Assignee: jackylau Resolution:

[jira] [Updated] (FLINK-29479) Support whether using system PythonPath for PyFlink jobs

[ https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29479: - Issue Type: Bug (was: Improvement) > Support whether using system PythonPath for PyFlink jobs >

[jira] [Updated] (FLINK-29677) Prevent dropping the current catalog

[ https://issues.apache.org/jira/browse/FLINK-29677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29677: - Fix Version/s: 1.17.0 1.16.1 > Prevent dropping the current catalog > ---

[jira] [Updated] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

[ https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29217: - Fix Version/s: 1.16.1 (was: 1.16.0) > CoordinatorEventsToStreamOperatorRe

[jira] [Updated] (FLINK-29733) Error Flink connector hive Test failing

[ https://issues.apache.org/jira/browse/FLINK-29733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29733: - Labels: pull-request-available test-stability (was: pull-request-available) > Error Flink conne

[jira] [Updated] (FLINK-29733) Error Flink connector hive Test failing

[ https://issues.apache.org/jira/browse/FLINK-29733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29733: - Component/s: Connectors / Hive > Error Flink connector hive Test failing > -

[jira] [Updated] (FLINK-29733) Error Flink connector hive Test failing

[ https://issues.apache.org/jira/browse/FLINK-29733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29733: - Affects Version/s: 1.17.0 > Error Flink connector hive Test failing > --

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622973#comment-17622973 ] Xingbo Huang commented on FLINK-29405: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622971#comment-17622971 ] Xingbo Huang commented on FLINK-24119: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622969#comment-17622969 ] Xingbo Huang commented on FLINK-29405: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29478) Flink sql Connector hive to support 3.1.3

[ https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622967#comment-17622967 ] Xingbo Huang commented on FLINK-29478: -- [https://dev.azure.com/apache-flink/apache-

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622965#comment-17622965 ] Xingbo Huang commented on FLINK-29387: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622964#comment-17622964 ] Xingbo Huang commented on FLINK-24119: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621470#comment-17621470 ] Xingbo Huang commented on FLINK-28766: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Comment Edited] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621469#comment-17621469 ] Xingbo Huang edited comment on FLINK-24119 at 10/21/22 3:39 AM: --

[jira] [Updated] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24119: - Fix Version/s: 1.16.1 (was: 1.16.0) > KafkaITCase.testTimestamps fails du

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621469#comment-17621469 ] Xingbo Huang commented on FLINK-24119: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-26402) MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBeforeInitializingFileSyste failed due to Container startup failed

[ https://issues.apache.org/jira/browse/FLINK-26402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620783#comment-17620783 ] Xingbo Huang commented on FLINK-26402: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-29468) Update jackson-bom to 2.13.4

[ https://issues.apache.org/jira/browse/FLINK-29468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29468: - Fix Version/s: 1.16.0 (was: 1.16.1) > Update jackson-bom to 2.13.4 >

[jira] [Updated] (FLINK-29638) Update jackson bom because of CVE-2022-42003

[ https://issues.apache.org/jira/browse/FLINK-29638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29638: - Fix Version/s: (was: 1.16.1) 1.16.0 > Update jackson bom because of CVE-2

[jira] [Updated] (FLINK-29613) Wrong message size assertion in Pulsar's batch message

[ https://issues.apache.org/jira/browse/FLINK-29613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29613: - Fix Version/s: 1.16.0 (was: 1.16.1) > Wrong message size assertion in Pul

[jira] [Updated] (FLINK-29512) Align SubtaskCommittableManager checkpointId with CheckpointCommittableManagerImpl checkpointId during recovery

[ https://issues.apache.org/jira/browse/FLINK-29512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29512: - Fix Version/s: 1.16.0 (was: 1.16.1) > Align SubtaskCommittableManager che

[jira] [Updated] (FLINK-29509) Set correct subtaskId during recovery of committables

[ https://issues.apache.org/jira/browse/FLINK-29509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29509: - Fix Version/s: 1.16.0 (was: 1.16.1) > Set correct subtaskId during recove

[jira] [Updated] (FLINK-22243) Reactive Mode parallelism changes are not shown in the job graph visualization in the UI

[ https://issues.apache.org/jira/browse/FLINK-22243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-22243: - Fix Version/s: 1.16.0 (was: 1.16.1) > Reactive Mode parallelism changes a

[jira] [Updated] (FLINK-29504) Jar upload spec should define a schema

[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29504: - Fix Version/s: 1.16.0 (was: 1.16.1) > Jar upload spec should define a sch

[jira] [Updated] (FLINK-29408) HiveCatalogITCase failed with NPE

[ https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29408: - Fix Version/s: 1.16.0 (was: 1.17.0) (was: 1.16.1)

[jira] [Updated] (FLINK-29503) Add backpressureLevel field without hyphens

[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29503: - Fix Version/s: 1.16.0 (was: 1.16.1) > Add backpressureLevel field without

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29395: - Fix Version/s: 1.16.0 (was: 1.16.1) > [Kinesis][EFO] Issue using EFO cons

[jira] [Updated] (FLINK-29562) JM/SQl gateway OpenAPI specs should have different titles

[ https://issues.apache.org/jira/browse/FLINK-29562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29562: - Fix Version/s: 1.16.0 (was: 1.16.1) > JM/SQl gateway OpenAPI specs should

[jira] [Updated] (FLINK-29483) flink python udf arrow in thread model bug

[ https://issues.apache.org/jira/browse/FLINK-29483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29483: - Fix Version/s: 1.16.0 (was: 1.16.1) > flink python udf arrow in thread mo

[jira] [Updated] (FLINK-29532) Update Pulsar dependency to 2.10.1

[ https://issues.apache.org/jira/browse/FLINK-29532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29532: - Fix Version/s: 1.16.0 (was: 1.16.1) > Update Pulsar dependency to 2.10.1

[jira] [Updated] (FLINK-29500) InitializeOnMaster uses wrong parallelism with AdaptiveScheduler

[ https://issues.apache.org/jira/browse/FLINK-29500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29500: - Fix Version/s: 1.16.0 (was: 1.16.1) > InitializeOnMaster uses wrong paral

[jira] [Updated] (FLINK-26469) Adaptive job shows error in WebUI when not enough resource are available

[ https://issues.apache.org/jira/browse/FLINK-26469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-26469: - Fix Version/s: 1.16.0 (was: 1.16.1) > Adaptive job shows error in WebUI w

[jira] [Updated] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

[ https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29476: - Fix Version/s: 1.16.0 (was: 1.16.1) > Kinesis Connector retry mechanism n

[jira] [Updated] (FLINK-29552) Fix documentation usage examples for DAYOFYEAR, DAYOFMONTH, and DAYOFWEEK functions

[ https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29552: - Fix Version/s: 1.16.0 (was: 1.16.1) > Fix documentation usage examples fo

[jira] [Commented] (FLINK-29622) KerberosDelegationTokenManager fails to load DelegationTokenProvider due to NoClassDefFoundError in various ITCases

[ https://issues.apache.org/jira/browse/FLINK-29622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620303#comment-17620303 ] Xingbo Huang commented on FLINK-29622: -- [~mbalassi] Thanks a lot for the informatio

[jira] [Commented] (FLINK-28424) JdbcExactlyOnceSinkE2eTest hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-28424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620101#comment-17620101 ] Xingbo Huang commented on FLINK-28424: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Closed] (FLINK-29681) Python side-output operator not generated in some cases

[ https://issues.apache.org/jira/browse/FLINK-29681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29681. Fix Version/s: (was: 1.17.0) Assignee: Juntao Hu Resolution: Fixed Merged into

[jira] [Closed] (FLINK-29641) SortMergeResultPartitionReadSchedulerTest.testCreateSubpartitionReader

[ https://issues.apache.org/jira/browse/FLINK-29641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29641. Fix Version/s: 1.16.0 (was: 1.17.0) (was: 1.16.1)

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619963#comment-17619963 ] Xingbo Huang commented on FLINK-29419: -- Temporarily disabled `HybridShuffleITCase`

[jira] [Comment Edited] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619963#comment-17619963 ] Xingbo Huang edited comment on FLINK-29419 at 10/19/22 3:23 AM: --

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619346#comment-17619346 ] Xingbo Huang commented on FLINK-29427: -- [https://dev.azure.com/apache-flink/apache-

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619342#comment-17619342 ] Xingbo Huang commented on FLINK-28440: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619341#comment-17619341 ] Xingbo Huang commented on FLINK-29419: -- [https://dev.azure.com/apache-flink/apache-

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619340#comment-17619340 ] Xingbo Huang commented on FLINK-29405: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-29405) InputFormatCacheLoaderTest is unstable

[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29405: - Labels: pull-request-available test-stability (was: pull-request-available) > InputFormatCacheL

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619333#comment-17619333 ] Xingbo Huang commented on FLINK-29387: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-28424) JdbcExactlyOnceSinkE2eTest hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-28424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619330#comment-17619330 ] Xingbo Huang commented on FLINK-28424: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Closed] (FLINK-29658) LocalTime support when converting Table to DataStream in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-29658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29658. Assignee: Juntao Hu Resolution: Fixed Merged into release-1.15 via 5e4da2cc868b28bfdadd689f2

[jira] [Closed] (FLINK-29648) "LocalDateTime not supported" error when retrieving Java TypeInformation from PyFlink

[ https://issues.apache.org/jira/browse/FLINK-29648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29648. Resolution: Fixed Merged into master via ef0489b5131d03112d8a4ef11962a2d1ba6a9f54 Merged into rel

  1   2   3   4   5   >