[jira] [Commented] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck

[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696741#comment-17696741 ] Renxiang Zhou commented on FLINK-31249: --- Thanks for your reply. The following che

[GitHub] [flink-table-store] JingsongLi commented on pull request #581: [FLINK-31190] Supports Spark call procedure command on Table Store

JingsongLi commented on PR #581: URL: https://github.com/apache/flink-table-store/pull/581#issuecomment-1455638847 Can we just implement a `CALL` procedure for validation? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink] rkhachatryan commented on pull request #21914: [FLINK-31035] add warn info to user when NoNodeException happend

rkhachatryan commented on PR #21914: URL: https://github.com/apache/flink/pull/21914#issuecomment-1455630852 Hi @xuzifu666, could you please squash the commits into one and format the commit message according to [Flink guide](https://flink.apache.org/how-to-contribute/code-style-and-qual

[GitHub] [flink] yunfengzhou-hub commented on a diff in pull request #22034: [FLINK-31240][table] Reduce the overhead of conversion between DataStream and Table

yunfengzhou-hub commented on code in PR #22034: URL: https://github.com/apache/flink/pull/22034#discussion_r1125931457 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/DataStreamJavaITCase.java: ## @@ -377,6 +385,102 @@ public vo

[GitHub] [flink] flinkbot commented on pull request #22103: [FLINK-28825] Add K8S pod scheduler into Kubernetes options [FLINK-28829] Support prepreparing K8S resources before JM creation [FLINK-28831

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

[GitHub] [flink] gj199575 opened a new pull request, #22103: [FLINK-28825] Add K8S pod scheduler into Kubernetes options

gj199575 opened a new pull request, #22103: URL: https://github.com/apache/flink/pull/22103 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[GitHub] [flink] snuyanzin commented on a diff in pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

snuyanzin commented on code in PR #15797: URL: https://github.com/apache/flink/pull/15797#discussion_r1125995093 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java: ## @@ -160,6 +166,117 @@ Stream getTestSetSp

[GitHub] [flink-table-store] tsreaper merged pull request #572: [FLINK-30608] support rename table

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

[jira] [Updated] (FLINK-31322) Improve merge-into action

[ https://issues.apache.org/jira/browse/FLINK-31322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzelin updated FLINK-31322: Description: Umbrella issue for improving flink merge-into action. (was: Umbrella issue for bug fixing an

[jira] [Updated] (FLINK-31323) Fix unstable E2E test for flink actions

[ https://issues.apache.org/jira/browse/FLINK-31323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzelin updated FLINK-31323: Description: Currently, the flink actions use Data Stream API to do insert job making batch configuration

[jira] [Updated] (FLINK-31323) Fix unstable E2E test for flink actions

[ https://issues.apache.org/jira/browse/FLINK-31323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzelin updated FLINK-31323: Summary: Fix unstable E2E test for flink actions (was: Fix unstable merge-into E2E test) > Fix unstable

[jira] [Updated] (FLINK-31323) Fix unstable merge-into E2E test

[ https://issues.apache.org/jira/browse/FLINK-31323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzelin updated FLINK-31323: Parent: (was: FLINK-31322) Issue Type: Bug (was: Sub-task) > Fix unstable merge-into E2E test

[GitHub] [flink] reswqa commented on pull request #22084: [WIP][FLINK-31293][runtime] LocalBufferPool request overdraft buffer only when no available buffer and pool size is reached

reswqa commented on PR #22084: URL: https://github.com/apache/flink/pull/22084#issuecomment-1455518523 Thanks @1996fanrui for the review, I have updated this as your comment, PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [flink] reswqa commented on a diff in pull request #22084: [WIP][FLINK-31293][runtime] LocalBufferPool request overdraft buffer only when no available buffer and pool size is reached

reswqa commented on code in PR #22084: URL: https://github.com/apache/flink/pull/22084#discussion_r1125960686 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java: ## @@ -396,7 +396,7 @@ private MemorySegment requestMemorySegment(int ta

[jira] [Updated] (FLINK-15289) Run sql appear error of "Zero-length character strings have no serializable string representation".

[ https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15289: Fix Version/s: (was: 1.17.0) > Run sql appear error of "Zero-length character strings have no serializ

[jira] [Closed] (FLINK-30983) the security.ssl.algorithms configuration does not take effect in rest ssl

[ https://issues.apache.org/jira/browse/FLINK-30983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-30983. -- Resolution: Fixed > the security.ssl.algorithms configuration does not take effect in rest ssl > -

[jira] [Commented] (FLINK-30983) the security.ssl.algorithms configuration does not take effect in rest ssl

[ https://issues.apache.org/jira/browse/FLINK-30983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696695#comment-17696695 ] Weijie Guo commented on FLINK-30983: master(1.18) via 84f532e65498164bc03529dc387a85

[GitHub] [flink] reswqa closed pull request #21937: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

reswqa closed pull request #21937: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL URL: https://github.com/apache/flink/pull/21937 -- 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] [Created] (FLINK-31329) Fix Parquet stats extractor

Jingsong Lee created FLINK-31329: Summary: Fix Parquet stats extractor Key: FLINK-31329 URL: https://issues.apache.org/jira/browse/FLINK-31329 Project: Flink Issue Type: Bug Compone

[GitHub] [flink] reswqa merged pull request #22097: [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL

reswqa merged PR #22097: URL: https://github.com/apache/flink/pull/22097 -- 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

[jira] [Closed] (FLINK-31327) Added conversion method for GenericRowData

[ https://issues.apache.org/jira/browse/FLINK-31327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hunter closed FLINK-31327. -- Resolution: Invalid > Added conversion method for GenericRowData > --

[jira] [Assigned] (FLINK-30829) Make the backpressure tab could be sort by the backpressure level

[ https://issues.apache.org/jira/browse/FLINK-30829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-30829: -- Assignee: Wencong Liu > Make the backpressure tab could be sort by the backpressure level > -

[GitHub] [flink] zhuzhurk commented on a diff in pull request #22098: [FLINK-31144][coordination] Modify the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the c

zhuzhurk commented on code in PR #22098: URL: https://github.com/apache/flink/pull/22098#discussion_r1125915973 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetriever.java: ## @@ -35,7 +35,7 @@ /** * Default implementation of {@

[jira] [Updated] (FLINK-31327) Added conversion method for GenericRowData

[ https://issues.apache.org/jira/browse/FLINK-31327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31327: Component/s: Table SQL / API > Added conversion method for GenericRowData > --

[jira] [Commented] (FLINK-31297) FineGrainedSlotManagerTest.testTaskManagerRegistrationDeductPendingTaskManager unstable when running it a single time

[ https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696682#comment-17696682 ] Weihua Hu commented on FLINK-31297: --- Hi, [~xtsong] [~Weijie Guo] Could you help review

[GitHub] [flink] huwh commented on a diff in pull request #22098: [FLINK-31144][coordination] Modify the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the corre

huwh commented on code in PR #22098: URL: https://github.com/apache/flink/pull/22098#discussion_r1125845041 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetriever.java: ## @@ -35,7 +35,7 @@ /** * Default implementation of {@link

[GitHub] [flink] huwh commented on pull request #22083: [FLINK-31297][Runtime] Use processResourceRequirements to allocate sk manager in FineGrainedSlotManagerTest

huwh commented on PR #22083: URL: https://github.com/apache/flink/pull/22083#issuecomment-1455397847 @JunRuiLee sorry，I mixed up the tabs -- 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 speci

[GitHub] [flink] flinkbot commented on pull request #22102: [FLINK-31092][sql-gateway][table-common] Fix Hive ITCase fail with OutOfMemoryError

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

[jira] [Created] (FLINK-31328) Greedy option on the looping pattern at the end not working

Juntao Hu created FLINK-31328: - Summary: Greedy option on the looping pattern at the end not working Key: FLINK-31328 URL: https://issues.apache.org/jira/browse/FLINK-31328 Project: Flink Issue

[GitHub] [flink] fsk119 opened a new pull request, #22102: [FLINK-31092][sql-gateway][table-common] Fix Hive ITCase fail with OutOfMemoryError

fsk119 opened a new pull request, #22102: URL: https://github.com/apache/flink/pull/22102 ## What is the purpose of the change Cherry-pick the fix to #22072 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink] xuzifu666 commented on pull request #21914: [FLINK-31035] add warn info to user when NoNodeException happend

xuzifu666 commented on PR #21914: URL: https://github.com/apache/flink/pull/21914#issuecomment-1455393875 @rkhachatryan hi，this pr can be merged？ this message is need where we occur zk leader change to resolve problem -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] JunRuiLee commented on pull request #22083: [FLINK-31297][Runtime] Use processResourceRequirements to allocate sk manager in FineGrainedSlotManagerTest

JunRuiLee commented on PR #22083: URL: https://github.com/apache/flink/pull/22083#issuecomment-1455393743 @huwh Did you accidentally misplace the comment? This pr was created by yourself. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-ml] zhipeng93 commented on pull request #220: [FLINK-31325] Improve performance of Swing.

zhipeng93 commented on PR #220: URL: https://github.com/apache/flink-ml/pull/220#issuecomment-1455393210 Thanks for the PR. Can you update the PR description as follows for better readbility? - Remove the `dot` at the end of PR title. The PR titles usually do not end with `.`. - A

[jira] [Commented] (FLINK-31324) Broken SingleThreadFetcherManager constructor API

[ https://issues.apache.org/jira/browse/FLINK-31324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696673#comment-17696673 ] Yun Tang commented on FLINK-31324: -- I think we can discuss changing the annotation of

[GitHub] [flink] luoyuxia commented on pull request #22032: [FLINK-30667][hive] introduce flink-table-calcite-bridge module

luoyuxia commented on PR #22032: URL: https://github.com/apache/flink/pull/22032#issuecomment-1455385893 @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] [Created] (FLINK-31327) Added conversion method for GenericRowData

hunter created FLINK-31327: -- Summary: Added conversion method for GenericRowData Key: FLINK-31327 URL: https://issues.apache.org/jira/browse/FLINK-31327 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-31040) Looping pattern notFollowedBy at end missing an element

[ https://issues.apache.org/jira/browse/FLINK-31040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696660#comment-17696660 ] Juntao Hu commented on FLINK-31040: --- [~nicholasjiang], [~martijnvisser] I could take t

[jira] [Updated] (FLINK-30501) Update Flink build instruction to deprecate Java 8 instead of requiring Java 11

[ https://issues.apache.org/jira/browse/FLINK-30501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30501: - Description: Flink 1.15 and later versions require at least Java 11 to build from sources [1], whereas

[GitHub] [flink] flinkbot commented on pull request #22101: [FLINK-31092][sql-gateway][table-common] Fix Hive ITCase fail with OutOfMemoryError

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

[jira] [Closed] (FLINK-30501) Update Flink build instruction to deprecate Java 8 instead of requiring Java 11

[ https://issues.apache.org/jira/browse/FLINK-30501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-30501. Resolution: Fixed > Update Flink build instruction to deprecate Java 8 instead of requiring Java > 11 > -

[jira] [Commented] (FLINK-30501) Update Flink build instruction to deprecate Java 8 instead of requiring Java 11

[ https://issues.apache.org/jira/browse/FLINK-30501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696657#comment-17696657 ] Dong Lin commented on FLINK-30501: -- Merged to apache/flink master branch 88d28a17459384

[jira] [Updated] (FLINK-30501) Update Flink build instruction to deprecate Java 8 instead of requiring Java 11

[ https://issues.apache.org/jira/browse/FLINK-30501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30501: - Fix Version/s: 1.17.0 > Update Flink build instruction to deprecate Java 8 instead of requiring Java >

[GitHub] [flink] lindong28 merged pull request #21557: [FLINK-30501] Update Flink build instruction to deprecate Java 8 instead of requiring Java 11

lindong28 merged PR #21557: URL: https://github.com/apache/flink/pull/21557 -- 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

[GitHub] [flink] fsk119 opened a new pull request, #22101: [FLINK-31092][sql-gateway][table-common] Fix Hive ITCase fail with OutOfMemoryError

fsk119 opened a new pull request, #22101: URL: https://github.com/apache/flink/pull/22101 ## What is the purpose of the change Cherry-pick the fix #22072 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink] liuyongvs commented on a diff in pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

liuyongvs commented on code in PR #15797: URL: https://github.com/apache/flink/pull/15797#discussion_r1125820468 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java: ## @@ -160,6 +166,117 @@ Stream getTestSetSp

[GitHub] [flink] liuyongvs commented on pull request #21993: [FLINK-31166][table] Fix array_contains does not support null argumen…

liuyongvs commented on PR #21993: URL: https://github.com/apache/flink/pull/21993#issuecomment-1455345429 have fixed, thanks, please have a look again -- 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 g

[GitHub] [flink] flinkbot commented on pull request #22100: [FLINK-31208][Connectors / Kafka] KafkaSourceReader overrides meaning…

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

[GitHub] [flink] liuyongvs commented on a diff in pull request #21993: [FLINK-31166][table] Fix array_contains does not support null argumen…

liuyongvs commented on code in PR #21993: URL: https://github.com/apache/flink/pull/21993#discussion_r1125817574 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java: ## @@ -71,7 +71,11 @@ public final

[GitHub] [flink] liuyongvs commented on a diff in pull request #21993: [FLINK-31166][table] Fix array_contains does not support null argumen…

liuyongvs commented on code in PR #21993: URL: https://github.com/apache/flink/pull/21993#discussion_r1125817095 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java: ## @@ -31,24 +31,28 @@ imp

[GitHub] [flink] loserwang1024 opened a new pull request, #22100: [FLINK-31208][Connectors / Kafka] KafkaSourceReader overrides meaning…

loserwang1024 opened a new pull request, #22100: URL: https://github.com/apache/flink/pull/22100 ## What is the purpose of the change As described in [FLINK-31208](https://issues.apache.org/jira/browse/FLINK-31208?filter=-2), an override method named pauseOrResumeSplits in KafkaSourceRea

[jira] [Commented] (FLINK-31324) Broken SingleThreadFetcherManager constructor API

[ https://issues.apache.org/jira/browse/FLINK-31324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696653#comment-17696653 ] Jark Wu commented on FLINK-31324: - +1 for keeping compatibility. Besides, I think {{Si

[GitHub] [flink] flinkbot commented on pull request #22099: [FLINK-30948][sql-client] Fix ExecutorImpl#testInterruptException han…

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

[GitHub] [flink] fsk119 opened a new pull request, #22099: [FLINK-30948][sql-client] Fix ExecutorImpl#testInterruptException han…

fsk119 opened a new pull request, #22099: URL: https://github.com/apache/flink/pull/22099 …gs (#22055) ## What is the purpose of the change Cherry pick the fix #22055 to release-1.17 -- This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] liuyongvs commented on pull request #22050: [FLINK-31279][table] fix builtin function of times wrong check.

liuyongvs commented on PR #22050: URL: https://github.com/apache/flink/pull/22050#issuecomment-1455319540 hi @snuyanzin , have fixed the PR's description -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink-table-store] JingsongLi commented on pull request #569: [FLINK-31269] Split hive connector to each module of each version

JingsongLi commented on PR #569: URL: https://github.com/apache/flink-table-store/pull/569#issuecomment-1455307283 > Have you tried to setup metastore in hive-2.1-cdh-6.3, and use flink-table-store-hive-catalog.jar in Flink side? -- This is an automated message from the Apache Gi

[GitHub] [flink] xuzifu666 commented on pull request #21914: [FLINK-31035] add warn info to user when NoNodeException happend

xuzifu666 commented on PR #21914: URL: https://github.com/apache/flink/pull/21914#issuecomment-1455300436 @rkhachatryan ok，get -- 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] [Reopened] (FLINK-31211) Flink chk files not delete automic after 1.13

[ https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leo.zhi reopened FLINK-31211: - unfortunately, there is no solution :( > Flink chk files not delete automic after 1.13 > --

[GitHub] [flink] snuyanzin commented on pull request #22050: [FLINK-31279][table] fix builtin function of times wrong check.

snuyanzin commented on PR #22050: URL: https://github.com/apache/flink/pull/22050#issuecomment-1455240769 Thanks for the contribution in general it looks good. The nit thing: could you please fix PR's description? -- This is an automated message from the Apache Git Service. To re

[GitHub] [flink] snuyanzin merged pull request #21933: [hotfix][docs] Replace `serailize` with `serialize` in data_types.md

snuyanzin merged PR #21933: URL: https://github.com/apache/flink/pull/21933 -- 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

[GitHub] [flink] snuyanzin commented on a diff in pull request #21993: [FLINK-31166][table] Fix array_contains does not support null argumen…

snuyanzin commented on code in PR #21993: URL: https://github.com/apache/flink/pull/21993#discussion_r1125750756 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java: ## @@ -71,7 +71,11 @@ public final

[GitHub] [flink] snuyanzin commented on a diff in pull request #21993: [FLINK-31166][table] Fix array_contains does not support null argumen…

snuyanzin commented on code in PR #21993: URL: https://github.com/apache/flink/pull/21993#discussion_r1125750431 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java: ## @@ -31,24 +31,28 @@ imp

[jira] [Updated] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-31139: -- Affects Version/s: 1.16.1 1.15.3 > not upload empty state chang

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21914: [FLINK-31035] add warn info to user when NoNodeException happend

rkhachatryan commented on code in PR #21914: URL: https://github.com/apache/flink/pull/21914#discussion_r1125727845 ## flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java: ## @@ -364,6 +364,7 @@ public Collection getAllHandles() throws E

[jira] [Commented] (FLINK-31326) Disabled source scaling breaks downstream scaling if source busyTimeMsPerSecond is 0

[ https://issues.apache.org/jira/browse/FLINK-31326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696603#comment-17696603 ] Gyula Fora commented on FLINK-31326: Good catch [~mateczagany] , there are a few odd

[jira] [Updated] (FLINK-31224) Add metrics for flink table store

[ https://issues.apache.org/jira/browse/FLINK-31224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Zhang updated FLINK-31224: -- Description: We can divide the metrics of the flink table store into three categories: SourceMetrics,

[GitHub] [flink-table-store] JingsongLi commented on pull request #581: [FLINK-31190] Supports Spark call procedure command on Table Store

JingsongLi commented on PR #581: URL: https://github.com/apache/flink-table-store/pull/581#issuecomment-1455125310 Wow~ Thanks @SteNicholas for your contribution! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[jira] [Created] (FLINK-31326) Disabled source scaling breaks downstream scaling if source busyTimeMsPerSecond is 0

Mate Czagany created FLINK-31326: Summary: Disabled source scaling breaks downstream scaling if source busyTimeMsPerSecond is 0 Key: FLINK-31326 URL: https://issues.apache.org/jira/browse/FLINK-31326

[jira] [Updated] (FLINK-31325) Improve Swing Transformer

[ https://issues.apache.org/jira/browse/FLINK-31325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31325: --- Labels: pull-request-available (was: ) > Improve Swing Transformer > -

[GitHub] [flink-ml] vacaly opened a new pull request, #220: [FLINK-31325] Improve performance of Swing.

vacaly opened a new pull request, #220: URL: https://github.com/apache/flink-ml/pull/220 ## What is the purpose of the change Optimize `Swing` transformer. Optimized code can lead to twice the speed of current code. ## Brief change log - Rewrite `ComputingSimil

[jira] [Updated] (FLINK-31190) Supports Spark call procedure command on Table Store

[ https://issues.apache.org/jira/browse/FLINK-31190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31190: --- Labels: pull-request-available (was: ) > Supports Spark call procedure command on Table Sto

[GitHub] [flink-table-store] SteNicholas opened a new pull request, #581: [FLINK-31190] Supports Spark call procedure command on Table Store

SteNicholas opened a new pull request, #581: URL: https://github.com/apache/flink-table-store/pull/581 At present Hudi and Iceberg supports the Spark call procedure command to execute the table service action etc. Flink Table Store could also support Spark call procedure command to run comp

[jira] [Updated] (FLINK-31325) Improve Swing Transformer

[ https://issues.apache.org/jira/browse/FLINK-31325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yindi Wang updated FLINK-31325: --- Summary: Improve Swing Transformer (was: Improve Transformer of Swing) > Improve Swing Transform

[jira] [Updated] (FLINK-31325) Improve Transformer of Swing

[ https://issues.apache.org/jira/browse/FLINK-31325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yindi Wang updated FLINK-31325: --- Summary: Improve Transformer of Swing (was: Improve performance of Swing) > Improve Transformer

[jira] [Resolved] (FLINK-31246) Beautify the SpecChange message

[ https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-31246. Fix Version/s: kubernetes-operator-1.5.0 Assignee: Peter Vary Resolution: Fixed me

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #539: [FLINK-31246] Beautify the SpecChange message

gyfora merged PR #539: URL: https://github.com/apache/flink-kubernetes-operator/pull/539 -- 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-benchmarks] lindong28 commented on a diff in pull request #66: [FLINK-29825] Replace median-based regression detect algorithm with max/min-based

lindong28 commented on code in PR #66: URL: https://github.com/apache/flink-benchmarks/pull/66#discussion_r1125658942 ## regression_report_v2.py: ## @@ -0,0 +1,108 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- +###

[jira] [Created] (FLINK-31325) Improve performance of Swing

Yindi Wang created FLINK-31325: -- Summary: Improve performance of Swing Key: FLINK-31325 URL: https://issues.apache.org/jira/browse/FLINK-31325 Project: Flink Issue Type: Improvement C

[GitHub] [flink] flinkbot commented on pull request #22098: [FLINK-31144][coordination] Modify the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the correspondi

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

[jira] [Updated] (FLINK-31144) Slow scheduling on large-scale batch jobs

[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31144: --- Labels: pull-request-available (was: ) > Slow scheduling on large-scale batch jobs > -

[GitHub] [flink] JunRuiLee opened a new pull request, #22098: [FLINK-31144][coordination] Modify the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the correspon

JunRuiLee opened a new pull request, #22098: URL: https://github.com/apache/flink/pull/22098 ## What is the purpose of the change Currently, the judgment logic of whether to ignore the input locations of a ConsumePartitionGroup if the corresponding ConsumerVertexGroup is t

[jira] [Commented] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar

[ https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696546#comment-17696546 ] Yufan Sheng commented on FLINK-31006: - [~lemonjing] Yep, I agree with you. > job is