[jira] [Commented] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361467#comment-17361467 ] Chesnay Schepler commented on FLINK-22908: -- master: f52b2d4d78a3b6facc2af5cc589

[jira] [Comment Edited] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361467#comment-17361467 ] Chesnay Schepler edited comment on FLINK-22908 at 6/11/21, 7:05 AM: --

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22908: - Affects Version/s: (was: 1.12.4) > FileExecutionGraphInfoStoreTest.testPutSuspendedJ

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22908: - Fix Version/s: (was: 1.12.5) > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOn

[jira] [Closed] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22908. Resolution: Fixed > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown f

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22908: - Summary: FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wa

[jira] [Reopened] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-22908: -- > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should > wait unti

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22908: - Fix Version/s: 1.12.5 > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShut

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22908: - Affects Version/s: 1.12.4 > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnCluster

[jira] [Updated] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-22954: -- Affects Version/s: 1.12.2 > Don't support consuming update and delete changes when use table function

[jira] [Updated] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-22954: -- Affects Version/s: (was: 1.12.2) 1.12.0 > Don't support consuming update an

[jira] [Created] (FLINK-22971) Initialization of Testcontainers unstable on Azure

Xintong Song created FLINK-22971: Summary: Initialization of Testcontainers unstable on Azure Key: FLINK-22971 URL: https://issues.apache.org/jira/browse/FLINK-22971 Project: Flink Issue Type

[jira] [Closed] (FLINK-22419) testScheduleRunAsync fail

[ https://issues.apache.org/jira/browse/FLINK-22419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22419. Resolution: Fixed 1.12: e9e8d1c630f714b802b08ed33d2062c098e40290 > testScheduleRunAsync fail > --

[jira] [Commented] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361500#comment-17361500 ] JasonLee commented on FLINK-22963: -- [~xintongsong] Hi Xitong, I have completed the mod

[jira] [Closed] (FLINK-22744) Simplify TableEnvironment.create()

[ https://issues.apache.org/jira/browse/FLINK-22744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22744. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in 1.14.0: commit 6fac6e4085f706c29d3f07b15b

[jira] [Created] (FLINK-22972) Deprecate/Remove StreamOperator#dispose method

Dawid Wysakowicz created FLINK-22972: Summary: Deprecate/Remove StreamOperator#dispose method Key: FLINK-22972 URL: https://issues.apache.org/jira/browse/FLINK-22972 Project: Flink Issue

[jira] [Commented] (FLINK-22878) Allow placeholder options in format factories

[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361508#comment-17361508 ] Nicholas Jiang commented on FLINK-22878: [~twalthr], `ReadableConfig` has no `se

[jira] [Commented] (FLINK-22878) Allow placeholder options in format factories

[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361513#comment-17361513 ] Timo Walther commented on FLINK-22878: -- [~nicholasjiang] sorry this was just a copy

[jira] [Comment Edited] (FLINK-22878) Allow placeholder options in format factories

[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360719#comment-17360719 ] Timo Walther edited comment on FLINK-22878 at 6/11/21, 7:52 AM: --

[jira] [Commented] (FLINK-22959) Keep the job jar files on JobManager

[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361518#comment-17361518 ] Till Rohrmann commented on FLINK-22959: --- Thanks for reporting this issue [~luke123

[jira] [Commented] (FLINK-22971) Initialization of Testcontainers unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361517#comment-17361517 ] Dawid Wysakowicz commented on FLINK-22971: -- Most probably could be fixed via FL

[jira] [Commented] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361523#comment-17361523 ] Till Rohrmann commented on FLINK-22965: --- Can you make sure that the JobManager pro

[jira] [Commented] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361526#comment-17361526 ] Chesnay Schepler commented on FLINK-22965: -- I'm more curious about what is actu

[jira] [Assigned] (FLINK-22927) Exception on JobClient.get_job_status().result()

[ https://issues.apache.org/jira/browse/FLINK-22927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-22927: Assignee: Huang Xingbo > Exception on JobClient.get_job_status().result() > -

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361526#comment-17361526 ] Chesnay Schepler edited comment on FLINK-22965 at 6/11/21, 8:02 AM: --

[jira] [Closed] (FLINK-18670) Add (statefun-)docker repos to community page

[ https://issues.apache.org/jira/browse/FLINK-18670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18670. Resolution: Fixed asf-site: 71244b98fe2d870d56f8068f67d3b0c115f4f1bc > Add (statefun-)doc

[jira] [Commented] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361540#comment-17361540 ] Bhagi commented on FLINK-22965: --- x.x.66.160 is the ip address of the old pod...I also not

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 8:25 AM: - x.x.66

[jira] [Closed] (FLINK-20025) Add flink-docker and flink-statefun-docker to repository overview page

[ https://issues.apache.org/jira/browse/FLINK-20025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20025. Resolution: Duplicate > Add flink-docker and flink-statefun-docker to repository overview

[jira] [Created] (FLINK-22973) Provide benchmark for unaligned checkpoints performance

Piotr Nowojski created FLINK-22973: -- Summary: Provide benchmark for unaligned checkpoints performance Key: FLINK-22973 URL: https://issues.apache.org/jira/browse/FLINK-22973 Project: Flink I

[jira] [Updated] (FLINK-20388) Supports users setting operators' metrics name

[ https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20388: Priority: Major (was: Minor) > Supports users setting operators' metrics name > -

[jira] [Updated] (FLINK-20388) Supports users setting operators' metrics name

[ https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20388: Labels: (was: auto-deprioritized-major) > Supports users setting operators' metrics name > -

[jira] [Commented] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-22197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361559#comment-17361559 ] Dawid Wysakowicz commented on FLINK-22197: -- That has not happened in a while. I

[jira] [Closed] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-22197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22197. Resolution: Fixed > UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail

[jira] [Assigned] (FLINK-22972) Deprecate/Remove StreamOperator#dispose method

[ https://issues.apache.org/jira/browse/FLINK-22972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22972: Assignee: Dawid Wysakowicz > Deprecate/Remove StreamOperator#dispose method > ---

[jira] [Commented] (FLINK-22971) Initialization of Testcontainers unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361564#comment-17361564 ] Xintong Song commented on FLINK-22971: -- Exactly. Thanks for the pointer. I wasn't a

[jira] [Created] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

tinawenqiao created FLINK-22974: --- Summary: No execution checkpointing config desc in flink-conf.yaml Key: FLINK-22974 URL: https://issues.apache.org/jira/browse/FLINK-22974 Project: Flink Issu

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:17 AM: - Hi Til

[jira] [Updated] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22965: -- Attachment: flink issue with jm log.txt > Association with remote system has failed, address is now gated > --

[jira] [Updated] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tinawenqiao updated FLINK-22974: Description: We found that there is no parameter description for execution checkpointing in flink

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:18 AM: - Hi Til

[jira] [Updated] (FLINK-22972) Deprecate/Remove StreamOperator#dispose method

[ https://issues.apache.org/jira/browse/FLINK-22972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22972: - Description: As discussed in the ML thread (e.g. https://lists.apache.org/thread.html/r

[jira] [Updated] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tinawenqiao updated FLINK-22974: Description: We found that there is no parameter description for execution checkpointing in flink

[jira] [Updated] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tinawenqiao updated FLINK-22974: Description: We found that there is no parameter description for execution checkpointing in flink

[jira] [Commented] (FLINK-22617) Add log when create bulk format

[ https://issues.apache.org/jira/browse/FLINK-22617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361568#comment-17361568 ] hehuiyuan commented on FLINK-22617: --- Hi  [~luoyuxia],    , i am willing to do it. > A

[jira] [Commented] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361569#comment-17361569 ] Xintong Song commented on FLINK-22963: -- [~jasonlee1017], Welcome to the community,

[jira] [Commented] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361570#comment-17361570 ] Guokuai Huang commented on FLINK-22946: --- [~zjwang] [~roman_khachatryan] [~arvid he

[jira] [Commented] (FLINK-11622) Translate the "Command-Line Interface" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361571#comment-17361571 ] pierrexiong commented on FLINK-11622: - Hi [~jark]，I found that the work was not comp

[jira] [Updated] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22965: -- Attachment: JM-log-debug-mode.log TM-log-debug-mode.log > Association with remote system has f

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:36 AM: - Hi Til

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:38 AM: - Hi Til

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-22969: --- Labels: starter (was: ) > Validate the topic is not null or empty string when create kafka

[jira] [Commented] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361586#comment-17361586 ] Timo Walther commented on FLINK-22968: -- [~DaChun777] {{toAppendStream}} is soft-dep

[jira] [Comment Edited] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361467#comment-17361467 ] Chesnay Schepler edited comment on FLINK-22908 at 6/11/21, 10:07 AM: -

[jira] [Closed] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22908. Resolution: Fixed > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown s

[jira] [Comment Edited] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361586#comment-17361586 ] Timo Walther edited comment on FLINK-22968 at 6/11/21, 10:12 AM: -

[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.

[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361588#comment-17361588 ] Roc Marshal commented on FLINK-22885: - For the time being, it would be feasible to s

[jira] [Updated] (FLINK-22015) SQL filter containing OR and IS NULL will produce an incorrect result.

[ https://issues.apache.org/jira/browse/FLINK-22015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22015: --- Fix Version/s: 1.12.5 > SQL filter containing OR and IS NULL will produce an incorrect result. > ---

[jira] [Commented] (FLINK-22015) SQL filter containing OR and IS NULL will produce an incorrect result.

[ https://issues.apache.org/jira/browse/FLINK-22015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361592#comment-17361592 ] Kurt Young commented on FLINK-22015: also fixed in 1.12.5: faf7cc43beebce3fee528ec56

[jira] [Updated] (FLINK-16356) Some dependencies contain CVEs

[ https://issues.apache.org/jira/browse/FLINK-16356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16356: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-16332) Support un-ordered mode for async lookup join

[ https://issues.apache.org/jira/browse/FLINK-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16332: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-16333) After exiting from the command line client, the process still exists

[ https://issues.apache.org/jira/browse/FLINK-16333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16333: --- Labels: auto-deprioritized-critical auto-deprioritized-major (was: auto-deprioritized-cri

[jira] [Updated] (FLINK-16568) Cannot call Hive UDAF that requires constant arguments

[ https://issues.apache.org/jira/browse/FLINK-16568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16568: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16582: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[jira] [Updated] (FLINK-16528) Support Limit push down for Kafka streaming sources

[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16528: --- Labels: auto-deprioritized-major usability (was: stale-major usability) Priority: Mino

[jira] [Updated] (FLINK-16310) Javadoc of AppendingState.get() contradicts with behavior of UserFacingListState

[ https://issues.apache.org/jira/browse/FLINK-16310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16310: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-16305) FlinkYarnSessionClI ignores target executor and uses yarn-session if YARN properties file is present

[ https://issues.apache.org/jira/browse/FLINK-16305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16305: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-16193) Improve error messaging when a key is assigned to the wrong key group range

[ https://issues.apache.org/jira/browse/FLINK-16193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16193: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-10518) Inefficient design in ContinuousFileMonitoringFunction

[ https://issues.apache.org/jira/browse/FLINK-10518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10518: --- Labels: Source:FileSystem auto-unassigned stale-major (was: Source:FileSystem auto-unassign

[jira] [Updated] (FLINK-16032) Depends on core classifier hive-exec in hive connector

[ https://issues.apache.org/jira/browse/FLINK-16032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16032: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major) P

[jira] [Updated] (FLINK-16294) Support to create non-existed table in database automatically when writing data to JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16294: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available usability (was: a

[jira] [Updated] (FLINK-10568) Show correct time attributes when calling Table.getSchema()

[ https://issues.apache.org/jira/browse/FLINK-10568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10568: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-10667) Clean up Scala 2.10 remnants

[ https://issues.apache.org/jira/browse/FLINK-10667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10667: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-16043) Support non-BMP Unicode for JsonRowSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-16043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16043: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was: auto-unassi

[jira] [Updated] (FLINK-10684) Improve the CSV reading process

[ https://issues.apache.org/jira/browse/FLINK-10684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10684: --- Labels: CSV stale-major (was: CSV) I am the [Flink Jira Bot|https://github.com/apache/flink

[jira] [Updated] (FLINK-16175) Add config option to switch case sensitive for column names in SQL

[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16175: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available usability (was: a

[jira] [Updated] (FLINK-10576) Introduce Machine/Node/TM health management

[ https://issues.apache.org/jira/browse/FLINK-10576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10576: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-16050) Add Attempt Information

[ https://issues.apache.org/jira/browse/FLINK-16050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16050: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-10515) Improve tokenisation of program args passed as string

[ https://issues.apache.org/jira/browse/FLINK-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10515: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner

[ https://issues.apache.org/jira/browse/FLINK-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16143: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-10688) Remove flink-table dependencies from flink-connectors

[ https://issues.apache.org/jira/browse/FLINK-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10688: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-10476) Change related ProcessFunction to KeyedProcessFunction in Sql/Table-api

[ https://issues.apache.org/jira/browse/FLINK-10476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10476: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-10274) The stop-cluster.sh cannot stop cluster properly when there are multiple clusters running

[ https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10274: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned pull-reque

[jira] [Updated] (FLINK-10266) Web UI has outdated entry about externalized checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10266: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-10306) Support the display of log file from any position on webUI

[ https://issues.apache.org/jira/browse/FLINK-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10306: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-10448) VALUES clause is translated into a separate operator per value

[ https://issues.apache.org/jira/browse/FLINK-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10448: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-10489) Inconsistent window information for streams with EventTime characteristic

[ https://issues.apache.org/jira/browse/FLINK-10489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10489: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-10273) Access composite type fields after a function

[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10273: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned pull-reque

[jira] [Updated] (FLINK-10297) PostVersionedIOReadableWritable ignores result of InputStream.read(...)

[ https://issues.apache.org/jira/browse/FLINK-10297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10297: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-10294) Split MiniClusterResource to be usable in runtime/streaming-java/clients

[ https://issues.apache.org/jira/browse/FLINK-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10294: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Created] (FLINK-22975) Specify port or range for k8s service

Jun Zhang created FLINK-22975: - Summary: Specify port or range for k8s service Key: FLINK-22975 URL: https://issues.apache.org/jira/browse/FLINK-22975 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22976) Whether to consider adding config-option to control whether to exclude record.key value from record.value value

hehuiyuan created FLINK-22976: - Summary: Whether to consider adding config-option to control whether to exclude record.key value from record.value value Key: FLINK-22976 URL: https://issues.apache.org/jira/browse/F

[jira] [Assigned] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-22593: - Assignee: Anton Kalashnikov > SavepointITCase.testShouldAddEntropyToSavepointPa

[jira] [Updated] (FLINK-22973) Provide benchmark for unaligned checkpoint with timeouts

[ https://issues.apache.org/jira/browse/FLINK-22973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22973: --- Summary: Provide benchmark for unaligned checkpoint with timeouts (was: Provide benchmark f

[jira] [Updated] (FLINK-22973) Provide benchmark for unaligned checkpoint with timeouts

[ https://issues.apache.org/jira/browse/FLINK-22973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22973: --- Description: Provide some simple benchmark to test speed of the unaligned checkpoints with t

[jira] [Closed] (FLINK-22882) Tasks are blocked while emitting records

[ https://issues.apache.org/jira/browse/FLINK-22882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22882. -- Resolution: Duplicate > Tasks are blocked while emitting records > ---

[jira] [Assigned] (FLINK-22882) Tasks are blocked while emitting records

[ https://issues.apache.org/jira/browse/FLINK-22882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22882: -- Assignee: Piotr Nowojski > Tasks are blocked while emitting records > ---

[jira] [Closed] (FLINK-22934) Add instructions for using the " ' " escape syntax of SQL client

[ https://issues.apache.org/jira/browse/FLINK-22934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22934. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: ddfd5cac045c7aa0ad3561b08ed0215db397 >

[jira] [Commented] (FLINK-22882) Tasks are blocked while emitting records

[ https://issues.apache.org/jira/browse/FLINK-22882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361733#comment-17361733 ] Piotr Nowojski commented on FLINK-22882: This turned out to be another symptom o

[jira] [Commented] (FLINK-18438) TaskManager start failed

[ https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17361826#comment-17361826 ] Derek Moore commented on FLINK-18438: - [~JohnSiro], [~cr0566], [~xintongsong], et al

  1   2   >