[jira] [Updated] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

2023-08-17 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-32791: - Attachment: image-2023-08-18-14-56-19-198.png > Release Testing: Verify FLIP-308: Support Time Travel >

[jira] [Updated] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

2023-08-17 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-32791: - Attachment: image-2023-08-18-14-55-18-883.png > Release Testing: Verify FLIP-308: Support Time Travel >

[jira] [Updated] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

2023-08-17 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-32791: - Attachment: image-2023-08-18-14-55-55-817.png > Release Testing: Verify FLIP-308: Support Time Travel >

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

2023-08-17 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755817#comment-17755817 ] Sergey Nuyanzin commented on FLINK-32523: - https://dev.azure.com/apache-flink/ap

[GitHub] [flink] WencongLiu commented on pull request #23179: [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle

2023-08-17 Thread via GitHub
WencongLiu commented on PR #23179: URL: https://github.com/apache/flink/pull/23179#issuecomment-1683406747 These fixup commits are squashed now. -- 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 th

[jira] [Updated] (FLINK-32876) ExecutionTimeBasedSlowTaskDetector treats unscheduled tasks as slow tasks and causes speculative execution to fail.

2023-08-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-32876: Affects Version/s: 1.17.1 > ExecutionTimeBasedSlowTaskDetector treats unscheduled tasks as slow tasks and

[jira] [Closed] (FLINK-32876) ExecutionTimeBasedSlowTaskDetector treats unscheduled tasks as slow tasks and causes speculative execution to fail.

2023-08-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-32876. --- Fix Version/s: 1.17.2 Resolution: Fixed master/1.18: 4bce9c09ca4fdf3ad8bf95ba5cf4ca361acea156 1.17: 3

[GitHub] [flink] zhuzhurk closed pull request #23222: [FLINK-32876][runtime] Prevent ExecutionTimeBasedSlowTaskDetector from identifying tasks in CREATED state as slow tasks.

2023-08-17 Thread via GitHub
zhuzhurk closed pull request #23222: [FLINK-32876][runtime] Prevent ExecutionTimeBasedSlowTaskDetector from identifying tasks in CREATED state as slow tasks. URL: https://github.com/apache/flink/pull/23222 -- This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] xuzifu666 commented on pull request #23220: [FLINK-32871][SQL] Support BuiltInMethod TO_TIMESTAMP with timezone options

2023-08-17 Thread via GitHub
xuzifu666 commented on PR #23220: URL: https://github.com/apache/flink/pull/23220#issuecomment-1683400101 @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 specific comment.

[GitHub] [flink] xuzifu666 closed pull request #23220: [FLINK-32871][SQL] Support BuiltInMethod TO_TIMESTAMP with timezone options

2023-08-17 Thread via GitHub
xuzifu666 closed pull request #23220: [FLINK-32871][SQL] Support BuiltInMethod TO_TIMESTAMP with timezone options URL: https://github.com/apache/flink/pull/23220 -- 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

[jira] [Commented] (FLINK-32658) State should not be silently removed when ignore-unclaimed-state is false

2023-08-17 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755814#comment-17755814 ] Rui Fan commented on FLINK-32658: - Thanks [~masteryhx] for the valuable feedback, I will

[GitHub] [flink] flinkbot commented on pull request #23236: [FLINK-32836][JUnit5 Migration] Migrate the checkpoint package of flink-runtime module to junit5

2023-08-17 Thread via GitHub
flinkbot commented on PR #23236: URL: https://github.com/apache/flink/pull/23236#issuecomment-1683365589 ## CI report: * e7ec08f7053c61c883290196b5c3830dce0b0f45 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32836) [JUnit5 Migration] The checkpoint package of flink-runtime module

2023-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32836: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] The checkpoint package of flink

[GitHub] [flink] xuzifu666 commented on pull request #23220: [FLINK-32871][SQL] Support BuiltInMethod TO_TIMESTAMP with timezone options

2023-08-17 Thread via GitHub
xuzifu666 commented on PR #23220: URL: https://github.com/apache/flink/pull/23220#issuecomment-1683341480 @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 specific comment.

[jira] [Closed] (FLINK-32797) Release Testing: Verify FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

2023-08-17 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-32797. - Fix Version/s: (was: 1.18.0) Resolution: Won't Do > Release Testing: Verify FLIP-288:

[jira] [Commented] (FLINK-32797) Release Testing: Verify FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

2023-08-17 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755795#comment-17755795 ] Qingsheng Ren commented on FLINK-32797: --- Closing as FLIP-288 is a Kafka connector

[GitHub] [flink] PatrickRen commented on pull request #23123: [FLINK-32523] Fix Timeout and Assert Error for NotifyCheckpointAbortedITCase#testNotifyCheckpointAborted

2023-08-17 Thread via GitHub
PatrickRen commented on PR #23123: URL: https://github.com/apache/flink/pull/23123#issuecomment-1683320068 @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 specific comment

[jira] [Commented] (FLINK-32658) State should not be silently removed when ignore-unclaimed-state is false

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755792#comment-17755792 ] Hangxiang Yu commented on FLINK-32658: -- Thanks a lot for the proposal, I think it m

[GitHub] [flink] xiangyuf commented on pull request #23230: [FLINK-32880][flink-runtime]Fulfill redundant taskmanagers periodical…

2023-08-17 Thread via GitHub
xiangyuf commented on PR #23230: URL: https://github.com/apache/flink/pull/23230#issuecomment-1683319254 @huwh Thanks for review, all comments resolved. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Commented] (FLINK-32806) EmbeddedJobResultStore keeps the non-dirty job entries forever

2023-08-17 Thread hk__lrzy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755791#comment-17755791 ] hk__lrzy commented on FLINK-32806: -- [~mapohl]  I am interesting in this issue, can you

[GitHub] [flink-ml] Fanoid commented on pull request #252: [FLINK-32889] Fix calcuation of weighted areaUnderROC and areaUnderPRC in BinaryClassificationEvaluator

2023-08-17 Thread via GitHub
Fanoid commented on PR #252: URL: https://github.com/apache/flink-ml/pull/252#issuecomment-1683304453 @weibozhao Could you help review this PR? -- 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] [Resolved] (FLINK-32879) slotmanager.max-total-resource.cpu/memory should be ignored in standalone mode.

2023-08-17 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32879. --- Fix Version/s: 1.18.0 (was: 1.19.0) Resolution: Fixed > slotmanager.ma

[jira] [Commented] (FLINK-32879) slotmanager.max-total-resource.cpu/memory should be ignored in standalone mode.

2023-08-17 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755787#comment-17755787 ] Weihua Hu commented on FLINK-32879: --- Resolved in master: c8cbb0e2dec6ed505ce749c453e4f

[GitHub] [flink] huwh merged pull request #23231: [FLINK-32879][flink-runtime]Ignore slotmanager.max-total-resource.cpu…

2023-08-17 Thread via GitHub
huwh merged PR #23231: URL: https://github.com/apache/flink/pull/23231 -- 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...@flink.apache.o

[jira] [Updated] (FLINK-32879) slotmanager.max-total-resource.cpu/memory should be ignored in standalone mode.

2023-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32879: --- Labels: pull-request-available (was: ) > slotmanager.max-total-resource.cpu/memory should b

[GitHub] [flink] flinkbot commented on pull request #23235: [FLINK-32869][e2e] Fix Kubernetes tests on aarch64

2023-08-17 Thread via GitHub
flinkbot commented on PR #23235: URL: https://github.com/apache/flink/pull/23235#issuecomment-1683277105 ## CI report: * 65179e68769e35cd924eb062f356746ed1c29ee5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] xiangyuf commented on pull request #23231: [FLINK-32879][flink-runtime]Ignore slotmanager.max-total-resource.cpu…

2023-08-17 Thread via GitHub
xiangyuf commented on PR #23231: URL: https://github.com/apache/flink/pull/23231#issuecomment-1683277093 > Hi, @xiangyuf , this pr belongs to https://issues.apache.org/jira/browse/FLINK-32879, Please update the commit message and PR title Hi @huwh , thanks for reply. Commit message a

[jira] [Commented] (FLINK-32869) Flink Kubernetes related tests failed to run on aarch64

2023-08-17 Thread Maomao Min (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755786#comment-17755786 ] Maomao Min commented on FLINK-32869: Thanks [~mapohl] ! I have already created a PR

[jira] [Updated] (FLINK-32869) Flink Kubernetes related tests failed to run on aarch64

2023-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32869: --- Labels: pull-request-available (was: ) > Flink Kubernetes related tests failed to run on aa

[GitHub] [flink] mimaomao opened a new pull request, #23235: [FLINK-32869][e2e] Fix Kubernetes tests on aarch64

2023-08-17 Thread via GitHub
mimaomao opened a new pull request, #23235: URL: https://github.com/apache/flink/pull/23235 ## What is the purpose of the change This pull request fixes Flink Kubernetes related tests on `aarch64` architecture. ## Brief change log - Download both `crictl` and `cr

[jira] [Resolved] (FLINK-6027) Ignore the exception thrown by the subsuming of old completed checkpoints

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-6027. - Resolution: Fixed I saw the pr is merged and the problem has been resolved, just marked as resol

[jira] [Closed] (FLINK-4620) Automatically creating savepoints

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-4620. --- Resolution: Not A Problem Close this as no intention in this direction just like FLINK-4511. Consider

[jira] [Commented] (FLINK-4620) Automatically creating savepoints

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755783#comment-17755783 ] Hangxiang Yu commented on FLINK-4620: - Close this as no intention in this direction j

[jira] (FLINK-4620) Automatically creating savepoints

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4620 ] Hangxiang Yu deleted comment on FLINK-4620: - was (Author: masteryhx): Close this as no intention in this direction just like FLINK-4511. Considering current design of checkpoint and savepoint,

[jira] [Commented] (FLINK-32889) BinaryClassificationEvaluator gives wrong weighted AUC value

2023-08-17 Thread Fan Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755780#comment-17755780 ] Fan Hong commented on FLINK-32889: -- BTW, the area under PRC is also found incorrect. Py

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

2023-08-17 Thread via GitHub
WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1297932131 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java: ## @@ -262,34 +262,67 @@ public void grantLeadership(UUID le

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

2023-08-17 Thread via GitHub
WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1297931816 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java: ## @@ -489,19 +522,29 @@ private boolean isRunning() {

[jira] [Closed] (FLINK-26196) error when Incremental Checkpoints by RocksDb

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-26196. Resolution: Cannot Reproduce Hi, [~hjw]  I closed this due to lacking more specific information an

[GitHub] [flink] flinkbot commented on pull request #23234: [FLINK-32668][e2e] fix up watchdog timeout error msg in common.sh

2023-08-17 Thread via GitHub
flinkbot commented on PR #23234: URL: https://github.com/apache/flink/pull/23234#issuecomment-1683262070 ## CI report: * fa11774034966d81cee71ebcf5c6f4d733dbbc7a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-15424) Make all AppendingState#add respect the java doc

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755777#comment-17755777 ] Hangxiang Yu commented on FLINK-15424: -- Hi, [~klion26]  I saw this problem still e

[jira] [Updated] (FLINK-32889) BinaryClassificationEvaluator gives wrong weighted AUC value

2023-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32889: --- Labels: pull-request-available (was: ) > BinaryClassificationEvaluator gives wrong weighted

[GitHub] [flink-ml] Fanoid opened a new pull request, #252: [FLINK-32889] Fix calcuation of weighted areaUnderROC and areaUnderPRC in BinaryClassificationEvaluator

2023-08-17 Thread via GitHub
Fanoid opened a new pull request, #252: URL: https://github.com/apache/flink-ml/pull/252 ## What is the purpose of the change Right now, BinaryClassificationEvaluator gives wrong areaUnderROC (auROC) and areaUnderPRC (auPRC) values when a weight column provided. This PR provides fix

[jira] [Commented] (FLINK-13194) Add explicit clarification about thread-safety of state in document

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755776#comment-17755776 ] Hangxiang Yu commented on FLINK-13194: -- Hi, [~yunta]  Kindly ping. Are you still wo

[jira] [Updated] (FLINK-32668) fix up watchdog timeout error msg in common.sh(e2e test)

2023-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32668: --- Labels: pull-request-available (was: ) > fix up watchdog timeout error msg in common.sh(e2

[GitHub] [flink] loserwang1024 opened a new pull request, #23234: [FLINK-32668][e2e] fix up watchdog timeout error msg in common.sh

2023-08-17 Thread via GitHub
loserwang1024 opened a new pull request, #23234: URL: https://github.com/apache/flink/pull/23234 ### What is the purpose of the change As showed in [FLINK-32668](https://issues.apache.org/jira/browse/FLINK-32668), an error occurs when watch dog thread exits before killed. ### Brie

[GitHub] [flink] masteryhx commented on pull request #7013: [FLINK-5601][Checkpointing] Watermark checkpointing

2023-08-17 Thread via GitHub
masteryhx commented on PR #7013: URL: https://github.com/apache/flink/pull/7013#issuecomment-1683256567 Hi, @Jiayi-Liao I think it's useful. So just kindly ping. Are you still working on this ? -- This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755775#comment-17755775 ] Hangxiang Yu commented on FLINK-26586: -- Hi, [~Matthias Schwalbe] , I think it makes

[jira] [Closed] (FLINK-32653) Add doc for catalog store

2023-08-17 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32653. - Fix Version/s: 1.19.0 Resolution: Fixed Thanks [~hackergin], fixed by 5628c7097875be4bd56fc7805db

[GitHub] [flink] FangYongs merged pull request #23110: [FLINK-32653][docs] Add doc for catalog store

2023-08-17 Thread via GitHub
FangYongs merged PR #23110: URL: https://github.com/apache/flink/pull/23110 -- 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...@flink.apa

[jira] [Comment Edited] (FLINK-29328) 【Flink is having problems using the status expiration setting】

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755772#comment-17755772 ] Hangxiang Yu edited comment on FLINK-29328 at 8/18/23 2:31 AM: ---

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

2023-08-17 Thread via GitHub
WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1297920993 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java: ## @@ -392,7 +392,7 @@ private void forwardResultFuture(

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

2023-08-17 Thread via GitHub
WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1297920162 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java: ## @@ -376,7 +376,7 @@ private void confirmLeadership(

[jira] [Closed] (FLINK-29328) 【Flink is having problems using the status expiration setting】

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-29328. Resolution: Not A Bug Hi, [~Jason_H]  I aggree with [~yunta] , this exception is only be thrown wh

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

2023-08-17 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755771#comment-17755771 ] Qingsheng Ren commented on FLINK-32523: --- https://dev.azure.com/apache-flink/apache

[jira] [Resolved] (FLINK-32350) FLIP-311: Support Call Stored Procedure

2023-08-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-32350. -- Fix Version/s: 1.18.0 Resolution: Fixed > FLIP-311: Support Call Stored Procedure > ---

[jira] [Resolved] (FLINK-32356) Add document for calling procedure

2023-08-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-32356. -- Resolution: Fixed master: 18b4759cc3405e784205f6df55dd7a4f0ee2d3b7 13cb456eb30dc50dbd47885b7471cd02c

[jira] [Commented] (FLINK-31268) OperatorCoordinator.Context#metricGroup will return null when restore from a savepoint

2023-08-17 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755769#comment-17755769 ] Qingsheng Ren commented on FLINK-31268: --- master: eab68f31193f3067ae3b58223e77851b7

[jira] [Resolved] (FLINK-31268) OperatorCoordinator.Context#metricGroup will return null when restore from a savepoint

2023-08-17 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-31268. --- Resolution: Fixed > OperatorCoordinator.Context#metricGroup will return null when restore fr

[GitHub] [flink] PatrickRen merged pull request #22048: [FLINK-31268][metrics] Change not to initialize operator coordinator metric group lazily

2023-08-17 Thread via GitHub
PatrickRen merged PR #22048: URL: https://github.com/apache/flink/pull/22048 -- 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...@flink.ap

[jira] [Commented] (FLINK-28819) The natural time of day TTL

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755768#comment-17755768 ] Hangxiang Yu commented on FLINK-28819: -- Hi,[~kcz]  Could you also share your speci

[jira] [Commented] (FLINK-32881) Client supports making savepoints in detach mode

2023-08-17 Thread Renxiang Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755767#comment-17755767 ] Renxiang Zhou commented on FLINK-32881: --- [~masteryhx] Many thanks~ ;) > Client su

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755766#comment-17755766 ] Hangxiang Yu commented on FLINK-27681: -- Hi, [~Ming Li] Thanks for reporting this. W

[GitHub] [flink] luoyuxia closed pull request #23130: [Flink-32356][doc] Add doc for procedure

2023-08-17 Thread via GitHub
luoyuxia closed pull request #23130: [Flink-32356][doc] Add doc for procedure URL: https://github.com/apache/flink/pull/23130 -- 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

[jira] [Commented] (FLINK-32797) Release Testing: Verify FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

2023-08-17 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755765#comment-17755765 ] Hongshun Wang commented on FLINK-32797: --- It has been already done > Release Testi

[GitHub] [flink] luoyuxia commented on pull request #23130: [Flink-32356][doc] Add doc for procedure

2023-08-17 Thread via GitHub
luoyuxia commented on PR #23130: URL: https://github.com/apache/flink/pull/23130#issuecomment-1683234136 @hackergin Thanks for review. Merging -- 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

[jira] [Commented] (FLINK-32881) Client supports making savepoints in detach mode

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755763#comment-17755763 ] Hangxiang Yu commented on FLINK-32881: -- [~zhourenxiang] Sure, assigned to you, plea

[jira] [Assigned] (FLINK-32881) Client supports making savepoints in detach mode

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32881: Assignee: Renxiang Zhou (was: Hangxiang Yu) > Client supports making savepoints in detac

[jira] [Assigned] (FLINK-32881) Client supports making savepoints in detach mode

2023-08-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-32881: Assignee: Hangxiang Yu > Client supports making savepoints in detach mode > -

[GitHub] [flink] X-czh commented on pull request #23198: [FLINK-32856][JUnit5 Migration] Migrate the testutils, throughput and throwable packages of flink-runtime module to junit5

2023-08-17 Thread via GitHub
X-czh commented on PR #23198: URL: https://github.com/apache/flink/pull/23198#issuecomment-1683231044 Thanks, LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubs

[jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

2023-08-17 Thread yong yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755761#comment-17755761 ] yong yang commented on FLINK-28693: --- watermark with column by udf may cause a error. w

[GitHub] [flink] hackergin commented on pull request #23110: [FLINK-32653][docs] Add doc for catalog store

2023-08-17 Thread via GitHub
hackergin commented on PR #23110: URL: https://github.com/apache/flink/pull/23110#issuecomment-1683221982 @FangYongs Thanks for reviewing the pr. -- 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

[GitHub] [flink] hackergin commented on pull request #23130: [Flink-32356][doc] Add doc for procedure

2023-08-17 Thread via GitHub
hackergin commented on PR #23130: URL: https://github.com/apache/flink/pull/23130#issuecomment-1683217081 @luoyuxia Thanks for the update, LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to th

[jira] [Updated] (FLINK-32807) when i use emitUpdateWithRetract of udtagg,bug error

2023-08-17 Thread yong yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yong yang updated FLINK-32807: -- Description: 参考: [https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/functions

[jira] [Commented] (FLINK-32832) Row对象不兼容scala int

2023-08-17 Thread yong yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755757#comment-17755757 ] yong yang commented on FLINK-32832: --- The paradox is that the first int can make scala

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #248: [FLINK-32704] Supports spilling to disk when feedback channel memory buffer is full

2023-08-17 Thread via GitHub
lindong28 commented on code in PR #248: URL: https://github.com/apache/flink-ml/pull/248#discussion_r1297881781 ## flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java: ## @@ -422,16 +430,44 @@ public void close() throw

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #248: [FLINK-32704] Supports spilling to disk when feedback channel memory buffer is full

2023-08-17 Thread via GitHub
lindong28 commented on code in PR #248: URL: https://github.com/apache/flink-ml/pull/248#discussion_r1297874568 ## flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/typeinfo/IterationRecordSerializer.java: ## @@ -106,7 +106,7 @@ public int get

[jira] [Commented] (FLINK-32507) Document KafkaSink SinkWriterMetricGroup metrics

2023-08-17 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755732#comment-17755732 ] Mason Chen commented on FLINK-32507: Yes it is, closed and marked as dup > Document

[jira] [Closed] (FLINK-32507) Document KafkaSink SinkWriterMetricGroup metrics

2023-08-17 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen closed FLINK-32507. -- Resolution: Duplicate > Document KafkaSink SinkWriterMetricGroup metrics > ---

[jira] [Updated] (FLINK-27284) KafkaSinkITCase$IntegrationTests.testScaleUp failed on azures due to failed to create topic

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27284: --- Labels: auto-deprioritized-major stale-assigned test-stability (was: auto-deprioritized-maj

[jira] [Updated] (FLINK-32744) HiveDialectQueryITCase.testWithOverWindow fails with timeout

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

[jira] [Updated] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27756: --- Labels: pull-request-available stale-assigned test-stability (was: pull-request-available t

[jira] [Updated] (FLINK-27146) [JUnit5 Migration] Module: flink-filesystems

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27146: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-26966) Implement incremental checkpoints

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26966: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-27051) CompletedCheckpoint.DiscardObject.discard is not idempotent

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27051: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-26666) Improve the error message of pyflink and flink version mismatch

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27529: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-27758) [JUnit5 Migration] Module: flink-table-runtime

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27758: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-27429) Implement Vertica JDBC Dialect

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27429: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-27637) Optimize the log information when the asynchronous part of checkpoint is canceled

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27637: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-32248) Incorrect AssertJ usage

2023-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32248: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Commented] (FLINK-32893) Make client.id configurable from KafkaSource

2023-08-17 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755707#comment-17755707 ] Mason Chen commented on FLINK-32893: I was talking to [~ryanvanhuuksloot] offline, h

[jira] [Created] (FLINK-32893) Make client.id configurable from KafkaSource

2023-08-17 Thread Mason Chen (Jira)
Mason Chen created FLINK-32893: -- Summary: Make client.id configurable from KafkaSource Key: FLINK-32893 URL: https://issues.apache.org/jira/browse/FLINK-32893 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-32892) Upgrade kafka-clients dependency to 3.4.x

2023-08-17 Thread Mason Chen (Jira)
Mason Chen created FLINK-32892: -- Summary: Upgrade kafka-clients dependency to 3.4.x Key: FLINK-32892 URL: https://issues.apache.org/jira/browse/FLINK-32892 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-32891) Opensearch SQL connector crash job on upsert from multiple sources (409 version conflict)

2023-08-17 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755686#comment-17755686 ] Andriy Redko commented on FLINK-32891: -- Thanks [~thebranchnotmerged] , I think it c

[GitHub] [flink] dmvk commented on a diff in pull request #23229: [FLINK-32888] Handle hasNext() throwing EndOfDataDecoderException

2023-08-17 Thread via GitHub
dmvk commented on code in PR #23229: URL: https://github.com/apache/flink/pull/23229#discussion_r129701 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/MultipartUploadExtension.java: ## @@ -119,6 +120,12 @@ public void before(ExtensionContext context) throws Ex

[GitHub] [flink] dmvk commented on a diff in pull request #23229: [FLINK-32888] Handle hasNext() throwing EndOfDataDecoderException

2023-08-17 Thread via GitHub
dmvk commented on code in PR #23229: URL: https://github.com/apache/flink/pull/23229#discussion_r129701 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/MultipartUploadExtension.java: ## @@ -119,6 +120,12 @@ public void before(ExtensionContext context) throws Ex

[GitHub] [flink] flinkbot commented on pull request #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

2023-08-17 Thread via GitHub
flinkbot commented on PR #23233: URL: https://github.com/apache/flink/pull/23233#issuecomment-1682740169 ## CI report: * a142c4df6d02d3b650fa59e1572859c79246 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32847) [JUnit5 Migration] The operators package of flink-runtime module

2023-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32847: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] The operators package of flink-

[GitHub] [flink] Jiabao-Sun opened a new pull request, #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

2023-08-17 Thread via GitHub
Jiabao-Sun opened a new pull request, #23233: URL: https://github.com/apache/flink/pull/23233 [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime ## What is the purpose of the change [flink-runtime][JUnit5 Migration] Module: The

[GitHub] [flink] venkata91 commented on a diff in pull request #23164: [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

2023-08-17 Thread via GitHub
venkata91 commented on code in PR #23164: URL: https://github.com/apache/flink/pull/23164#discussion_r1297514150 ## flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java: ## @@ -360,11 +362,27 @@ List registerProvidedLocalResources() {

  1   2   3   >