[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] [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=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:38 AM: - Hi Till and Chesnay

[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=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:36 AM: - Hi Till and Chesnay

[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

[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=17361571#comment-17361571 ] pierrexiong commented on FLINK-11622: - Hi [~jark]，I found that the work was not completed yet. Can

[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=17361570#comment-17361570 ] Guokuai Huang commented on FLINK-22946: --- [~zjwang] [~roman_khachatryan] [~arvid heise] [~ym]

[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=17361569#comment-17361569 ] Xintong Song commented on FLINK-22963: -- [~jasonlee1017], Welcome to the community, and thanks for

[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=17361568#comment-17361568 ] hehuiyuan commented on FLINK-22617: --- Hi  [~luoyuxia],    , i am willing to do it. > Add log when

[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

[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

[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.

[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=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:18 AM: - Hi Till and Chesnay

[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

[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=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:17 AM: - Hi Till & x.x.66.160

[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

[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=17361564#comment-17361564 ] Xintong Song commented on FLINK-22971: -- Exactly. Thanks for the pointer. I wasn't aware of

[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] [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

[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=17361559#comment-17361559 ] Dawid Wysakowicz commented on FLINK-22197: -- That has not happened in a while. I can't see any

[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] [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] [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

[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] [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=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 8:25 AM: - x.x.66.160 is the ip

[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=17361540#comment-17361540 ] Bhagi commented on FLINK-22965: --- x.x.66.160 is the ip address of the old pod...I also not

[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

[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=17361526#comment-17361526 ] Chesnay Schepler edited comment on FLINK-22965 at 6/11/21, 8:02 AM:

[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] [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=17361526#comment-17361526 ] Chesnay Schepler commented on FLINK-22965: -- I'm more curious about what is actually running on

[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=17361523#comment-17361523 ] Till Rohrmann commented on FLINK-22965: --- Can you make sure that the JobManager process can reach

[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=17361517#comment-17361517 ] Dawid Wysakowicz commented on FLINK-22971: -- Most probably could be fixed via FLINK-22386 >

[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=17361518#comment-17361518 ] Till Rohrmann commented on FLINK-22959: --- Thanks for reporting this issue [~luke123]. It is indeed

[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=17360719#comment-17360719 ] Timo Walther edited comment on FLINK-22878 at 6/11/21, 7:52 AM: We found

[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=17361513#comment-17361513 ] Timo Walther commented on FLINK-22878: -- [~nicholasjiang] sorry this was just a copy-paste error. It

[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=17361508#comment-17361508 ] Nicholas Jiang commented on FLINK-22878: [~twalthr], `ReadableConfig` has no `set` API and

[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] [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

[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=17361500#comment-17361500 ] JasonLee commented on FLINK-22963: -- [~xintongsong] Hi Xitong, I have completed the modification of

[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] [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

[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

[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] [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

[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 >

[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 >

[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

[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

[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) >

[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) >

[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=17361467#comment-17361467 ] Chesnay Schepler edited comment on FLINK-22908 at 6/11/21, 7:05 AM:

[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=17361467#comment-17361467 ] Chesnay Schepler commented on FLINK-22908: -- master: f52b2d4d78a3b6facc2af5cc589b3fcbeaa12826 >

[jira] [Assigned] (FLINK-22788) Code of equals method grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-22788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-22788: - Assignee: Ingo Bürk > Code of equals method grows beyond 64 KB >

[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: -- Description: {code:java} Exception in thread "main" org.apache.flink.table.api.TableException: Table

[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: -- Description: {code:java} Exception in thread "main" org.apache.flink.table.api.TableException: Table

[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: -- Description: {code:java} Exception in thread "main" org.apache.flink.table.api.TableException: Table

[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: -- Description: {code:java} Exception in thread "main" org.apache.flink.table.api.TableException: Table

[jira] [Comment Edited] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361442#comment-17361442 ] Leonard Xu edited comment on FLINK-22970 at 6/11/21, 6:22 AM: -- [~tonywei]

[jira] [Commented] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361442#comment-17361442 ] Leonard Xu commented on FLINK-22970: minor: TO_TIMESTAMP doesn't use any time zone information. >

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

[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361437#comment-17361437 ] Ingo Bürk commented on FLINK-22885: --- Have we ever considered just supporting INFORMATION_SCHEMA? As

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361438#comment-17361438 ] Xintong Song commented on FLINK-22198: --

<    1   2