[jira] [Closed] (FLINK-26357) add @PublicEvolving to AvroParquetRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-26357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-26357. --- > add @PublicEvolving to AvroParquetRecordFormat > -- > >

[jira] [Resolved] (FLINK-26357) add @PublicEvolving to AvroParquetRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-26357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26357. - Fix Version/s: 1.15.0 Resolution: Fixed > add @PublicEvolving to AvroParquetRecordFormat

[jira] [Updated] (FLINK-26357) add @PublicEvolving to AvroParquetRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-26357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26357: Affects Version/s: 1.15.0 > add @PublicEvolving to AvroParquetRecordFormat > -

[jira] [Commented] (FLINK-26357) add @PublicEvolving to AvroParquetRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-26357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498749#comment-17498749 ] Fabian Paul commented on FLINK-26357: - Merged in master: e2463ddace26601c6442dbaa68c

[GitHub] [flink] fapaul merged pull request #18911: [FLINK-26357][format] add FLINK API annotations

fapaul merged pull request #18911: URL: https://github.com/apache/flink/pull/18911 -- 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

[jira] [Assigned] (FLINK-26374) JSON_OBJECT may throw NullPointerException on nullable column

[ https://issues.apache.org/jira/browse/FLINK-26374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-26374: Assignee: Timo Walther > JSON_OBJECT may throw NullPointerException on nullable column >

[GitHub] [flink] flinkbot edited a comment on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

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

[jira] [Commented] (FLINK-26052) Update chinese documentation regarding FLIP-203

[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498747#comment-17498747 ] Dawid Wysakowicz commented on FLINK-26052: -- Sure [~shenzhu0127] I can assign it

[jira] [Assigned] (FLINK-26052) Update chinese documentation regarding FLIP-203

[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26052: Assignee: Shen Zhu > Update chinese documentation regarding FLIP-203 > --

[GitHub] [flink] flinkbot edited a comment on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

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

[GitHub] [flink] XComp commented on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

XComp commented on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1053977510 rebased branch after PR #18919 was 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 t

[jira] [Resolved] (FLINK-26285) ZooKeeperStateHandleStore does not handle not existing nodes properly in getAllAndLock

[ https://issues.apache.org/jira/browse/FLINK-26285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26285. --- Fix Version/s: 1.15.0 1.14.4 1.13.7 Resolution:

[jira] [Created] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

Yun Gao created FLINK-26387: --- Summary: KafkaSourceLegacyITCase.testBrokerFailure hang on azure Key: FLINK-26387 URL: https://issues.apache.org/jira/browse/FLINK-26387 Project: Flink Issue Type: Bug

[GitHub] [flink] XComp merged pull request #18922: [BP-1.13][FLINK-26285] Fixes an inconsistency

XComp merged pull request #18922: URL: https://github.com/apache/flink/pull/18922 -- 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] XComp merged pull request #18921: [BP-1.14][FLINK-26285] Fixes an inconsistency

XComp merged pull request #18921: URL: https://github.com/apache/flink/pull/18921 -- 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] XComp merged pull request #18919: [FLINK-26285] Fixes an inconsistency

XComp merged pull request #18919: URL: https://github.com/apache/flink/pull/18919 -- 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.

[jira] [Created] (FLINK-26386) CassandraConnectorITCase.testCassandraTableSink failed on azure

Yun Gao created FLINK-26386: --- Summary: CassandraConnectorITCase.testCassandraTableSink failed on azure Key: FLINK-26386 URL: https://issues.apache.org/jira/browse/FLINK-26386 Project: Flink Issue

[GitHub] [flink] Myasuka commented on a change in pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

Myasuka commented on a change in pull request #18840: URL: https://github.com/apache/flink/pull/18840#discussion_r815634090 ## File path: flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/output/SnapshotUtilsTest.java ## @@ -52,6 +53,7 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

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

[GitHub] [flink] gaoyunhaii closed pull request #18916: [FLINK-26314] Disable unaligned checkpoints for StreamingExecutionFileSinkITCase.

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

[jira] [Commented] (FLINK-26370) Make Flink cluster communication asynchronous

[ https://issues.apache.org/jira/browse/FLINK-26370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498737#comment-17498737 ] Yang Wang commented on FLINK-26370: --- In the go implemented K8s operators, they usually

[GitHub] [flink] liufangqi commented on pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

liufangqi commented on pull request #18840: URL: https://github.com/apache/flink/pull/18840#issuecomment-1053950480 @Myasuka Agree the idea that only support Savepoint cause flink support the native savepoint in the new version. Updated the code that support switching the savepoint format

[GitHub] [flink] flinkbot edited a comment on pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

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

[jira] [Created] (FLINK-26385) Use new Kafka source and sink in Python API

Qingsheng Ren created FLINK-26385: - Summary: Use new Kafka source and sink in Python API Key: FLINK-26385 URL: https://issues.apache.org/jira/browse/FLINK-26385 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-26139) Improve JobStatus tracking and handle different job states

[ https://issues.apache.org/jira/browse/FLINK-26139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498731#comment-17498731 ] Yang Wang commented on FLINK-26139: --- I agree with introducing a {{UNKNOWN}} state for

[GitHub] [flink] flinkbot edited a comment on pull request #18899: [hotfix] Log architecture on startup

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

[GitHub] [flink] flinkbot edited a comment on pull request #18899: [hotfix] Log architecture on startup

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

[GitHub] [flink] rmetzger commented on pull request #18899: [hotfix] Log architecture on startup

rmetzger commented on pull request #18899: URL: https://github.com/apache/flink/pull/18899#issuecomment-1053938577 Thanks for the approval. Rebased to latest master, hoping that the tests are passing now ... -- This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink] flinkbot edited a comment on pull request #18480: [FLINK-25789][docs-zh] Translate the formats/hadoop page into Chinese.

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

[jira] [Closed] (FLINK-26356) Revisit the create of RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-26356. - Resolution: Fixed Fixed via: main: a5ecd445c0dc7a9d5e3a3ddc478cb626f65eb897 > Revisit the create of Re

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[jira] [Commented] (FLINK-26356) Revisit the create of RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498704#comment-17498704 ] Yang Wang commented on FLINK-26356: --- Thanks for the verification. I will look at the P

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[jira] [Commented] (FLINK-25648) Redundant to query deployment when creating task manager pods

[ https://issues.apache.org/jira/browse/FLINK-25648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498699#comment-17498699 ] Yuan Huang commented on FLINK-25648: - Thank you for your time. Let me know if there

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[jira] [Commented] (FLINK-24677) JdbcBatchingOutputFormat should not generate circulate chaining of exceptions when flushing fails in timer thread

[ https://issues.apache.org/jira/browse/FLINK-24677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498698#comment-17498698 ] 张健 commented on FLINK-24677: [~TsReaper] hello，I see JingSong Lee do not leave further comme

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] 1996fanrui commented on a change in pull request #18852: [FLINK-26049][checkpoint] Improve logic after checkpoint trigger fails

1996fanrui commented on a change in pull request #18852: URL: https://github.com/apache/flink/pull/18852#discussion_r81714 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java ## @@ -105,12 +105,12 @@ /** The checkpoint

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

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

[GitHub] [flink] oogetyboogety edited a comment on pull request #18788: [hotfix] [docs] Typo in filesystem.md

oogetyboogety edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1053834261 @knaufk sure, updated -- 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

[GitHub] [flink] oogetyboogety opened a new pull request #18788: Typo in filesystem.md

oogetyboogety opened a new pull request #18788: URL: https://github.com/apache/flink/pull/18788 Looks like you left something unchanged in the docs. I updated it for you. ## What is the purpose of the change *(For example: This pull request makes task deployment go thro

[GitHub] [flink] oogetyboogety commented on pull request #18788: Typo in filesystem.md

oogetyboogety commented on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1053834261 sure, updated -- 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

[GitHub] [flink] oogetyboogety closed pull request #18788: Typo in filesystem.md

oogetyboogety closed pull request #18788: URL: https://github.com/apache/flink/pull/18788 -- 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-u

[GitHub] [flink] flinkbot edited a comment on pull request #18788: Typo in filesystem.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #18788: Typo in filesystem.md

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

[jira] [Updated] (FLINK-26383) Create model stream sink demo

[ https://issues.apache.org/jira/browse/FLINK-26383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26383: --- Labels: pull-request-available (was: ) > Create model stream sink demo > --

[GitHub] [flink-ml] weibozhao opened a new pull request #67: [FLINK-26383] Create model stream sink demo

weibozhao opened a new pull request #67: URL: https://github.com/apache/flink-ml/pull/67 [FLINK-26383] Create model stream sink demo -- 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

[GitHub] [flink] Myasuka commented on a change in pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

Myasuka commented on a change in pull request #18840: URL: https://github.com/apache/flink/pull/18840#discussion_r815545910 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/SnapshotUtils.java ## @@ -52,12 +53,13 @@ privat

[jira] [Updated] (FLINK-25528) support state processor api to create checkpoint

[ https://issues.apache.org/jira/browse/FLINK-25528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-25528: - Summary: support state processor api to create checkpoint (was: state processor api do not support incr

[jira] [Closed] (FLINK-26384) This exception indicates that the query uses an unsupported SQL feature.

[ https://issues.apache.org/jira/browse/FLINK-26384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob closed FLINK-26384. - Resolution: Not A Problem > This exception indicates that the query uses an unsupported SQL feature. > -

[jira] [Commented] (FLINK-26377) Extract Reconciler interface

[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498687#comment-17498687 ] Aitozi commented on FLINK-26377: ok, i will take a look first before work on it. > Extr

[jira] [Created] (FLINK-26384) This exception indicates that the query uses an unsupported SQL feature.

Spongebob created FLINK-26384: - Summary: This exception indicates that the query uses an unsupported SQL feature. Key: FLINK-26384 URL: https://issues.apache.org/jira/browse/FLINK-26384 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18480: [FLINK-25789][docs-zh] Translate the formats/hadoop page into Chinese.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18480: [FLINK-25789][docs-zh] Translate the formats/hadoop page into Chinese.

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

[GitHub] [flink] RocMarshal commented on pull request #18480: [FLINK-25789][docs-zh] Translate the formats/hadoop page into Chinese.

RocMarshal commented on pull request #18480: URL: https://github.com/apache/flink/pull/18480#issuecomment-1053797345 @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

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

MrWhiteSike commented on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1053794622 [@RocMarshal](https://github.com/RocMarshal) Thanks for the comments. Please review it again. -- This is an automated message from the Apache Git Service. To respond to t

[jira] [Updated] (FLINK-26334) when the (timestamp - offset + windowSize) is less than 0 the calculation result of TimeWindow.getWindowSTartWithOffset is incorrect

[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] realdengziqi updated FLINK-26334: - Description:   source code {code:java} //Method to get the window start for a timestamp. //Para

[jira] [Created] (FLINK-26383) Create model stream sink demo

weibo zhao created FLINK-26383: -- Summary: Create model stream sink demo Key: FLINK-26383 URL: https://issues.apache.org/jira/browse/FLINK-26383 Project: Flink Issue Type: New Feature C

[GitHub] [flink] shenzhu commented on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

shenzhu commented on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-1053767381 Hey @wuchong , would you mind taking a look at this PR when you have a moment? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] shenzhu commented on pull request #18926: [FLINK-26358][Runtime / Coordination] Operator maxParallelism is lost during chaining

shenzhu commented on pull request #18926: URL: https://github.com/apache/flink/pull/18926#issuecomment-1053765399 Hey @fapaul , Thanks so much for your review! Yeah I read the code in `loadAndValidateCheckpoint` and indeed this would break state compatibility. Sorry I'm new to this

[jira] [Commented] (FLINK-26052) Update chinese documentation regarding FLIP-203

[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498670#comment-17498670 ] Shen Zhu commented on FLINK-26052: -- Hi [~dwysakowicz] , I'm interested in translating t

[GitHub] [flink] flinkbot edited a comment on pull request #18923: [FLINK-26373][connector/kinesis] Renaming KinesisDataStreams module to KinesisStreams

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

[GitHub] [flink] flinkbot edited a comment on pull request #18923: [FLINK-26373][connector/kinesis] Renaming KinesisDataStreams module to KinesisStreams

flinkbot edited a comment on pull request #18923: URL: https://github.com/apache/flink/pull/18923#issuecomment-1050968682 ## CI report: * Unknown: [CANCELED](TBD) * 5967cbe7bc27936f5938f6d6ddcd1f31639d533b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-462

[GitHub] [flink] flinkbot edited a comment on pull request #18923: [FLINK-26373][connector/kinesis] Renaming KinesisDataStreams module to KinesisStreams

flinkbot edited a comment on pull request #18923: URL: https://github.com/apache/flink/pull/18923#issuecomment-1050968682 ## CI report: * Unknown: [CANCELED](TBD) * 5967cbe7bc27936f5938f6d6ddcd1f31639d533b UNKNOWN Bot commands The @flinkbot bot supports the fo

[GitHub] [flink] vahmed-hamdy commented on pull request #18923: [FLINK-26373][connector/kinesis] Renaming KinesisDataStreams module to KinesisStreams

vahmed-hamdy commented on pull request #18923: URL: https://github.com/apache/flink/pull/18923#issuecomment-1053664791 @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 spe

[jira] [Comment Edited] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498493#comment-17498493 ] Fil Karnicki edited comment on FLINK-25866 at 2/27/22, 7:11 PM: --

[GitHub] [flink] fapaul commented on pull request #18794: [hotfix] Refactor the name of builder method

fapaul commented on pull request #18794: URL: https://github.com/apache/flink/pull/18794#issuecomment-1053648084 I agree, renaming it to "build" definitely aligns it with other parts of the codebase but I would prefer to make this change part of a ticket and not a hotfix because it affects

[GitHub] [flink] knaufk commented on pull request #18498: [FLINK-25801][ metrics]add cpu processor metric of taskmanager

knaufk commented on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1053648013 @zentol what do you think about this change? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[GitHub] [flink] knaufk closed pull request #18562: [MINOR] ResourceManager_Refactor

knaufk closed pull request #18562: URL: https://github.com/apache/flink/pull/18562 -- 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] knaufk commented on pull request #18562: [MINOR] ResourceManager_Refactor

knaufk commented on pull request #18562: URL: https://github.com/apache/flink/pull/18562#issuecomment-1053647634 Closing in favor of #18662. -- 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 s

[GitHub] [flink] knaufk commented on pull request #18662: [MINOR] Remove unused method in resourcemanager

knaufk commented on pull request #18662: URL: https://github.com/apache/flink/pull/18662#issuecomment-1053646850 Thank you for opening the PR? @dmvk could you have a quick look? @xuzifu666 could you edit your commit message so that it starts with "[hotfix] [runtime]"? -- Th

[GitHub] [flink] knaufk merged pull request #18904: [hotfix]fix method name typos

knaufk merged pull request #18904: URL: https://github.com/apache/flink/pull/18904 -- 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] knaufk merged pull request #18855: [hotfix][sqlclient][docs] Improved sql client docs

knaufk merged pull request #18855: URL: https://github.com/apache/flink/pull/18855 -- 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] knaufk commented on a change in pull request #18917: error

knaufk commented on a change in pull request #18917: URL: https://github.com/apache/flink/pull/18917#discussion_r815476538 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -97,13 +97,14 @@ If only the value of Kafka ```ConsumerRecord``` is needed, you can u

[GitHub] [flink] flinkbot edited a comment on pull request #18923: [FLINK-26373][connector/kinesis] Renaming KinesisDataStreams module to KinesisStreams

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

[jira] [Commented] (FLINK-26139) Improve JobStatus tracking and handle different job states

[ https://issues.apache.org/jira/browse/FLINK-26139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498596#comment-17498596 ] Gyula Fora commented on FLINK-26139: CANCELLED: I think the only question here is wh

[jira] [Assigned] (FLINK-26356) Revisit the create of RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26356: -- Assignee: Aitozi > Revisit the create of RestClusterClient >

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18923: [FLINK-26373][connector/kinesis] Renaming KinesisDataStreams module to KinesisStreams

flinkbot edited a comment on pull request #18923: URL: https://github.com/apache/flink/pull/18923#issuecomment-1050968682 ## CI report: * Unknown: [CANCELED](TBD) * eeaeb7da08512252a880b5b8132152202fb3f7b2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-462

[GitHub] [flink] flinkbot edited a comment on pull request #18923: [FLINK-26373][connector/kinesis] Renaming KinesisDataStreams module to KinesisStreams

flinkbot edited a comment on pull request #18923: URL: https://github.com/apache/flink/pull/18923#issuecomment-1050968682 ## CI report: * Unknown: [CANCELED](TBD) * eeaeb7da08512252a880b5b8132152202fb3f7b2 UNKNOWN Bot commands The @flinkbot bot supports the fo

[GitHub] [flink] vahmed-hamdy commented on pull request #18923: [FLINK-26373][connector/kinesis] Renaming KinesisDataStreams module to KinesisStreams

vahmed-hamdy commented on pull request #18923: URL: https://github.com/apache/flink/pull/18923#issuecomment-1053540972 @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 spe

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

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

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

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

[jira] [Updated] (FLINK-20912) Increase Log and Metric: Time consumed by Checkpoint Restore

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

[jira] [Updated] (FLINK-15507) Activate local recovery for RocksDB backends by default

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

[jira] [Updated] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure

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

  1   2   >