[jira] [Updated] (FLINK-31023) Introduce ConfigOption for table store

[ https://issues.apache.org/jira/browse/FLINK-31023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31023: - Parent: FLINK-30276 Issue Type: Sub-task (was: Improvement) > Introduce ConfigOption fo

[jira] [Updated] (FLINK-31022) Using new Serializer for table store

[ https://issues.apache.org/jira/browse/FLINK-31022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31022: - Parent: FLINK-30276 Issue Type: Sub-task (was: Improvement) > Using new Serializer for

[jira] [Closed] (FLINK-30874) Introduce configuration for table store

[ https://issues.apache.org/jira/browse/FLINK-30874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30874. Resolution: Duplicate > Introduce configuration for table store >

[jira] [Commented] (FLINK-30874) Introduce configuration for table store

[ https://issues.apache.org/jira/browse/FLINK-30874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687540#comment-17687540 ] Jingsong Lee commented on FLINK-30874: -- Thanks [~zhoupeijie] and [~zjureel], this i

[jira] [Updated] (FLINK-30874) Introduce configuration for table store

[ https://issues.apache.org/jira/browse/FLINK-30874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30874: - Parent: (was: FLINK-30276) Issue Type: New Feature (was: Sub-task) > Introduce conf

[jira] [Closed] (FLINK-30900) Introduce utils for table store

[ https://issues.apache.org/jira/browse/FLINK-30900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30900. Fix Version/s: table-store-0.4.0 Assignee: Shammon Resolution: Fixed master: 8a900

[jira] [Created] (FLINK-31024) Copy code splitter to table store from flink table

Jingsong Lee created FLINK-31024: Summary: Copy code splitter to table store from flink table Key: FLINK-31024 URL: https://issues.apache.org/jira/browse/FLINK-31024 Project: Flink Issue Type

[GitHub] [flink] lsyldliu commented on pull request #21896: [FLINK-30640][sql-client] Fix unstable ctas test in CliClientITCase

lsyldliu commented on PR #21896: URL: https://github.com/apache/flink/pull/21896#issuecomment-1426955252 @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-30998) Add optional exception handler to flink-connector-opensearch

[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687502#comment-17687502 ] Leonid Ilyevsky commented on FLINK-30998: - [~reta] here is my pull request: [ht

[GitHub] [flink-connector-opensearch] boring-cyborg[bot] commented on pull request #8: Add FailureHandler.

boring-cyborg[bot] commented on PR #8: URL: https://github.com/apache/flink-connector-opensearch/pull/8#issuecomment-1426907929 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This i

[GitHub] [flink-kubernetes-operator] xshipeng commented on pull request #530: [FLINK-30757] Upgrade busybox version to a pinned version for operator

xshipeng commented on PR #530: URL: https://github.com/apache/flink-kubernetes-operator/pull/530#issuecomment-1426893118 Hi @gyfora @gaborgsomogyi , the pipeline checks with 1.35.0 busybox version passed. Should we wait for https://github.com/docker-library/busybox/issues/162 to be solved

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #529: [FLINK-30776] Move autoscaler code into a separate Maven module

gyfora commented on code in PR #529: URL: https://github.com/apache/flink-kubernetes-operator/pull/529#discussion_r1103692900 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoscalerFactoryImpl.java: ## @@ -0,0 +1,41 @@

[jira] [Created] (FLINK-31023) Introduce ConfigOption for table store

Jingsong Lee created FLINK-31023: Summary: Introduce ConfigOption for table store Key: FLINK-31023 URL: https://issues.apache.org/jira/browse/FLINK-31023 Project: Flink Issue Type: Improvemen

[GitHub] [flink] 1996fanrui commented on a diff in pull request #21840: [FLINK-29481] Show jobType in webUI

1996fanrui commented on code in PR #21840: URL: https://github.com/apache/flink/pull/21840#discussion_r1101113026 ## flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java: ## @@ -541,10 +549,12 @@ public ExecutionConfig setExecutionRetryDelay(long executionR

[jira] [Comment Edited] (FLINK-31021) JavaCodeSplitter doesn't split static method properly

[ https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687449#comment-17687449 ] Krzysztof Chmielewski edited comment on FLINK-31021 at 2/11/23 2:10 PM: --

[jira] [Commented] (FLINK-31021) JavaCodeSplitter doesn't split static method properly

[ https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687449#comment-17687449 ] Krzysztof Chmielewski commented on FLINK-31021: --- Ok so I verified and it s

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #522: [FLINK-30979] Support shuffling data by partition

JingsongLi commented on code in PR #522: URL: https://github.com/apache/flink-table-store/pull/522#discussion_r1103626550 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java: ## @@ -69,6 +69,13 @@ public class FlinkConne

[jira] [Created] (FLINK-31022) Using new Serializer for table store

Jingsong Lee created FLINK-31022: Summary: Using new Serializer for table store Key: FLINK-31022 URL: https://issues.apache.org/jira/browse/FLINK-31022 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #21912: [FLINK-28658][docs] Add docs for job statements

flinkbot commented on PR #21912: URL: https://github.com/apache/flink/pull/21912#issuecomment-1426762736 ## CI report: * 85820ed5bd54b155a4e3a602dabcc753c198e03b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28658) Add document for job lifecycle statements

[ https://issues.apache.org/jira/browse/FLINK-28658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28658: --- Labels: pull-request-available (was: ) > Add document for job lifecycle statements > --

[GitHub] [flink] link3280 commented on pull request #21912: [FLINK-28658][docs] Add docs for job statements

link3280 commented on PR #21912: URL: https://github.com/apache/flink/pull/21912#issuecomment-1426760916 cc @fsk119 -- 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 unsu

[GitHub] [flink] link3280 opened a new pull request, #21912: [FLINK-28658][docs] Add docs for job statements

link3280 opened a new pull request, #21912: URL: https://github.com/apache/flink/pull/21912 ## What is the purpose of the change Add docs for job statements. ## Brief change log - Add docs for job statements. ## Verifying this change This change is a tri

[jira] [Closed] (FLINK-31004) Introduce data input and output stream for table store

[ https://issues.apache.org/jira/browse/FLINK-31004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31004. Fix Version/s: table-store-0.4.0 Assignee: Shammon Resolution: Fixed master: 03f18

[GitHub] [flink-table-store] JingsongLi merged pull request #516: [FLINK-31004] Introduce input and output stream for table store

JingsongLi merged PR #516: URL: https://github.com/apache/flink-table-store/pull/516 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #519: [FLINK-31008] Fix the bug that ContinuousFileSplitEnumerator may be out of order when allocating splits.

JingsongLi commented on code in PR #519: URL: https://github.com/apache/flink-table-store/pull/519#discussion_r1103568302 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/ContinuousFileSplitEnumerator.java: ## @@ -91,6 +92,19 @@ private

[jira] [Closed] (FLINK-30994) Introduce DoubleSerializer for Table Store

[ https://issues.apache.org/jira/browse/FLINK-30994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30994. Assignee: Feng Wang Resolution: Fixed master: 8363dc6f57ae053f9b34cf7403c734b9e6c66a3b > In

[GitHub] [flink-table-store] JingsongLi merged pull request #520: [Flink-30994] Introduce DoubleSerializer for Table Store

JingsongLi merged PR #520: URL: https://github.com/apache/flink-table-store/pull/520 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@

[jira] [Closed] (FLINK-30995) Introduce ByteSerializer for Table Store

[ https://issues.apache.org/jira/browse/FLINK-30995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30995. Assignee: Feng Wang Resolution: Fixed master: 677313714323a2f745cfe15497e7de7c8f866069 > In

[GitHub] [flink-table-store] JingsongLi merged pull request #521: [Flink-30995] Introduce ByteSerializer for Table Store

JingsongLi merged PR #521: URL: https://github.com/apache/flink-table-store/pull/521 -- 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...@