[jira] [Comment Edited] (FLINK-23826) Verify optimized scheduler performance for large-scale jobs

[ https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420218#comment-17420218 ] Zhu Zhu edited comment on FLINK-23826 at 9/26/21, 6:56 AM: --- He

[jira] [Comment Edited] (FLINK-23826) Verify optimized scheduler performance for large-scale jobs

[ https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420218#comment-17420218 ] Zhu Zhu edited comment on FLINK-23826 at 9/26/21, 6:48 AM: --- He

[jira] [Closed] (FLINK-23826) Verify optimized scheduler performance for large-scale jobs

[ https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-23826. --- Resolution: Done > Verify optimized scheduler performance for large-scale jobs > ---

[jira] [Commented] (FLINK-23826) Verify optimized scheduler performance for large-scale jobs

[ https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420218#comment-17420218 ] Zhu Zhu commented on FLINK-23826: - Here is the benchmark results of release-1.14 v.s. re

[GitHub] [flink] curcur commented on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-927244429 rebase on master -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comm

[jira] [Updated] (FLINK-23826) Verify optimized scheduler performance for large-scale jobs

[ https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-23826: Description: This ticket is used to verify the result of FLINK-21110. It should check if large scale jobs'

[GitHub] [flink] RocMarshal commented on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal commented on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-927241423 @alpinegizmo Could you help me to review this PR ? Thank you very much. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] ruanhang1993 closed pull request #17134: [FLINK-24108][docs] Kafka documentation

ruanhang1993 closed pull request #17134: URL: https://github.com/apache/flink/pull/17134 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-un

[GitHub] [flink] ruanhang1993 commented on pull request #17134: [FLINK-24108][docs] Kafka documentation

ruanhang1993 commented on pull request #17134: URL: https://github.com/apache/flink/pull/17134#issuecomment-927239206 duplicated to #17310 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the sp

[GitHub] [flink] flinkbot edited a comment on pull request #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition

flinkbot edited a comment on pull request #17311: URL: https://github.com/apache/flink/pull/17311#issuecomment-921772935 ## CI report: * fc672357fbf257644939e084ab7786b77cac30ed Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition

flinkbot edited a comment on pull request #17311: URL: https://github.com/apache/flink/pull/17311#issuecomment-921772935 ## CI report: * fc672357fbf257644939e084ab7786b77cac30ed Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17297: [FLINK-24307][docs] Some lines in Scala code example end with unneces…

flinkbot edited a comment on pull request #17297: URL: https://github.com/apache/flink/pull/17297#issuecomment-920679598 ## CI report: * c0a8ee0f0c87ba1a0d7b48cfe704db4fb9ed4d05 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition

flinkbot edited a comment on pull request #17311: URL: https://github.com/apache/flink/pull/17311#issuecomment-921772935 ## CI report: * fc672357fbf257644939e084ab7786b77cac30ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zoltar9264 commented on pull request #17292: [FLINK-24274][docs] Wrong parameter order in documentation of State Processor API

zoltar9264 commented on pull request #17292: URL: https://github.com/apache/flink/pull/17292#issuecomment-927226698 Kindly ping @sjwiesman -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the sp

[GitHub] [flink] xuyangzhong commented on pull request #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition

xuyangzhong commented on pull request #17311: URL: https://github.com/apache/flink/pull/17311#issuecomment-927225297 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the speci

[jira] [Closed] (FLINK-23950) Revert FLINK-23738 (i.e. unhide config, API, docs)

[ https://issues.apache.org/jira/browse/FLINK-23950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei closed FLINK-23950. Resolution: Fixed merged commit  [{{be581bc}}|https://github.com/apache/flink/commit/be581bc8a8da1bb757143

[jira] [Updated] (FLINK-24375) The name of flush thread in RecordWriter should contain subtask index

[ https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-24375: --- Affects Version/s: 1.14.0 > The name of flush thread in RecordWriter should contain subtask index >

[jira] [Created] (FLINK-24375) The name of flush thread in RecordWriter should contain subtask index

Lijie Wang created FLINK-24375: -- Summary: The name of flush thread in RecordWriter should contain subtask index Key: FLINK-24375 URL: https://issues.apache.org/jira/browse/FLINK-24375 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17297: [FLINK-24307][docs] Some lines in Scala code example end with unneces…

flinkbot edited a comment on pull request #17297: URL: https://github.com/apache/flink/pull/17297#issuecomment-920679598 ## CI report: * 11528d03f4ebc5f0664ddb12ab3cd3715088af52 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur merged pull request #17287: [FLINK-23950] Revert [FLINK-23738][state] to re-enable ChangelogBackend

curcur merged pull request #17287: URL: https://github.com/apache/flink/pull/17287 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] curcur commented on pull request #17287: [FLINK-23950] Revert [FLINK-23738][state] to re-enable ChangelogBackend

curcur commented on pull request #17287: URL: https://github.com/apache/flink/pull/17287#issuecomment-927220296 LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To u

[GitHub] [flink] lirui-apache commented on pull request #17245: [FLINK-23316][Table SQL/Ecosystem] Add tests for custom PartitionCommitPolicy

lirui-apache commented on pull request #17245: URL: https://github.com/apache/flink/pull/17245#issuecomment-927218964 Thanks @JackWangCS for updating, LGTM. Please take a look at the CI failure. Alternatively, if your own azure pipeline has passed, please post the link here. Either way, we

[jira] [Closed] (FLINK-24271) Add document for special char in JSON_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24271. Fix Version/s: 1.15.0 Resolution: Fixed [~liliwei] of course. Merged via master: 9bcc10bd6

[GitHub] [flink] JingsongLi merged pull request #17275: [FLINK-24271][docs] Add document for special char in JSON_VALUE and JSON_QUERY

JingsongLi merged pull request #17275: URL: https://github.com/apache/flink/pull/17275 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsu

[GitHub] [flink] flinkbot edited a comment on pull request #17297: [FLINK-24307][docs] Some lines in Scala code example end with unneces…

flinkbot edited a comment on pull request #17297: URL: https://github.com/apache/flink/pull/17297#issuecomment-920679598 ## CI report: * 11528d03f4ebc5f0664ddb12ab3cd3715088af52 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

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

[jira] [Commented] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420187#comment-17420187 ] Xintong Song commented on FLINK-23493: -- [~hxbks2ks], Are you still looking into thi

[jira] [Commented] (FLINK-23493) python tests hang on Azure

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

[jira] [Commented] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure

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

[jira] [Commented] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure

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

[jira] [Commented] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420183#comment-17420183 ] Xintong Song commented on FLINK-24374: -- cc [~dwysakowicz] > ManualCheckpointITCase

[jira] [Created] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure

Xintong Song created FLINK-24374: Summary: ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure Key: FLINK-24374 URL: https://issues.apache.org/jira/browse/FLINK-24374 Project: Fli

[GitHub] [flink] paul8263 commented on pull request #17297: [FLINK-24307][docs] Some lines in Scala code example end with unneces…

paul8263 commented on pull request #17297: URL: https://github.com/apache/flink/pull/17297#issuecomment-927213829 Hi @slinkydeveloper , Those enclosing brackets and indentation issues were fixed. Thanks for reviewing. -- This is an automated message from the Apache Git Service. To res

[GitHub] [flink] leonardBang commented on pull request #17353: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs

leonardBang commented on pull request #17353: URL: https://github.com/apache/flink/pull/17353#issuecomment-927208906 Thanks @sjwiesman for the contribution, looks good to me both English and Chinese parts. -- This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [flink] RocMarshal commented on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

RocMarshal commented on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-927206639 @Airblader Thank you for your comments. I made some changes based on your suggestions. Please let me know what's your opinion. -- This is an automated message from the Apac

[jira] [Updated] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure

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

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 374b1e58d31ae1eb6b7ada320970a62fad252594 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dugenkui03 closed pull request #13277: [FLINK-19089][Connectors / Kafka] Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue

dugenkui03 closed pull request #13277: URL: https://github.com/apache/flink/pull/13277 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsu

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 058c1afa8429213aa02672388d2e309a5ff7c510 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 471fd7fb6373ea0f2ebfe19d5ee1f7e097bc25b8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 471fd7fb6373ea0f2ebfe19d5ee1f7e097bc25b8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 471fd7fb6373ea0f2ebfe19d5ee1f7e097bc25b8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 471fd7fb6373ea0f2ebfe19d5ee1f7e097bc25b8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] RocMarshal commented on a change in pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

RocMarshal commented on a change in pull request #17352: URL: https://github.com/apache/flink/pull/17352#discussion_r716039287 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java ## @@ -1441,6 +1468,59 @@ p

[GitHub] [flink] RocMarshal commented on a change in pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

RocMarshal commented on a change in pull request #17352: URL: https://github.com/apache/flink/pull/17352#discussion_r716039173 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/catalog/CatalogViewITCase.scala ## @@ -307,6 +307,91 @@ cl

[GitHub] [flink] RocMarshal commented on a change in pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

RocMarshal commented on a change in pull request #17352: URL: https://github.com/apache/flink/pull/17352#discussion_r716039126 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/catalog/CatalogViewITCase.scala ## @@ -307,6 +307,91 @@ cl

[GitHub] [flink] flinkbot edited a comment on pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

flinkbot edited a comment on pull request #17344: URL: https://github.com/apache/flink/pull/17344#issuecomment-925952696 ## CI report: * 4ad29008075dc93463c07ce098cd7b1086104d7b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result