Re: [PR] [FLINK-34971]Add the function of History Server cleaning job archives regularly [flink]

2024-03-31 Thread via GitHub
d20162416 closed pull request #24592: [FLINK-34971]Add the function of History Server cleaning job archives regularly URL: https://github.com/apache/flink/pull/24592 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-34971) Add the function of History Server cleaning job archives regularly

2024-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34971: --- Labels: pull-request-available (was: ) > Add the function of History Server cleaning job

Re: [PR] Add the function of History Server cleaning job archives regularly [flink]

2024-03-31 Thread via GitHub
flinkbot commented on PR #24592: URL: https://github.com/apache/flink/pull/24592#issuecomment-2028664146 ## CI report: * 60580f94d942fb4d7accf9b43e9c53c762183202 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-34972) MigrationTestsSnapshotGenerator does not work properly for all subclasses of SnapshotMigrationTestBase

2024-03-31 Thread lincoln lee (Jira)
lincoln lee created FLINK-34972: --- Summary: MigrationTestsSnapshotGenerator does not work properly for all subclasses of SnapshotMigrationTestBase Key: FLINK-34972 URL:

[jira] [Commented] (FLINK-34738) "Deployment - YARN" Page for Flink CDC Chinese Documentation

2024-03-31 Thread Vincent Woo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17832554#comment-17832554 ] Vincent Woo commented on FLINK-34738: - I'm willing to handle this issue, could someone assign it to

[PR] Add the function of History Server cleaning job archives regularly [flink]

2024-03-31 Thread via GitHub
d20162416 opened a new pull request, #24592: URL: https://github.com/apache/flink/pull/24592 Currently, flink does not provide the ability to regularly clean the archives of completed jobs. I think this ability is necessary. When flink provides this ability, users can decide whether to

Re: [PR] [FLINK-34971]Add the function of History Server cleaning job archives… [flink]

2024-03-31 Thread via GitHub
flinkbot commented on PR #24593: URL: https://github.com/apache/flink/pull/24593#issuecomment-2028711002 ## CI report: * bdaa8dc9c5ab9840c554dc537af168670bcea851 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation

2024-03-31 Thread Vincent Woo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17832553#comment-17832553 ] Vincent Woo commented on FLINK-34736: - I'm willing to contribute, could someone assign this to me?

[jira] [Created] (FLINK-34971) Add the function of History Server cleaning job archives regularly

2024-03-31 Thread dengxaing (Jira)
dengxaing created FLINK-34971: - Summary: Add the function of History Server cleaning job archives regularly Key: FLINK-34971 URL: https://issues.apache.org/jira/browse/FLINK-34971 Project: Flink

[PR] [FLINK-34971]Add the function of History Server cleaning job archives… [flink]

2024-03-31 Thread via GitHub
d20162416 opened a new pull request, #24593: URL: https://github.com/apache/flink/pull/24593 Currently, flink does not provide the ability to regularly clean the archives of completed jobs. I think this ability is necessary. When flink provides this ability, users can decide whether

Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
caicancai commented on code in PR #809: URL: https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545572383 ## docs/content.zh/docs/concepts/architecture.md: ## @@ -26,55 +26,55 @@ under the License. # Architecture Review Comment: Thank you for your

Re: [PR] [hotfix] Fix incomplete comment [flink]

2024-03-31 Thread via GitHub
JK-Wang closed pull request #22463: [hotfix] Fix incomplete comment URL: https://github.com/apache/flink/pull/22463 -- 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

Re: [PR] [FLINK-34971]Add the function of History Server cleaning job archives regularly [flink]

2024-03-31 Thread via GitHub
d20162416 closed pull request #24592: [FLINK-34971]Add the function of History Server cleaning job archives regularly URL: https://github.com/apache/flink/pull/24592 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [FLINK-34955] Upgrade commons-compress to 1.26.0. [flink]

2024-03-31 Thread via GitHub
slfan1989 commented on PR #24580: URL: https://github.com/apache/flink/pull/24580#issuecomment-2028949298 @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

Re: [PR] [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 [flink]

2024-03-31 Thread via GitHub
lincoln-lil commented on PR #24517: URL: https://github.com/apache/flink/pull/24517#issuecomment-2028805753 After some debugging, seems `MigrationTestsSnapshotGenerator` cannot work for the four failure tests (

[jira] [Updated] (FLINK-34712) Update reference data for Migration Tests

2024-03-31 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34712: Component/s: Tests > Update reference data for Migration Tests >

[jira] [Updated] (FLINK-34712) Update reference data for Migration Tests

2024-03-31 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34712: Component/s: Test Infrastructure (was: Tests) > Update reference data for

[jira] [Updated] (FLINK-34712) Update reference data for Migration Tests

2024-03-31 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34712: Component/s: (was: Test Infrastructure) > Update reference data for Migration Tests >

[jira] [Updated] (FLINK-34972) MigrationTestsSnapshotGenerator does not work properly for all subclasses of SnapshotMigrationTestBase

2024-03-31 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34972: Component/s: Test Infrastructure > MigrationTestsSnapshotGenerator does not work properly for all

Re: [PR] [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 [flink]

2024-03-31 Thread via GitHub
lincoln-lil commented on PR #24517: URL: https://github.com/apache/flink/pull/24517#issuecomment-2028808821 @masteryhx Could you take a look again when you have time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-34978) Introduce Asynchronous State APIs

2024-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34978: --- Labels: pull-request-available (was: ) > Introduce Asynchronous State APIs >

[PR] [FLINK-34978] Introduce Asynchronous State APIs [flink]

2024-03-31 Thread via GitHub
Zakelly opened a new pull request, #24595: URL: https://github.com/apache/flink/pull/24595 ## What is the purpose of the change As discussed in FLIP-424, we will introduce a new set of State APIs for asynchronous state access. This PR provides the definition of this API as described

Re: [PR] [FLINK-34978] Introduce Asynchronous State APIs [flink]

2024-03-31 Thread via GitHub
flinkbot commented on PR #24595: URL: https://github.com/apache/flink/pull/24595#issuecomment-2029154015 ## CI report: * db1e02b3972270b3f401fa796c25a490d4309b3a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Resolved] (FLINK-34934) Translation Flink-Kubernetes-Operator document framework construction

2024-03-31 Thread Caican Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caican Cai resolved FLINK-34934. Resolution: Fixed > Translation Flink-Kubernetes-Operator document framework construction >

[PR] [FLINK-34980] Translate overview document into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
caicancai opened a new pull request, #810: URL: https://github.com/apache/flink-kubernetes-operator/pull/810 ## What is the purpose of the change *(For example: This pull request adds a new feature to periodically create and maintain savepoints through the `FlinkDeployment`

[jira] [Created] (FLINK-34980) Translate overview document into Chinese

2024-03-31 Thread Caican Cai (Jira)
Caican Cai created FLINK-34980: -- Summary: Translate overview document into Chinese Key: FLINK-34980 URL: https://issues.apache.org/jira/browse/FLINK-34980 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-34980) Translate overview document into Chinese

2024-03-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34980: --- Labels: pull-request-available (was: ) > Translate overview document into Chinese >

[jira] [Created] (FLINK-34981) FLIP-426: Grouping Remote State Access

2024-03-31 Thread Jinzhong Li (Jira)
Jinzhong Li created FLINK-34981: --- Summary: FLIP-426: Grouping Remote State Access Key: FLINK-34981 URL: https://issues.apache.org/jira/browse/FLINK-34981 Project: Flink Issue Type: New Feature

Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]

2024-03-31 Thread via GitHub
lvyanquan commented on PR #2916: URL: https://github.com/apache/flink-cdc/pull/2916#issuecomment-2029160857 > paimon latest version is 0.7,we should update paimon version from 0.6 to 0.7 Done and rebased to master. -- This is an automated message from the Apache Git Service. To

Re: [PR] [FLINK-34955] Upgrade commons-compress to 1.26.0. [flink]

2024-03-31 Thread via GitHub
slfan1989 commented on PR #24580: URL: https://github.com/apache/flink/pull/24580#issuecomment-2029194510 @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

[jira] [Updated] (FLINK-34975) FLIP-427: ForSt - Disaggregated state Store

2024-03-31 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34975: - Fix Version/s: 2.0.0 > FLIP-427: ForSt - Disaggregated state Store >

Re: [PR] [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 [flink]

2024-03-31 Thread via GitHub
flinkbot commented on PR #24594: URL: https://github.com/apache/flink/pull/24594#issuecomment-2029006210 ## CI report: * 67877b27f002d7a43b16ef0a1fb352a625218f59 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
RocMarshal commented on code in PR #809: URL: https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545923010 ## docs/content.zh/docs/concepts/architecture.md: ## @@ -24,57 +24,57 @@ specific language governing permissions and limitations under the

Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
RocMarshal commented on code in PR #809: URL: https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545922843 ## docs/content.zh/docs/concepts/architecture.md: ## @@ -24,57 +24,57 @@ specific language governing permissions and limitations under the

[jira] [Created] (FLINK-34973) FLIP-423: Disaggregated State Storage and Management

2024-03-31 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34973: --- Summary: FLIP-423: Disaggregated State Storage and Management Key: FLINK-34973 URL: https://issues.apache.org/jira/browse/FLINK-34973 Project: Flink Issue

[jira] [Created] (FLINK-34974) FLIP-424: Asynchronous State APIs

2024-03-31 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34974: --- Summary: FLIP-424: Asynchronous State APIs Key: FLINK-34974 URL: https://issues.apache.org/jira/browse/FLINK-34974 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-34975) FLIP-427: ForSt - Disaggregated state Store

2024-03-31 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-34975: Summary: FLIP-427: ForSt - Disaggregated state Store Key: FLINK-34975 URL: https://issues.apache.org/jira/browse/FLINK-34975 Project: Flink Issue Type: New

[jira] [Created] (FLINK-34976) LD_PRELOAD environment may not be effective after su to flink user

2024-03-31 Thread xiaogang zhou (Jira)
xiaogang zhou created FLINK-34976: - Summary: LD_PRELOAD environment may not be effective after su to flink user Key: FLINK-34976 URL: https://issues.apache.org/jira/browse/FLINK-34976 Project: Flink

[jira] [Updated] (FLINK-34977) FLIP-433: State Access on DataStream API V2

2024-03-31 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34977: --- Description: This is the umbrella ticket for FLIP-433: Config, Context and Processing Timer Service

Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
caicancai commented on code in PR #809: URL: https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936742 ## docs/content.zh/docs/concepts/architecture.md: ## @@ -24,57 +24,57 @@ specific language governing permissions and limitations under the License.

[jira] [Updated] (FLINK-34962) flink-connector-pulsa starts failed due to incorrect use of Pulsar API: LookupService. getPartitionedTopicMetadata

2024-03-31 Thread Yubiao Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubiao Feng updated FLINK-34962: Description: - The unnecessary codes calls

[jira] [Updated] (FLINK-34962) flink-connector-pulsa starts failed due to incorrect use of Pulsar API: LookupService. getPartitionedTopicMetadata

2024-03-31 Thread Yubiao Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubiao Feng updated FLINK-34962: Description: - The unnecessary codes calls

[jira] [Updated] (FLINK-34948) CDC RowType can not convert to flink row type

2024-03-31 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34948: --- Priority: Critical (was: Minor) > CDC RowType can not convert to flink row type >

Re: [PR] [FLINK-34948][cdc-common] Fix cdc `RowType` can not convert to flink type [flink-cdc]

2024-03-31 Thread via GitHub
Jiabao-Sun merged PR #3130: URL: https://github.com/apache/flink-cdc/pull/3130 -- 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] [Resolved] (FLINK-34948) CDC RowType can not convert to flink row type

2024-03-31 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-34948. Assignee: Qishang Zhong Resolution: Fixed Fixed via cdc master: 

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-31 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17832695#comment-17832695 ] Weijie Guo commented on FLINK-34643:

Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
RocMarshal commented on code in PR #809: URL: https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545922843 ## docs/content.zh/docs/concepts/architecture.md: ## @@ -24,57 +24,57 @@ specific language governing permissions and limitations under the

Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
caicancai commented on code in PR #809: URL: https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936742 ## docs/content.zh/docs/concepts/architecture.md: ## @@ -24,57 +24,57 @@ specific language governing permissions and limitations under the License.

Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
caicancai commented on code in PR #809: URL: https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936400 ## docs/content.zh/docs/concepts/architecture.md: ## @@ -24,57 +24,57 @@ specific language governing permissions and limitations under the License.

Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
caicancai commented on code in PR #809: URL: https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936400 ## docs/content.zh/docs/concepts/architecture.md: ## @@ -24,57 +24,57 @@ specific language governing permissions and limitations under the License.

Re: [PR] [FLINK-34970] Translate architecture documents into Chinese [flink-kubernetes-operator]

2024-03-31 Thread via GitHub
caicancai commented on code in PR #809: URL: https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936400 ## docs/content.zh/docs/concepts/architecture.md: ## @@ -24,57 +24,57 @@ specific language governing permissions and limitations under the License.

[jira] [Updated] (FLINK-34977) FLIP-433: State Access on DataStream API V2

2024-03-31 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34977: --- Description: This is the umbrella ticket for FLIP-433: State Access on DataStream API V2. (was:

[jira] [Created] (FLINK-34977) FLIP-433: State Access on DataStream API V2

2024-03-31 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-34977: -- Summary: FLIP-433: State Access on DataStream API V2 Key: FLINK-34977 URL: https://issues.apache.org/jira/browse/FLINK-34977 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-34976) LD_PRELOAD environment may not be effective after su to flink user

2024-03-31 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-34976: -- Description: I am not sure if LD_PRELOAD  still takes effect after drop_privs_cmd. Do we

Re: [PR] [FLINK-32079][checkpoint] Support to read/write checkpoint metadata of merged files [flink]

2024-03-31 Thread via GitHub
masteryhx commented on code in PR #24480: URL: https://github.com/apache/flink/pull/24480#discussion_r1545946971 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java: ## @@ -677,6 +734,18 @@ static void

[jira] [Created] (FLINK-34978) Introduce Asynchronous State APIs

2024-03-31 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34978: --- Summary: Introduce Asynchronous State APIs Key: FLINK-34978 URL: https://issues.apache.org/jira/browse/FLINK-34978 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34979) Implement State Future and related utilities

2024-03-31 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34979: --- Summary: Implement State Future and related utilities Key: FLINK-34979 URL: https://issues.apache.org/jira/browse/FLINK-34979 Project: Flink Issue Type:

Re: [PR] [FLINK-34955] Upgrade commons-compress to 1.26.0. [flink]

2024-03-31 Thread via GitHub
slfan1989 commented on PR #24580: URL: https://github.com/apache/flink/pull/24580#issuecomment-2029139974 @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

[jira] [Updated] (FLINK-34976) LD_PRELOAD environment may not be effective after su to flink user

2024-03-31 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-34976: -- Description: I am not sure if LD_PRELOAD  still takes effect after drop_privs_cmd. Should we 

[jira] [Updated] (FLINK-34976) LD_PRELOAD environment may not be effective after su to flink user

2024-03-31 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-34976: -- Description: I am not sure if LD_PRELOAD  still takes effect after drop_privs_cmd. Do we