[jira] [Updated] (FLINK-23815) Separate the concerns of PendingCheckpoint and CheckpointPlan

[ https://issues.apache.org/jira/browse/FLINK-23815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23815: Parent: (was: FLINK-23883) Issue Type: Improvement (was: Sub-task) > Separate the concerns of

[jira] [Updated] (FLINK-23815) Separate the concerns of PendingCheckpoint and CheckpointPlan

[ https://issues.apache.org/jira/browse/FLINK-23815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23815: Parent: FLINK-26113 Issue Type: Sub-task (was: Improvement) > Separate the concerns of PendingChe

[jira] [Updated] (FLINK-23883) (1.15) Follow up tasks and code improvements for FLIP-147

[ https://issues.apache.org/jira/browse/FLINK-23883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23883: Summary: (1.15) Follow up tasks and code improvements for FLIP-147 (was: Follow up tasks and code improve

[jira] [Created] (FLINK-26113) (1.16) Follow up tasks and code refactoring for FLIP-147

Yun Gao created FLINK-26113: --- Summary: (1.16) Follow up tasks and code refactoring for FLIP-147 Key: FLINK-26113 URL: https://issues.apache.org/jira/browse/FLINK-26113 Project: Flink Issue Type: Bu

[jira] [Updated] (FLINK-11813) Standby per job mode Dispatchers don't know job's JobSchedulingStatus

[ https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-11813: -- Release Note: The issue of re-submitting a job in Application Mode when the job finished but f

[GitHub] [flink] flinkbot edited a comment on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

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

[jira] [Updated] (FLINK-26112) Port getEndpoint method to the specific service type subclass

[ https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26112: --- Description: In the [FLINK-20830 |https://issues.apache.org/jira/projects/FLINK/issues/FLINK-20830]we introd

[jira] [Created] (FLINK-26112) Port getEndpoint method to the specific service type subclass

Aitozi created FLINK-26112: -- Summary: Port getEndpoint method to the specific service type subclass Key: FLINK-26112 URL: https://issues.apache.org/jira/browse/FLINK-26112 Project: Flink Issue Type

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491843#comment-17491843 ] Yun Gao commented on FLINK-23391: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-25431) Implement file-based JobResultStore

[ https://issues.apache.org/jira/browse/FLINK-25431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-25431: -- Release Note: Introduces a file-based version of the JobResultStore with new configuration par

[jira] [Created] (FLINK-26111) ElasticsearchSinkITCase.testElasticsearchSink failed on azure

Yun Gao created FLINK-26111: --- Summary: ElasticsearchSinkITCase.testElasticsearchSink failed on azure Key: FLINK-26111 URL: https://issues.apache.org/jira/browse/FLINK-26111 Project: Flink Issue Ty

[jira] [Updated] (FLINK-26111) ElasticsearchSinkITCase.testElasticsearchSink failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26111: Labels: test-stability (was: ) > ElasticsearchSinkITCase.testElasticsearchSink failed on azure >

[jira] [Updated] (FLINK-25431) Implement file-based JobResultStore

[ https://issues.apache.org/jira/browse/FLINK-25431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-25431: -- Release Note: Introduces a file-based version of the JobResultStore with new configuration par

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * 026018918ca60db860e0a0dd6454ef04a1f1861e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26110) AvroStreamingFileSinkITCase failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26110: Labels: test-stability (was: ) > AvroStreamingFileSinkITCase failed on azure > --

[jira] [Created] (FLINK-26110) AvroStreamingFileSinkITCase failed on azure

Yun Gao created FLINK-26110: --- Summary: AvroStreamingFileSinkITCase failed on azure Key: FLINK-26110 URL: https://issues.apache.org/jira/browse/FLINK-26110 Project: Flink Issue Type: Bug C

[jira] [Commented] (FLINK-26107) CoordinatorEventsExactlyOnceITCase.test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491842#comment-17491842 ] Yun Gao commented on FLINK-26107: - Hi [~dmvk] could you also have a look at this issue a

[jira] [Commented] (FLINK-26108) CoordinatedSourceITCase.testEnumeratorCreationFails failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491839#comment-17491839 ] Yun Gao commented on FLINK-26108: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Resolved] (FLINK-25974) Make cancellation of jobs depend on the JobResultStore

[ https://issues.apache.org/jira/browse/FLINK-25974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-25974. --- Fix Version/s: 1.15.0 Resolution: Fixed master: 17c89564ae3 e8a91fd8428 > Make canc

[GitHub] [flink] flinkbot edited a comment on pull request #18717: [hotfix][avro] Add comments to explain why projection pushdown works for avro bulk format

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

[GitHub] [flink] flinkbot edited a comment on pull request #18715: [FLINK-25046][runtime] Convert unspecified edge to rescale when using adapive batch scheduler

flinkbot edited a comment on pull request #18715: URL: https://github.com/apache/flink/pull/18715#issuecomment-1035853003 ## CI report: * 58d1ec01c0ad3bda0e0f2d2260caac113c3fa942 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25941) KafkaSinkITCase.testAbortTransactionsAfterScaleInBeforeFirstCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491838#comment-17491838 ] Yun Gao commented on FLINK-25941: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] wanglijie95 commented on pull request #18715: [FLINK-25046][runtime] Convert unspecified edge to rescale when using adapive batch scheduler

wanglijie95 commented on pull request #18715: URL: https://github.com/apache/flink/pull/18715#issuecomment-1038758135 @zhuzhurk Thanks for review. I 've addressed your comment. Please help to review it again. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] MrWhiteSike edited a comment on pull request #18607: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…

MrWhiteSike edited a comment on pull request #18607: URL: https://github.com/apache/flink/pull/18607#issuecomment-1029722910 [@wuchong ](https://github.com/wuchong) [@xccui](https://github.com/xccui) [@klion26](https://github.com/klion26) Could you help to review this in your available ti

[jira] [Commented] (FLINK-26107) CoordinatorEventsExactlyOnceITCase.test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491837#comment-17491837 ] Yun Gao commented on FLINK-26107: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] XComp merged pull request #18644: [FLINK-25974] Makes job cancellation rely on JobResultStore entry

XComp merged pull request #18644: URL: https://github.com/apache/flink/pull/18644 -- 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] MrWhiteSike edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

MrWhiteSike edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032274801 -- 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.

[GitHub] [flink] MrWhiteSike edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

MrWhiteSike edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032274801 Hi, [RocMarshal](https://github.com/RocMarshal) [@wuchong](https://github.com/wuchong) [@xccui](https://github.com/xccui) [@klion26] could you help to review this? w

[jira] [Updated] (FLINK-26109) Avro Confluent Schema Registry nightly end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26109: Labels: test-stability (was: ) > Avro Confluent Schema Registry nightly end-to-end test failed on azure >

[jira] [Created] (FLINK-26109) Avro Confluent Schema Registry nightly end-to-end test failed on azure

Yun Gao created FLINK-26109: --- Summary: Avro Confluent Schema Registry nightly end-to-end test failed on azure Key: FLINK-26109 URL: https://issues.apache.org/jira/browse/FLINK-26109 Project: Flink

[GitHub] [flink] MrWhiteSike edited a comment on pull request #18607: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…

MrWhiteSike edited a comment on pull request #18607: URL: https://github.com/apache/flink/pull/18607#issuecomment-1029722910 [@wuchong ](https://github.com/wuchong) [@xccui](https://github.com/xccui) [@klion26](https://github.com/klion26) Could you review this in your available time? Than

[GitHub] [flink] MrWhiteSike edited a comment on pull request #18607: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…

MrWhiteSike edited a comment on pull request #18607: URL: https://github.com/apache/flink/pull/18607#issuecomment-1029722910 [@wuchong ](https://github.com/wuchong) [xccui](https://github.com/xccui) [klion26](https://github.com/klion26) Could you review this in your available time? Thanks

[GitHub] [flink] flinkbot edited a comment on pull request #18723: [FLINK-25640][docs] Enhance the document for blocking shuffle

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

[GitHub] [flink] MrWhiteSike edited a comment on pull request #18607: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…

MrWhiteSike edited a comment on pull request #18607: URL: https://github.com/apache/flink/pull/18607#issuecomment-1029722910 [@wuchong ](https://github.com/wuchong) Could you review this in your available time? Thanks. -- This is an automated message from the Apache Git Service. To respo

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #15: [FLINK-25820] Introduce Table Store Flink Source

tsreaper commented on a change in pull request #15: URL: https://github.com/apache/flink-table-store/pull/15#discussion_r805569270 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitGeneratorTest.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] dawidwys commented on a change in pull request #18729: [FLINK-26093][tests] Adjust SavepointFormatITCase for ChangelogStateBackend

dawidwys commented on a change in pull request #18729: URL: https://github.com/apache/flink/pull/18729#discussion_r805565771 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointFormatITCase.java ## @@ -78,138 +82,151 @@ LoggerAuditingExten

[jira] [Commented] (FLINK-26108) CoordinatedSourceITCase.testEnumeratorCreationFails failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491831#comment-17491831 ] Yun Gao commented on FLINK-26108: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] JingGe edited a comment on pull request #18736: [hotfix][datastream] move the change and restore of env parallelism into the adjusTransformations method.

JingGe edited a comment on pull request #18736: URL: https://github.com/apache/flink/pull/18736#issuecomment-1038747241 @gaoyunhaii would you like to take a look at this PR? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Updated] (FLINK-26107) CoordinatorEventsExactlyOnceITCase.test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26107: Priority: Critical (was: Major) > CoordinatorEventsExactlyOnceITCase.test failed on azure > -

[GitHub] [flink] JingGe commented on pull request #18736: [hotfix][datastream] move the change and restore of env parallelism into the adjusTransformations method.

JingGe commented on pull request #18736: URL: https://github.com/apache/flink/pull/18736#issuecomment-1038747241 @gaoyunhaii would you like to take a look at this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Commented] (FLINK-26107) CoordinatorEventsExactlyOnceITCase.test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491830#comment-17491830 ] Yun Gao commented on FLINK-26107: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491829#comment-17491829 ] Yun Gao commented on FLINK-25825: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-26108) CoordinatedSourceITCase.testEnumeratorCreationFails failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26108: Priority: Critical (was: Major) > CoordinatedSourceITCase.testEnumeratorCreationFails failed on azure > -

[jira] [Created] (FLINK-26108) CoordinatedSourceITCase.testEnumeratorCreationFails failed on azure

Yun Gao created FLINK-26108: --- Summary: CoordinatedSourceITCase.testEnumeratorCreationFails failed on azure Key: FLINK-26108 URL: https://issues.apache.org/jira/browse/FLINK-26108 Project: Flink Is

[jira] [Created] (FLINK-26107) CoordinatorEventsExactlyOnceITCase.test failed on azure

Yun Gao created FLINK-26107: --- Summary: CoordinatorEventsExactlyOnceITCase.test failed on azure Key: FLINK-26107 URL: https://issues.apache.org/jira/browse/FLINK-26107 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491824#comment-17491824 ] Yun Gao commented on FLINK-25825: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491823#comment-17491823 ] Yun Gao commented on FLINK-26105: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

[ https://issues.apache.org/jira/browse/FLINK-26106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26106: Labels: test-stability (was: ) > BoundedSourceITCase failed due to JVM exits with code 239 >

[jira] [Created] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

Yun Gao created FLINK-26106: --- Summary: BoundedSourceITCase failed due to JVM exits with code 239 Key: FLINK-26106 URL: https://issues.apache.org/jira/browse/FLINK-26106 Project: Flink Issue Type: B

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #15: [FLINK-25820] Introduce Table Store Flink Source

JingsongLi commented on a change in pull request #15: URL: https://github.com/apache/flink-table-store/pull/15#discussion_r805559798 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitGeneratorTest.java ##

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #15: [FLINK-25820] Introduce Table Store Flink Source

JingsongLi commented on a change in pull request #15: URL: https://github.com/apache/flink-table-store/pull/15#discussion_r805559171 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReader.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

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

[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #15: [FLINK-25820] Introduce Table Store Flink Source

JingsongLi commented on a change in pull request #15: URL: https://github.com/apache/flink-table-store/pull/15#discussion_r805557046 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitGenerator.java ## @@ -

[jira] [Updated] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26105: Priority: Critical (was: Major) > Running HA (hashmap, async) end-to-end test failed on azure > -

[jira] [Created] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

Yun Gao created FLINK-26105: --- Summary: Running HA (hashmap, async) end-to-end test failed on azure Key: FLINK-26105 URL: https://issues.apache.org/jira/browse/FLINK-26105 Project: Flink Issue Type

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #15: [FLINK-25820] Introduce Table Store Flink Source

JingsongLi commented on a change in pull request #15: URL: https://github.com/apache/flink-table-store/pull/15#discussion_r805557046 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitGenerator.java ## @@ -

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

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

[GitHub] [flink] flinkbot edited a comment on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] twalthr commented on pull request #18710: [FLINK-26055][table][annotations] Modified CompiledPlan#getFlinkVersion return type to FlinkVersion

twalthr commented on pull request #18710: URL: https://github.com/apache/flink/pull/18710#issuecomment-1038728000 @slinkydeveloper It seems the build is still red. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink] flinkbot edited a comment on pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] MrWhiteSike edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

MrWhiteSike edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032274801 Hi, [RocMarshal](https://github.com/RocMarshal) [@wuchong](https://github.com/wuchong) could you help to review this? when you are available. very appreciated it.

[jira] [Created] (FLINK-26104) KeyError: 'type_info' in PyFlink test

Huang Xingbo created FLINK-26104: Summary: KeyError: 'type_info' in PyFlink test Key: FLINK-26104 URL: https://issues.apache.org/jira/browse/FLINK-26104 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18745: [FLINK-24607] Make OperatorCoordinator closing sequence more robust.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] wuchong commented on pull request #18745: [FLINK-24607] Make OperatorCoordinator closing sequence more robust.

wuchong commented on pull request #18745: URL: https://github.com/apache/flink/pull/18745#issuecomment-1038713848 @becketqin , do you want this PR get merged in 1.15 release? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink] flinkbot commented on pull request #18745: [FLINK-24607] Make OperatorCoordinator closing sequence more robust.

flinkbot commented on pull request #18745: URL: https://github.com/apache/flink/pull/18745#issuecomment-1038713655 ## CI report: * 1cb9f56136e9aae7583737bb17428c3c72ce0805 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] wuchong commented on pull request #18745: [FLINK-24607] Make OperatorCoordinator closing sequence more robust.

wuchong commented on pull request #18745: URL: https://github.com/apache/flink/pull/18745#issuecomment-1038713270 cc @leonardBang -- 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 co

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18745: [FLINK-24607] Make OperatorCoordinator closing sequence more robust.

flinkbot commented on pull request #18745: URL: https://github.com/apache/flink/pull/18745#issuecomment-1038712533 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pr

[GitHub] [flink] becketqin commented on pull request #18745: [FLINK-24607] Make OperatorCoordinator closing sequence more robust.

becketqin commented on pull request #18745: URL: https://github.com/apache/flink/pull/18745#issuecomment-1038710684 Ping @wuchong @pnowojski for review. -- 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

[jira] [Updated] (FLINK-24607) SourceCoordinator may miss to close SplitEnumerator when failover frequently

[ https://issues.apache.org/jira/browse/FLINK-24607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24607: --- Labels: pull-request-available (was: ) > SourceCoordinator may miss to close SplitEnumerato

[GitHub] [flink] becketqin opened a new pull request #18745: [FLINK-24607] Make OperatorCoordinator closing sequence more robust.

becketqin opened a new pull request #18745: URL: https://github.com/apache/flink/pull/18745 ## What is the purpose of the change Currently the closing sequence of the `OperatorCoordinator` does not swallow the exceptions thrown in the middle. So when exception is thrown in the middle, t

[jira] [Resolved] (FLINK-25940) pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state failed on AZP

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

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] HuangXingBo closed pull request #18742: [FLINK-25940][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink

HuangXingBo closed pull request #18742: URL: https://github.com/apache/flink/pull/18742 -- 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-uns

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26103) Introduce log store

[ https://issues.apache.org/jira/browse/FLINK-26103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26103: --- Labels: pull-request-available (was: ) > Introduce log store > --- > >

[GitHub] [flink-table-store] JingsongLi opened a new pull request #20: [FLINK-26103] Introduce log store

JingsongLi opened a new pull request #20: URL: https://github.com/apache/flink-table-store/pull/20 Introduce log store: - Refactor SinkRecord - Introduce log store interfaces - Implement Kafka log store -- This is an automated message from the Apache Git Service. To respond to th

[GitHub] [flink] wenlong88 commented on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

wenlong88 commented on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1038705401 @gaoyunhaii thanks for the detailed review, I have addressed the comments -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-26100) Set up Flink ML Document Website

[ https://issues.apache.org/jira/browse/FLINK-26100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26100: --- Labels: pull-request-available (was: ) > Set up Flink ML Document Website > ---

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request #57: [FLINK-26100] Set up Flink ML Document Website

yunfengzhou-hub opened a new pull request #57: URL: https://github.com/apache/flink-ml/pull/57 ## What is the purpose of the change - Set up Flink ML Document Website ## Brief change log - Add `docs` folder containing all configurations needed to setup the framework for

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Closed] (FLINK-26102) connector test by using 'flink run --python'

[ https://issues.apache.org/jira/browse/FLINK-26102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-26102. --- Resolution: Not A Problem Hi [~waittting], you should post this kind of question in go to the [user mailing

[jira] [Comment Edited] (FLINK-26102) connector test by using 'flink run --python'

[ https://issues.apache.org/jira/browse/FLINK-26102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491814#comment-17491814 ] Dian Fu edited comment on FLINK-26102 at 2/14/22, 6:34 AM: --- Hi

[jira] [Assigned] (FLINK-26103) Introduce log store

[ https://issues.apache.org/jira/browse/FLINK-26103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26103: Assignee: Jingsong Lee > Introduce log store > --- > > Ke

[jira] [Created] (FLINK-26103) Introduce log store

Jingsong Lee created FLINK-26103: Summary: Introduce log store Key: FLINK-26103 URL: https://issues.apache.org/jira/browse/FLINK-26103 Project: Flink Issue Type: Sub-task Components

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18400: [FLINK-25198][docs] Add doc about name and description of operator

flinkbot edited a comment on pull request #18400: URL: https://github.com/apache/flink/pull/18400#issuecomment-1016057839 ## CI report: * 0ee72a0732026c046d991d959033995c7baf44e1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] MrWhiteSike edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

MrWhiteSike edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032274801 Hi, [@wuchong](https://github.com/wuchong) could you help to review this? when you are available. very appreciated it. -- This is an automated message from the Apa

[GitHub] [flink] flinkbot edited a comment on pull request #18738: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

flinkbot edited a comment on pull request #18738: URL: https://github.com/apache/flink/pull/18738#issuecomment-1037051889 ## CI report: * 2a0939dfb92ff0485a51a01416b3ed7a86caf79e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-26042) PyFlinkEmbeddedSubInterpreterTests. test_udf_without_arguments failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-26042: Assignee: Huang Xingbo > PyFlinkEmbeddedSubInterpreterTests. test_udf_without_arguments f

  1   2   3   4   >