[jira] [Updated] (FLINK-3203) DistributedCache crashing when run in OGS

[ https://issues.apache.org/jira/browse/FLINK-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3203: -- Labels: DistributedCache OGS auto-deprioritized-major stale-minor (was: DistributedCache OGS a

[jira] [Updated] (FLINK-3110) Add support for partition-centric iterations

[ https://issues.apache.org/jira/browse/FLINK-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3110: -- Labels: auto-deprioritized-major requires-design-doc stale-minor (was: auto-deprioritized-majo

[jira] [Updated] (FLINK-8606) Clean up Table API for Java users

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

[jira] [Updated] (FLINK-8716) AvroSerializer does not use schema of snapshot

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

[jira] [Updated] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

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

[jira] [Updated] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

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

[jira] [Updated] (FLINK-9036) Add default value via suppliers

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

[jira] [Updated] (FLINK-9171) Flink HCatolog integration

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

[jira] [Updated] (FLINK-8869) Kafka restore from checkpoint without react to the new add partition to kafka server

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

[jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway failed

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

[jira] [Updated] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

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

[jira] [Updated] (FLINK-9195) Delete non-well-defined output methods on DataStream

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

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

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

[jira] [Commented] (FLINK-25023) ClassLoader leak on JM/TM through indirectly-started Hadoop threads out of user code

[ https://issues.apache.org/jira/browse/FLINK-25023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466995#comment-17466995 ] Kerem Ulutaş commented on FLINK-25023: -- I am also investigating a metaspace OOM exc

[GitHub] [flink] flinkbot edited a comment on pull request #18169: add shutdown hook

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: add shutdown hook

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: add shutdown hook

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

[GitHub] [flink] flinkbot edited a comment on pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18210: [FLINK-25454][runtime] Pause and resume time for throughput calculator only from one thread.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

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

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

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

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: add shutdown hook

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: add shutdown hook

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

[jira] [Commented] (FLINK-25488) Using a pipe symbol as pair delimiter in STR_TO_MAP in combination with concatenation results in broken output

[ https://issues.apache.org/jira/browse/FLINK-25488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466953#comment-17466953 ] Yuhao Bi commented on FLINK-25488: --   try this  {code:java} System.out.println(SqlFunc

[GitHub] [flink] flinkbot edited a comment on pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18210: [FLINK-25454][runtime] Pause and resume time for throughput calculator only from one thread.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

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

[jira] [Assigned] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

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

[GitHub] [flink] flinkbot edited a comment on pull request #18210: [FLINK-25454][runtime] Pause and resume time for throughput calculator only from one thread.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

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

[GitHub] [flink] gaoyunhaii commented on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

gaoyunhaii commented on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-1003116309 Very thanks @pnowojski for the review! I updated the release note field and the documents~ -- This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][docs] Fix typo in name for HiveParserQBSubQuery.java

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

[GitHub] [flink] flinkbot edited a comment on pull request #18229: [hotfix][docs] Fix typo in name for data_stream_api.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18231: [hotfix][docs] Fix typo in name for archetype-resources/pom.xml

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

[GitHub] [flink] gaoyunhaii commented on a change in pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

gaoyunhaii commented on a change in pull request #18068: URL: https://github.com/apache/flink/pull/18068#discussion_r776803171 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java ## @@ -617,7 +617,6 @@ private static JobGraph create

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[jira] [Created] (FLINK-25490) Update the Chinese document related to final checkpoint

Yun Gao created FLINK-25490: --- Summary: Update the Chinese document related to final checkpoint Key: FLINK-25490 URL: https://issues.apache.org/jira/browse/FLINK-25490 Project: Flink Issue Type: Sub

[GitHub] [flink] gaoyunhaii closed pull request #18195: [hotfix][runtime/source] fix comment typo

gaoyunhaii closed pull request #18195: URL: https://github.com/apache/flink/pull/18195 -- 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 #18159: [FLINK-21186][network] Wrap IOException in UncheckedIOException in RecordWriterOutput

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

[GitHub] [flink] gaoyunhaii commented on pull request #18195: [hotfix][runtime/source] fix comment typo

gaoyunhaii commented on pull request #18195: URL: https://github.com/apache/flink/pull/18195#issuecomment-1003089262 Very thanks @JingGe for the PR! LGTM and would merge~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[jira] [Updated] (FLINK-25105) Enables final checkpoint by default

[ https://issues.apache.org/jira/browse/FLINK-25105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25105: Release Note: In 1.15 we enabled the support of checkpoints after part of tasks finished by default, and

[jira] [Updated] (FLINK-25105) Enables final checkpoint by default

[ https://issues.apache.org/jira/browse/FLINK-25105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25105: Release Note: In 1.15 we enabled the support of checkpoints after part of tasks finished by default, and

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466923#comment-17466923 ] David Morávek commented on FLINK-25307: --- I don't see any hints in the logs either.

[GitHub] [flink] wsry commented on pull request #18173: [FLINK-25407][network] Fix the deadlock issue caused by LocalBufferPool#reserveSegments

wsry commented on pull request #18173: URL: https://github.com/apache/flink/pull/18173#issuecomment-1003085575 If we just want to guard that the locking behavior can not be changed by the following patches. We can add some tests, for example, when calling some method of network buffer pool

[GitHub] [flink] flinkbot edited a comment on pull request #18181: [FLINK-25414][metrics] Provide metrics to measure how long task has been blocked

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

[jira] [Updated] (FLINK-25489) mac m1 built flink from source failed cause of couldn't download nodejs

[ https://issues.apache.org/jira/browse/FLINK-25489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jie han updated FLINK-25489: Summary: mac m1 built flink from source failed cause of couldn't download nodejs (was: failed at task: no

[jira] [Created] (FLINK-25489) failed at task: node and npm install when building flink from source in mac m1

jie han created FLINK-25489: --- Summary: failed at task: node and npm install when building flink from source in mac m1 Key: FLINK-25489 URL: https://issues.apache.org/jira/browse/FLINK-25489 Project: Flink

[jira] [Closed] (FLINK-25424) Checkpointing is currently not supported for operators that implement InputSelectable

[ https://issues.apache.org/jira/browse/FLINK-25424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25424. -- Resolution: Duplicate Hi [~ghandzhipeng]. Thanks for rising this issue. This is a well known

[GitHub] [flink] flinkbot edited a comment on pull request #18229: [hotfix][docs] Fix typo in name for data_stream_api.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][docs] Fix typo in name for HiveParserQBSubQuery.java

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

[GitHub] [flink-ml] gaoyunhaii merged pull request #49: [hotfix] Add scala version as suffix of all modules

gaoyunhaii merged pull request #49: URL: https://github.com/apache/flink-ml/pull/49 -- 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-unsubsc

[GitHub] [flink-ml] gaoyunhaii merged pull request #50: [hotfix] Add scala version as suffix of all modules

gaoyunhaii merged pull request #50: URL: https://github.com/apache/flink-ml/pull/50 -- 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-unsubsc

[GitHub] [flink] flinkbot edited a comment on pull request #18229: [hotfix][docs] Fix typo in name for data_stream_api.md

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

[GitHub] [flink] sky-walking commented on pull request #18227: [hotfix][docs] Fix typo in name for HiveParserQBSubQuery.java

sky-walking commented on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1003066746 Thank you for your review. I have finished correcting it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix][docs] Fix typo in name for HiveParserQBSubQuery.java

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

[GitHub] [flink] sky-walking commented on pull request #18231: [hotfix][docs] Fix typo in name for archetype-resources/pom.xml

sky-walking commented on pull request #18231: URL: https://github.com/apache/flink/pull/18231#issuecomment-100305 Thank you for your review. I have finished correcting it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink] sky-walking commented on pull request #18229: [hotfix][docs] Fix typo in name for data_stream_api.md

sky-walking commented on pull request #18229: URL: https://github.com/apache/flink/pull/18229#issuecomment-1003066556 Thank you for your review. I have finished correcting it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] wanglijie95 commented on a change in pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

wanglijie95 commented on a change in pull request #18023: URL: https://github.com/apache/flink/pull/18023#discussion_r776761828 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java ## @@ -762,18 +762,38 @@ public void set

[jira] [Updated] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25307: --- Component/s: Runtime / Coordination (was: Runtime / Checkpointing) > Re

[GitHub] [flink] flinkbot edited a comment on pull request #18231: [hotfix][docs] Fix typo in name for archetype-resources/pom.xml

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

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

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

[GitHub] [flink] flinkbot edited a comment on pull request #18231: [hotfix][docs] Fix typo in name for archetype-resources/pom.xml

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

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

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

[GitHub] [flink] wanglijie95 commented on a change in pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

wanglijie95 commented on a change in pull request #18023: URL: https://github.com/apache/flink/pull/18023#discussion_r776757395 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultVertexParallelismInfoTest.java ## @@ -41,15 +41,15 @@ public void

[GitHub] [flink] wsry commented on pull request #18173: [FLINK-25407][network] Fix the deadlock issue caused by LocalBufferPool#reserveSegments

wsry commented on pull request #18173: URL: https://github.com/apache/flink/pull/18173#issuecomment-1003059833 > I guess in LocalBufferPool we can have four options: > I. Preemptively acquire factoryLock (2.) in methods that are used rarely > II. Decouple logic in two steps. First do s

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

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

[GitHub] [flink] flinkbot edited a comment on pull request #18237: [DRAFT][FLINK-XXXX] Use working directory to persist local state

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

[jira] [Commented] (FLINK-25128) Reorganize table modules and introduce flink-table-planner-loader

[ https://issues.apache.org/jira/browse/FLINK-25128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466889#comment-17466889 ] Timo Walther commented on FLINK-25128: -- Also announced on the dev@ ML: https://list

[jira] [Commented] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466888#comment-17466888 ] Piotr Nowojski commented on FLINK-25026: Ok. In that case let's disregard those

[jira] [Updated] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25026: --- Component/s: Runtime / Checkpointing (was: Runtime / Coordination) > Un

[jira] [Assigned] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-25026: -- Assignee: (was: Anton Kalashnikov) > UnalignedCheckpointRescaleITCase.shouldResca

[GitHub] [flink] pnowojski commented on pull request #18173: [FLINK-25407][network] Fix the deadlock issue caused by LocalBufferPool#reserveSegments

pnowojski commented on pull request #18173: URL: https://github.com/apache/flink/pull/18173#issuecomment-1003042631 There are 3 locks being acquired in the context of this ticket: 1. `LocalBufferPool#availableMemorySegments` 2. `NetworkBufferPool#factoryLock` 3. `NetworkBufferPool#a

[GitHub] [flink] wanglijie95 commented on a change in pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

wanglijie95 commented on a change in pull request #18023: URL: https://github.com/apache/flink/pull/18023#discussion_r776737950 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -167,7 +167,7 @@ public stat

[jira] [Commented] (FLINK-25472) Update to Log4j 2.17.1

[ https://issues.apache.org/jira/browse/FLINK-25472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466885#comment-17466885 ] Yun Gao commented on FLINK-25472: - Merged on master: fe9ead73427a3720c571952ad28aac693c

[jira] [Closed] (FLINK-25472) Update to Log4j 2.17.1

[ https://issues.apache.org/jira/browse/FLINK-25472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25472. --- Resolution: Fixed > Update to Log4j 2.17.1 > -- > > Key: FLINK-25472 >

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

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

[GitHub] [flink] gaoyunhaii commented on a change in pull request #18234: [hotfix][docs] Fixing multiple 404 links in docs

gaoyunhaii commented on a change in pull request #18234: URL: https://github.com/apache/flink/pull/18234#discussion_r776736369 ## File path: docs/content/docs/dev/table/sql/queries/match_recognize.md ## @@ -267,7 +267,7 @@ look at the [event stream navigation](#pattern-navigati

[GitHub] [flink] wanglijie95 commented on a change in pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

wanglijie95 commented on a change in pull request #18023: URL: https://github.com/apache/flink/pull/18023#discussion_r776735043 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java ## @@ -115,19 +116,15 @@ private Eithe

[jira] [Commented] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466882#comment-17466882 ] Anton Kalashnikov commented on FLINK-25026: --- as I can see last two reports rel

[GitHub] [flink] flinkbot edited a comment on pull request #18159: [FLINK-21186][network] Wrap IOException in UncheckedIOException in RecordWriterOutput

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

[GitHub] [flink] gaoyunhaii commented on pull request #18233: [FLINK-25472][BP 1.12][core] Update to Log4j 2.17.1

gaoyunhaii commented on pull request #18233: URL: https://github.com/apache/flink/pull/18233#issuecomment-1003033893 Merged~ -- 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] gaoyunhaii closed pull request #18233: [FLINK-25472][BP 1.12][core] Update to Log4j 2.17.1

gaoyunhaii closed pull request #18233: URL: https://github.com/apache/flink/pull/18233 -- 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] dmvk commented on a change in pull request #18237: [DRAFT][FLINK-XXXX] Use working directory to persist local state

dmvk commented on a change in pull request #18237: URL: https://github.com/apache/flink/pull/18237#discussion_r776626328 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerRuntimeInfo.java ## @@ -62,4 +64,7 @@ default String getTaskM

[jira] [Comment Edited] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466869#comment-17466869 ] Lijie Wang edited comment on FLINK-25441 at 12/30/21, 1:39 PM: ---

[jira] [Comment Edited] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466869#comment-17466869 ] Lijie Wang edited comment on FLINK-25441 at 12/30/21, 1:39 PM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #18159: [FLINK-21186][network] Wrap IOException in UncheckedIOException in RecordWriterOutput

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

[jira] [Comment Edited] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466869#comment-17466869 ] Lijie Wang edited comment on FLINK-25441 at 12/30/21, 1:36 PM: ---

[jira] [Comment Edited] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466869#comment-17466869 ] Lijie Wang edited comment on FLINK-25441 at 12/30/21, 1:35 PM: ---

[GitHub] [flink] gaoyunhaii commented on pull request #18232: [FLINK-25472][BP 1-1.3][core] Update to Log4j 2.17.1

gaoyunhaii commented on pull request #18232: URL: https://github.com/apache/flink/pull/18232#issuecomment-1003031924 merged~ -- 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] gaoyunhaii closed pull request #18232: [FLINK-25472][BP 1-1.3][core] Update to Log4j 2.17.1

gaoyunhaii closed pull request #18232: URL: https://github.com/apache/flink/pull/18232 -- 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] pnowojski edited a comment on pull request #18159: [FLINK-21186][network] Wrap IOException in UncheckedIOException in RecordWriterOutput

pnowojski edited a comment on pull request #18159: URL: https://github.com/apache/flink/pull/18159#issuecomment-1003029611 tests failure unrelated - https://issues.apache.org/jira/browse/FLINK-25185 kafka failure also unrelated - https://issues.apache.org/jira/browse/FLINK-20928 I

[GitHub] [flink] gaoyunhaii closed pull request #18230: [FLINK-25472][BP 1.14][core] Update to Log4j 2.17.1

gaoyunhaii closed pull request #18230: URL: https://github.com/apache/flink/pull/18230 -- 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] gaoyunhaii commented on pull request #18230: [FLINK-25472][BP 1.14][core] Update to Log4j 2.17.1

gaoyunhaii commented on pull request #18230: URL: https://github.com/apache/flink/pull/18230#issuecomment-1003030777 Merged~ -- 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] pnowojski edited a comment on pull request #18159: [FLINK-21186][network] Wrap IOException in UncheckedIOException in RecordWriterOutput

pnowojski edited a comment on pull request #18159: URL: https://github.com/apache/flink/pull/18159#issuecomment-1003029611 tests failure unrelated - https://issues.apache.org/jira/browse/FLINK-25185 kafka failure also unrelated - https://issues.apache.org/jira/browse/FLINK-20928 >

[GitHub] [flink] pnowojski edited a comment on pull request #18159: [FLINK-21186][network] Wrap IOException in UncheckedIOException in RecordWriterOutput

pnowojski edited a comment on pull request #18159: URL: https://github.com/apache/flink/pull/18159#issuecomment-1003029611 tests failure unrelated - https://issues.apache.org/jira/browse/FLINK-25185 kafka failure also unrelated - https://issues.apache.org/jira/browse/FLINK-20928 W

[GitHub] [flink] pnowojski commented on pull request #18159: [FLINK-21186][network] Wrap IOException in UncheckedIOException in RecordWriterOutput

pnowojski commented on pull request #18159: URL: https://github.com/apache/flink/pull/18159#issuecomment-1003029611 tests failure unrelated - https://issues.apache.org/jira/browse/FLINK-25185 kafka failure also unrelated - https://issues.apache.org/jira/browse/FLINK-20928 -- This is a

<    1   2   3   4   5   >