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

2022-02-27 Thread Fabian Paul (Jira)
[ 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

2022-02-27 Thread Fabian Paul (Jira)
[ 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

2022-02-27 Thread Fabian Paul (Jira)
[ 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

2022-02-27 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498749#comment-17498749 ] Fabian Paul commented on FLINK-26357: - Merged in master: e2463ddace26601c6442dbaa68c198a27c9cfbcf >

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

2022-02-27 Thread GitBox
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:

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

2022-02-27 Thread Timo Walther (Jira)
[ 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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1047490231 ## CI report: * 74aea8329e1cfa728c8ff07cde3c92971e0a556d Azure:

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

2022-02-27 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498747#comment-17498747 ] Dawid Wysakowicz commented on FLINK-26052: -- Sure [~shenzhu0127] I can assign it to you. Just

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

2022-02-27 Thread Dawid Wysakowicz (Jira)
[ 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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1047490231 ## CI report: * 74aea8329e1cfa728c8ff07cde3c92971e0a556d Azure:

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread Matthias Pohl (Jira)
[ 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

2022-02-27 Thread Yun Gao (Jira)
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:

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

2022-02-27 Thread GitBox
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:

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

2022-02-27 Thread GitBox
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:

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

2022-02-27 Thread GitBox
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:

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

2022-02-27 Thread Yun Gao (Jira)
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

2022-02-27 Thread GitBox
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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18840: URL: https://github.com/apache/flink/pull/18840#issuecomment-1044222572 ## CI report: * 55065bc03cf829a97a47b609f5b0e0d6c1b37437 Azure:

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

2022-02-27 Thread GitBox
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:

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

2022-02-27 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498737#comment-17498737 ] Yang Wang commented on FLINK-26370: --- In the go implemented K8s operators, they usually have a

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

2022-02-27 Thread GitBox
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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18840: URL: https://github.com/apache/flink/pull/18840#issuecomment-1044222572 ## CI report: * 55065bc03cf829a97a47b609f5b0e0d6c1b37437 Azure:

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

2022-02-27 Thread Qingsheng Ren (Jira)
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:

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

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

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18899: URL: https://github.com/apache/flink/pull/18899#issuecomment-1048710698 ## CI report: * 651e557e3e844133723f25c2f5ac4e0ff7c0de22 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18899: URL: https://github.com/apache/flink/pull/18899#issuecomment-1048710698 ## CI report: * 651e557e3e844133723f25c2f5ac4e0ff7c0de22 Azure:

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18480: URL: https://github.com/apache/flink/pull/18480#issuecomment-1020209467 ## CI report: * df2c35e2bbf45b2b0fa47e9c5ae22de71ea5a293 Azure:

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

2022-02-27 Thread Yang Wang (Jira)
[ 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

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 5300f34a8dae108dba04828a5ed744242ea85a91 Azure:

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

2022-02-27 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498704#comment-17498704 ] Yang Wang commented on FLINK-26356: --- Thanks for the verification. I will look at the PR and make it

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread Yuan Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498699#comment-17498699 ] Yuan Huang commented on FLINK-25648: - Thank you for your time. Let me know if there needs any

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498698#comment-17498698 ] 张健 commented on FLINK-24677: [~TsReaper] hello,I see JingSong Lee do not leave further comments on our

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * 8c7270bf94228ed938028bb05fdc2519825026d4 Azure:

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * e9a702514010c81ff0d927209ac340c6b3644fbf Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18788: URL: https://github.com/apache/flink/pull/18788#issuecomment-1040866594 ## CI report: * e9a702514010c81ff0d927209ac340c6b3644fbf Azure:

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

2022-02-27 Thread ASF GitHub Bot (Jira)
[ 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

2022-02-27 Thread GitBox
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

2022-02-27 Thread GitBox
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 @@

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

2022-02-27 Thread Yun Tang (Jira)
[ 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

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

2022-02-27 Thread Spongebob (Jira)
[ 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

2022-02-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498687#comment-17498687 ] Aitozi commented on FLINK-26377: ok, i will take a look first before work on it. > Extract Reconciler

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

2022-02-27 Thread Spongebob (Jira)
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.

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18480: URL: https://github.com/apache/flink/pull/18480#issuecomment-1020209467 ## CI report: * df2c35e2bbf45b2b0fa47e9c5ae22de71ea5a293 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18480: URL: https://github.com/apache/flink/pull/18480#issuecomment-1020209467 ## CI report: * df2c35e2bbf45b2b0fa47e9c5ae22de71ea5a293 Azure:

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread realdengziqi (Jira)
[ 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.

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

2022-02-27 Thread weibo zhao (Jira)
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

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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

2022-02-27 Thread Shen Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498670#comment-17498670 ] Shen Zhu commented on FLINK-26052: -- Hi [~dwysakowicz] , I'm interested in translating these commits to

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18923: URL: https://github.com/apache/flink/pull/18923#issuecomment-1050968682 ## CI report: * 5967cbe7bc27936f5938f6d6ddcd1f31639d533b Azure:

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

2022-02-27 Thread GitBox
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:

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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

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

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

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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:

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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]"? --

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

2022-02-27 Thread GitBox
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:

[GitHub] [flink] knaufk merged pull request #18855: [hotfix][sqlclient][docs] Improved sql client docs

2022-02-27 Thread GitBox
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:

[GitHub] [flink] knaufk commented on a change in pull request #18917: error

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18923: URL: https://github.com/apache/flink/pull/18923#issuecomment-1050968682 ## CI report: * eeaeb7da08512252a880b5b8132152202fb3f7b2 Azure:

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

2022-02-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498596#comment-17498596 ] Gyula Fora commented on FLINK-26139: CANCELLED: I think the only question here is what to do with

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

2022-02-27 Thread Gyula Fora (Jira)
[ 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.

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310 ## CI report: * 6688ef9bfaaa9642a7255bf8437b17a7667874a2 Azure:

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

2022-02-27 Thread GitBox
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:

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
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

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310 ## CI report: * 0c8521ddff81d06560cc3b060670d3c8a3bbb991 Azure:

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

2022-02-27 Thread GitBox
flinkbot edited a comment on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310 ## CI report: * 0c8521ddff81d06560cc3b060670d3c8a3bbb991 Azure:

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

2022-02-27 Thread Flink Jira Bot (Jira)
[ 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:

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

2022-02-27 Thread Flink Jira Bot (Jira)
[ 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

2022-02-27 Thread Flink Jira Bot (Jira)
[ 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

  1   2   >