[jira] [Resolved] (FLINK-36344) Introduce lastCheckpointCompletedTimestamp metrics

[ https://issues.apache.org/jira/browse/FLINK-36344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-36344. -- Fix Version/s: (was: 1.20.1) Resolution: Fixed merged in master: e5ce2c34d81ff9c8b207709838

[jira] [Commented] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure

[ https://issues.apache.org/jira/browse/FLINK-35012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885795#comment-17885795 ] Xuannan Su commented on FLINK-35012: https://dev.azure.com/apache-flink/apache-flink

[jira] [Updated] (FLINK-36064) Refactor REST API for Client and Operator Coordinator Communication to Use operatorUid.

[ https://issues.apache.org/jira/browse/FLINK-36064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-36064: -- Summary: Refactor REST API for Client and Operator Coordinator Communication to Use operatorUid. (was

[jira] [Updated] (FLINK-36064) Refactor CollectResultIterator to eliminate dependency on OperatorID

[ https://issues.apache.org/jira/browse/FLINK-36064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-36064: -- Description: Currently, the REST API between clients and operator coordinators relies on the operator

[jira] [Created] (FLINK-36408) MySQL pipeline connector could not work with FLOAT type with precision

yux created FLINK-36408: --- Summary: MySQL pipeline connector could not work with FLOAT type with precision Key: FLINK-36408 URL: https://issues.apache.org/jira/browse/FLINK-36408 Project: Flink Issue T

[jira] [Resolved] (FLINK-36395) Graceful quit for Forst StateBackend

[ https://issues.apache.org/jira/browse/FLINK-36395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36395. - Fix Version/s: 2.0-preview Resolution: Fixed > Graceful quit for Forst StateBackend > ---

[jira] [Commented] (FLINK-36403) K8s native mode Use ConfigMap to get a better experience

[ https://issues.apache.org/jira/browse/FLINK-36403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885779#comment-17885779 ] gaoyan commented on FLINK-36403: [~xiqian_yu]  # This solution cannot resolve the JAR d

[jira] [Resolved] (FLINK-35666) Implement Aggregating Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-35666. - Fix Version/s: 2.0-preview Assignee: Jie Pu Resolution: Fixed > Implement Aggreg

[jira] [Commented] (FLINK-35666) Implement Aggregating Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885778#comment-17885778 ] Zakelly Lan commented on FLINK-35666: - Merge 773ea76 into master > Implement Aggre

[jira] [Commented] (FLINK-36348) Netty shuffle direct memory consumption end-to-end test failed due to direct memory OOM

[ https://issues.apache.org/jira/browse/FLINK-36348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885775#comment-17885775 ] Xuannan Su commented on FLINK-36348: master(2.0): 338d0246eccd66fbc5e20d433c8cdd090e

[jira] [Resolved] (FLINK-36348) Netty shuffle direct memory consumption end-to-end test failed due to direct memory OOM

[ https://issues.apache.org/jira/browse/FLINK-36348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuannan Su resolved FLINK-36348. Resolution: Fixed > Netty shuffle direct memory consumption end-to-end test failed due to direct

[jira] [Resolved] (FLINK-36396) Remove dependency flink-java in all flink-table-api-xxx module

[ https://issues.apache.org/jira/browse/FLINK-36396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-36396. Fix Version/s: 2.0-preview Resolution: Resolved > Remove dependency flink-java in all flink-table-a

[jira] [Resolved] (FLINK-36386) Remove dependency flink-java in flink-table-planner-loader and flink-table-planner-loader-bundle module

[ https://issues.apache.org/jira/browse/FLINK-36386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-36386. Fix Version/s: 2.0-preview Resolution: Resolved > Remove dependency flink-java in flink-table-plann

[jira] [Resolved] (FLINK-36391) Remove dependency flink-java in flink-table-runtime module

[ https://issues.apache.org/jira/browse/FLINK-36391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-36391. Fix Version/s: 2.0-preview Resolution: Resolved > Remove dependency flink-java in flink-table-runti

[jira] [Commented] (FLINK-36391) Remove dependency flink-java in flink-table-runtime module

[ https://issues.apache.org/jira/browse/FLINK-36391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885769#comment-17885769 ] xuyang commented on FLINK-36391: Resolved in parent umbrella. > Remove dependency flink

[jira] [Commented] (FLINK-36386) Remove dependency flink-java in flink-table-planner-loader and flink-table-planner-loader-bundle module

[ https://issues.apache.org/jira/browse/FLINK-36386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885767#comment-17885767 ] xuyang commented on FLINK-36386: Resolved in parent umbrella. > Remove dependency flink

[jira] [Commented] (FLINK-36396) Remove dependency flink-java in all flink-table-api-xxx module

[ https://issues.apache.org/jira/browse/FLINK-36396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885770#comment-17885770 ] xuyang commented on FLINK-36396: Resolved in parent umbrella. > Remove dependency flink

[jira] [Commented] (FLINK-36387) Remove dependency flink-java in flink-table-planner module

[ https://issues.apache.org/jira/browse/FLINK-36387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885768#comment-17885768 ] xuyang commented on FLINK-36387: Resolved in parent umbrella. > Remove dependency flink

[jira] [Resolved] (FLINK-36387) Remove dependency flink-java in flink-table-planner module

[ https://issues.apache.org/jira/browse/FLINK-36387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-36387. Fix Version/s: 2.0-preview Resolution: Resolved > Remove dependency flink-java in flink-table-plann

[jira] [Resolved] (FLINK-36384) Remove dependency flink-java in flink-sql-client module

[ https://issues.apache.org/jira/browse/FLINK-36384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-36384. Fix Version/s: 2.0-preview Resolution: Resolved > Remove dependency flink-java in flink-sql-client

[jira] [Resolved] (FLINK-36383) Remove dependency flink-java in flink-sql-jdbc-driver and flink-sql-jdbc-driver-bundle module

[ https://issues.apache.org/jira/browse/FLINK-36383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-36383. Fix Version/s: 2.0-preview Resolution: Resolved > Remove dependency flink-java in flink-sql-jdbc-dr

[jira] [Commented] (FLINK-36384) Remove dependency flink-java in flink-sql-client module

[ https://issues.apache.org/jira/browse/FLINK-36384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885765#comment-17885765 ] xuyang commented on FLINK-36384: Resolved in parent umbrella. > Remove dependency flink

[jira] [Resolved] (FLINK-36385) Remove dependency flink-java in flink-sql-gateway and flink-sql-gateway-api module

[ https://issues.apache.org/jira/browse/FLINK-36385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-36385. Fix Version/s: 2.0-preview Resolution: Resolved > Remove dependency flink-java in flink-sql-gateway

[jira] [Commented] (FLINK-36385) Remove dependency flink-java in flink-sql-gateway and flink-sql-gateway-api module

[ https://issues.apache.org/jira/browse/FLINK-36385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885766#comment-17885766 ] xuyang commented on FLINK-36385: Resolved in parent umbrella. > Remove dependency flink

[jira] [Commented] (FLINK-36383) Remove dependency flink-java in flink-sql-jdbc-driver and flink-sql-jdbc-driver-bundle module

[ https://issues.apache.org/jira/browse/FLINK-36383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885764#comment-17885764 ] xuyang commented on FLINK-36383: Resolved in parent umbrella. > Remove dependency flink

[jira] [Commented] (FLINK-36382) Remove dependency flink-java in flink-table-test-utils module

[ https://issues.apache.org/jira/browse/FLINK-36382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885763#comment-17885763 ] xuyang commented on FLINK-36382: Resolved in parent umbrella. > Remove dependency flink

[jira] [Resolved] (FLINK-36382) Remove dependency flink-java in flink-table-test-utils module

[ https://issues.apache.org/jira/browse/FLINK-36382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-36382. Fix Version/s: 2.0-preview Resolution: Resolved > Remove dependency flink-java in flink-table-test-

[jira] [Updated] (FLINK-36381) Remove legacy csv format in python module

[ https://issues.apache.org/jira/browse/FLINK-36381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36381: --- Description: Use `filesystem connector` and `csv format` instead (was:   * test_tumbling_group_window_over_

[jira] [Updated] (FLINK-36381) Remove legacy csv source/sink in python module

[ https://issues.apache.org/jira/browse/FLINK-36381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36381: --- Summary: Remove legacy csv source/sink in python module (was: Remove legacy csv format in python module) >

[jira] [Updated] (FLINK-36381) Remove legacy csv format in python module

[ https://issues.apache.org/jira/browse/FLINK-36381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36381: --- Summary: Remove legacy csv format in python module (was: Remove skip tag in python module caused by depreca

[jira] [Commented] (FLINK-36403) K8s native mode Use ConfigMap to get a better experience

[ https://issues.apache.org/jira/browse/FLINK-36403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885758#comment-17885758 ] yux commented on FLINK-36403: - +1 that repackaging images are not convenient and necessary c

[jira] [Resolved] (FLINK-36362) Remove dependency `flink-java` in table module

[ https://issues.apache.org/jira/browse/FLINK-36362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-36362. Resolution: Done > Remove dependency `flink-java` in table module > --

[jira] [Commented] (FLINK-36362) Remove dependency `flink-java` in table module

[ https://issues.apache.org/jira/browse/FLINK-36362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885757#comment-17885757 ] Weijie Guo commented on FLINK-36362: master(2.0) via fc10d3e1d639e485714b3e7a8511c23

[jira] [Updated] (FLINK-36362) Remove dependency `flink-java` in table module

[ https://issues.apache.org/jira/browse/FLINK-36362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36362: --- Affects Version/s: 2.0-preview > Remove dependency `flink-java` in table module > --

[jira] [Assigned] (FLINK-36362) Remove dependency `flink-java` in table module

[ https://issues.apache.org/jira/browse/FLINK-36362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-36362: -- Assignee: xuyang > Remove dependency `flink-java` in table module > -

[jira] [Updated] (FLINK-36407) SchemaRegistry doesn't shutdown its underlying ExecutorService upon closing

[ https://issues.apache.org/jira/browse/FLINK-36407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergei Morozov updated FLINK-36407: --- Attachment: Flink36407Reproducer.java > SchemaRegistry doesn't shutdown its underlying Execu

[jira] [Updated] (FLINK-36407) SchemaRegistry doesn't shutdown its underlying ExecutorService upon closing

[ https://issues.apache.org/jira/browse/FLINK-36407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergei Morozov updated FLINK-36407: --- Description: The {{SchemaRegistry}} class exclusively uses an {{ExecutorService}} referenced

[jira] [Created] (FLINK-36407) SchemaRegistry doesn't shutdown its underlying ExecutorService upon closing

Sergei Morozov created FLINK-36407: -- Summary: SchemaRegistry doesn't shutdown its underlying ExecutorService upon closing Key: FLINK-36407 URL: https://issues.apache.org/jira/browse/FLINK-36407 Proje

[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885746#comment-17885746 ] David Anderson commented on FLINK-5601: --- [~juntaozhang] While this is a source of n

[jira] [Closed] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled

[ https://issues.apache.org/jira/browse/FLINK-36389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-36389. - > Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled > --

[jira] [Resolved] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled

[ https://issues.apache.org/jira/browse/FLINK-36389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-36389. --- Fix Version/s: 2.0.0 Resolution: Fixed [{{18e1950}}|https://github.com/apache/flink/c

[jira] [Created] (FLINK-36406) MetadataApplier should be closed when the job stop

Sergei Morozov created FLINK-36406: -- Summary: MetadataApplier should be closed when the job stop Key: FLINK-36406 URL: https://issues.apache.org/jira/browse/FLINK-36406 Project: Flink Issue

[jira] [Comment Edited] (FLINK-14068) Use Java's Duration instead of Flink's Time

[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882175#comment-17882175 ] Matthias Pohl edited comment on FLINK-14068 at 9/29/24 2:32 PM: --

[jira] [Comment Edited] (FLINK-14068) Use Java's Duration instead of Flink's Time

[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882175#comment-17882175 ] Matthias Pohl edited comment on FLINK-14068 at 9/29/24 2:30 PM: --

[jira] [Commented] (FLINK-33634) Add Conditions to Flink CRD's Status field

[ https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885712#comment-17885712 ] david radley commented on FLINK-33634: -- Hi [~ryanvanhuuksloot] , Talking with [~la

[jira] [Resolved] (FLINK-36310) Remove per-job and run-application deprecated APIs

[ https://issues.apache.org/jira/browse/FLINK-36310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuhuang resolved FLINK-36310. - Resolution: Fixed > Remove per-job and run-application deprecated APIs > ---

[jira] [Commented] (FLINK-36310) Remove per-job and run-application deprecated APIs

[ https://issues.apache.org/jira/browse/FLINK-36310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885706#comment-17885706 ] xuhuang commented on FLINK-36310: - master(2.0) via fe97786366619042e2c5683297c90c8ec4c00

[jira] [Updated] (FLINK-36405) Fix startup issues on kerberos clusters

[ https://issues.apache.org/jira/browse/FLINK-36405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenyu Zheng updated FLINK-36405: - Description: Fount these error when startup on kerberos cluster. Error 1: renew user dismatched

[jira] [Created] (FLINK-36405) Fix startup issues on kerberos clusters

Chenyu Zheng created FLINK-36405: Summary: Fix startup issues on kerberos clusters Key: FLINK-36405 URL: https://issues.apache.org/jira/browse/FLINK-36405 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal

[ https://issues.apache.org/jira/browse/FLINK-36378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885697#comment-17885697 ] Jing Ge commented on FLINK-36378: - master: 6444f18ed36d6d47d70e82fba994fca549c8e0c0 > t

[jira] [Closed] (FLINK-36401) CI is not triggered for PRs

[ https://issues.apache.org/jira/browse/FLINK-36401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-36401. Resolution: Fixed > CI is not triggered for PRs > --- > >

[jira] [Assigned] (FLINK-36401) CI is not triggered for PRs

[ https://issues.apache.org/jira/browse/FLINK-36401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-36401: Assignee: Jing Ge > CI is not triggered for PRs > --- > >

[jira] [Commented] (FLINK-36401) CI is not triggered for PRs

[ https://issues.apache.org/jira/browse/FLINK-36401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885696#comment-17885696 ] Xintong Song commented on FLINK-36401: -- [~jingge] has helped re-started the ci-bot.

[jira] [Comment Edited] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal

[ https://issues.apache.org/jira/browse/FLINK-36378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885288#comment-17885288 ] Dylan He edited comment on FLINK-36378 at 9/29/24 10:14 AM:

[jira] [Commented] (FLINK-36400) 403 and 404 responses should be fatal

[ https://issues.apache.org/jira/browse/FLINK-36400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885695#comment-17885695 ] Lorenzo Nicora commented on FLINK-36400: This issue is coupled with FLINK-36404.

[jira] [Updated] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

[ https://issues.apache.org/jira/browse/FLINK-36404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36404: --- Description: *Issue* {{PrometheusSinkWriteException}} thrown by {{HttpResponseCallback}} do

[jira] [Updated] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

[ https://issues.apache.org/jira/browse/FLINK-36404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-36404: --- Description: *Issue* {{PrometheusSinkWriteException}} thrown by {{HttpResponseCallback}} do

[jira] [Created] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

Lorenzo Nicora created FLINK-36404: -- Summary: PrometheusSinkWriteException thrown by the response callback may not cause job to fail Key: FLINK-36404 URL: https://issues.apache.org/jira/browse/FLINK-36404

[jira] [Commented] (FLINK-36369) Move deprecated user-visible classes in table modules to the legacy package to make it easier to delete them later

[ https://issues.apache.org/jira/browse/FLINK-36369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885686#comment-17885686 ] Xintong Song commented on FLINK-36369: -- remove annotation in master: 74864b0b376cf2

[jira] [Created] (FLINK-36403) K8s native mode Use ConfigMap to get a better experience

gaoyan created FLINK-36403: -- Summary: K8s native mode Use ConfigMap to get a better experience Key: FLINK-36403 URL: https://issues.apache.org/jira/browse/FLINK-36403 Project: Flink Issue Type: Impr