[GitHub] [flink] ljz2051 opened a new pull request, #23407: [FLINK-32953][docs]Add notes about changing state ttl value

2023-09-13 Thread via GitHub
ljz2051 opened a new pull request, #23407: URL: https://github.com/apache/flink/pull/23407 ## What is the purpose of the change This pull request add notes about changing state TTL value when restore checkpoint. ## Brief change log - Add a note in "state.md" document.

[jira] [Updated] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

2023-09-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32953: --- Labels: pull-request-available (was: ) > [State TTL]resolve data correctness problem after

[jira] [Created] (FLINK-33080) The checkpoint storage configured in the job level by config option will not take effect

2023-09-13 Thread Junrui Li (Jira)
Junrui Li created FLINK-33080: - Summary: The checkpoint storage configured in the job level by config option will not take effect Key: FLINK-33080 URL: https://issues.apache.org/jira/browse/FLINK-33080 Pr

[jira] [Assigned] (FLINK-33080) The checkpoint storage configured in the job level by config option will not take effect

2023-09-13 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-33080: -- Assignee: Junrui Li > The checkpoint storage configured in the job level by config option wil

[GitHub] [flink] flinkbot commented on pull request #23407: [FLINK-32953][docs]Add notes about changing state ttl value

2023-09-13 Thread via GitHub
flinkbot commented on PR #23407: URL: https://github.com/apache/flink/pull/23407#issuecomment-1717067773 ## CI report: * f59f7f7004c10ba16d2cdbb1dec363964414880c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

2023-09-13 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764518#comment-17764518 ] Jinzhong Li commented on FLINK-32953: - [~masteryhx]  I publish a pr which add some n

[jira] [Assigned] (FLINK-30400) Stop bundling connector-base in externalized connectors

2023-09-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-30400: -- Assignee: Hang Ruan > Stop bundling connector-base in externalized connectors > -

[jira] [Updated] (FLINK-33080) The checkpoint storage configured in the job level by config option will not take effect

2023-09-13 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33080: -- Description: When we configure the checkpoint storage at the job level, it can only be done through t

[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-09-13 Thread via GitHub
lindong28 commented on code in PR #248: URL: https://github.com/apache/flink-ml/pull/248#discussion_r1299531846 ## flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/feedback/SpillableFeedbackQueue.java: ## @@ -0,0 +1,115 @@ +/* + * Li

[jira] [Assigned] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-33052: Assignee: Zakelly Lan (was: Yuan Mei) > codespeed server is down > > >

[GitHub] [flink] JunRuiLee opened a new pull request, #23408: [FLINK-33080][runtime] Make the configured checkpoint storage in the job-side configuration will take effect.

2023-09-13 Thread via GitHub
JunRuiLee opened a new pull request, #23408: URL: https://github.com/apache/flink/pull/23408 ## What is the purpose of the change Make the configured checkpoint storage in the job-side configuration will take effect. ## Brief change log Load checkpoin

[jira] [Updated] (FLINK-33080) The checkpoint storage configured in the job level by config option will not take effect

2023-09-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33080: --- Labels: pull-request-available (was: ) > The checkpoint storage configured in the job level

[GitHub] [flink] flinkbot commented on pull request #23408: [FLINK-33080][runtime] Make the configured checkpoint storage in the job-side configuration will take effect.

2023-09-13 Thread via GitHub
flinkbot commented on PR #23408: URL: https://github.com/apache/flink/pull/23408#issuecomment-1717151891 ## CI report: * 9960939d8f00229a2cd201c2a9a87db4e90a5c10 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] gaborgsomogyi commented on pull request #23359: [FLINK-33029][python] Drop python 3.7 support

2023-09-13 Thread via GitHub
gaborgsomogyi commented on PR #23359: URL: https://github.com/apache/flink/pull/23359#issuecomment-1717171777 Asked in the dev discussion thread whether somebody has addition, nothing arrived so I would say yes. I'm intended to merge it soon... -- This is an automated message from the Apa

[jira] [Assigned] (FLINK-32863) Improve Flink UI's time precision from second level to millisecond level

2023-09-13 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32863: -- Assignee: Jufang He > Improve Flink UI's time precision from second level to millisecond leve

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #23403: [FLINK-32863][runtime-web] Improve Flink UI's time precision from sec…

2023-09-13 Thread via GitHub
KarmaGYZ commented on code in PR #23403: URL: https://github.com/apache/flink/pull/23403#discussion_r1324171749 ## flink-runtime-web/web-dashboard/src/app/components/humanize-duration.pipe.ts: ## @@ -46,23 +46,23 @@ export class HumanizeDurationPipe implements PipeTransform {

[jira] [Closed] (FLINK-31387) StreamTaskCancellationTest.testCancelTaskShouldPreventAdditionalProcessingTimeTimersFromBeingFired failed with an assertion

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-31387. -- > StreamTaskCancellationTest.testCancelTaskShouldPreventAdditionalProcessingTimeTimersFromBeingFir

[GitHub] [flink] hejufang commented on a diff in pull request #23403: [FLINK-32863][runtime-web] Improve Flink UI's time precision from sec…

2023-09-13 Thread via GitHub
hejufang commented on code in PR #23403: URL: https://github.com/apache/flink/pull/23403#discussion_r1324189387 ## flink-runtime-web/web-dashboard/src/app/components/humanize-duration.pipe.ts: ## @@ -46,23 +46,23 @@ export class HumanizeDurationPipe implements PipeTransform {

[jira] [Created] (FLINK-33081) Move parallelism override logic into scale method

2023-09-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-33081: -- Summary: Move parallelism override logic into scale method Key: FLINK-33081 URL: https://issues.apache.org/jira/browse/FLINK-33081 Project: Flink Issue Type: Imp

[GitHub] [flink] maosuhan commented on pull request #23162: [FLINK-32650][protobuf]Added the ability to split flink-protobuf code…

2023-09-13 Thread via GitHub
maosuhan commented on PR #23162: URL: https://github.com/apache/flink/pull/23162#issuecomment-1717237735 @ljw-hit Hi, thanks for your effort and the code is already in good shape to me. I have left a few comments about unit tests. And could you provide a benchmark test for this improvement?

[jira] [Updated] (FLINK-33052) codespeed server is down

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-33052: --- Priority: Blocker (was: Major) > codespeed server is down > > >

[jira] [Updated] (FLINK-33052) codespeed server is down

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-33052: --- Affects Version/s: 1.18.0 > codespeed server is down > > >

[jira] [Updated] (FLINK-33052) codespeed server is down

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-33052: --- Component/s: Benchmarks > codespeed server is down > > >

[jira] [Commented] (FLINK-33052) codespeed server is down

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764564#comment-17764564 ] Piotr Nowojski commented on FLINK-33052: Thanks for investigating this issue [~j

[jira] [Updated] (FLINK-33081) Move parallelism override logic into scale method

2023-09-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33081: --- Labels: pull-request-available (was: ) > Move parallelism override logic into scale method

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #672: [FLINK-33081] Apply parallelism overrides in scale

2023-09-13 Thread via GitHub
gyfora opened a new pull request, #672: URL: https://github.com/apache/flink-kubernetes-operator/pull/672 ## What is the purpose of the change Simplify the scale / parallelism override flow based on previous feedback. This change is a refactor and does not introduce new behaviour.

[GitHub] [flink] echauchot commented on a diff in pull request #22985: [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler

2023-09-13 Thread via GitHub
echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1324233808 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -124,17 +154,33 @@ private void handleDeploymentFailure(ExecutionVert

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

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

[jira] [Updated] (FLINK-33082) Azure Pipelines 4 is not responding on AZP

2023-09-13 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33082: Affects Version/s: 1.17.2 > Azure Pipelines 4 is not responding on AZP > -

[jira] [Created] (FLINK-33082) Azure Pipelines 4 is not responding on AZP

2023-09-13 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33082: --- Summary: Azure Pipelines 4 is not responding on AZP Key: FLINK-33082 URL: https://issues.apache.org/jira/browse/FLINK-33082 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-09-13 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-18356: Affects Version/s: 1.19.0 > flink-table-planner Exit code 137 returned from process >

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

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

[GitHub] [flink] echauchot commented on a diff in pull request #22985: [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler

2023-09-13 Thread via GitHub
echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1324233808 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -124,17 +154,33 @@ private void handleDeploymentFailure(ExecutionVert

[GitHub] [flink] echauchot commented on pull request #22985: [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler

2023-09-13 Thread via GitHub
echauchot commented on PR #22985: URL: https://github.com/apache/flink/pull/22985#issuecomment-1717288424 > @dmvk as you authored part on the code in that part, can you review the PR as well ? The discussions went around `scalingIntervalMax`, @zentol was the one who proposed the addi

[jira] [Created] (FLINK-33083) SupportsReadingMetadata is not applied when loading a CompiledPlan

2023-09-13 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-33083: Summary: SupportsReadingMetadata is not applied when loading a CompiledPlan Key: FLINK-33083 URL: https://issues.apache.org/jira/browse/FLINK-33083 Project: F

[jira] [Commented] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764570#comment-17764570 ] Yuan Mei commented on FLINK-33052: -- [~pnowojski] We have the historical data backed up.

[jira] [Updated] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-33052: - Priority: Critical (was: Blocker) > codespeed server is down > > >

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

2023-09-13 Thread via GitHub
wangyang0918 commented on PR #23164: URL: https://github.com/apache/flink/pull/23164#issuecomment-1717326350 @architgyl Could you please verify this PR in a real YARN cluster whether it solves your original requirement about hive config? -- This is an automated message from the Apache Git

[GitHub] [flink-kubernetes-operator] mbalassi commented on pull request #668: Give cluster/job role access to k8s services API

2023-09-13 Thread via GitHub
mbalassi commented on PR #668: URL: https://github.com/apache/flink-kubernetes-operator/pull/668#issuecomment-1717336055 @sbrother could you please open a ticket for this, as a good example see this one: https://issues.apache.org/jira/browse/FLINK-33066 Could you clarify what do y

[GitHub] [flink-kubernetes-operator] mbalassi commented on pull request #671: [FLINK-33066] Support all k8s methods to configure env variable in operatorPod

2023-09-13 Thread via GitHub
mbalassi commented on PR #671: URL: https://github.com/apache/flink-kubernetes-operator/pull/671#issuecomment-1717348931 Thanks, @dongwoo6kim. Please include the documentation in this change, unfortunately we maintain that manually here: https://github.com/apache/flink-kubernetes-operat

[GitHub] [flink] TanYuxin-tyx commented on pull request #23401: [FLINK-30906][task] TwoInputStreamTask and MultipleInputStreamTask passes wrong configuration when create input processor

2023-09-13 Thread via GitHub
TanYuxin-tyx commented on PR #23401: URL: https://github.com/apache/flink/pull/23401#issuecomment-1717360318 @reswqa Thanks for fixing the configuration bug. 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

[GitHub] [flink] reswqa commented on pull request #23401: [FLINK-30906][task] TwoInputStreamTask and MultipleInputStreamTask passes wrong configuration when create input processor

2023-09-13 Thread via GitHub
reswqa commented on PR #23401: URL: https://github.com/apache/flink/pull/23401#issuecomment-1717361467 Thanks! 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 the specific comment. To

[GitHub] [flink] reswqa merged pull request #23401: [FLINK-30906][task] TwoInputStreamTask and MultipleInputStreamTask passes wrong configuration when create input processor

2023-09-13 Thread via GitHub
reswqa merged PR #23401: URL: https://github.com/apache/flink/pull/23401 -- 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] [Created] (FLINK-33084) Migrate globalJobParameter in ExecutionConfig to configuration instance

2023-09-13 Thread Junrui Li (Jira)
Junrui Li created FLINK-33084: - Summary: Migrate globalJobParameter in ExecutionConfig to configuration instance Key: FLINK-33084 URL: https://issues.apache.org/jira/browse/FLINK-33084 Project: Flink

[jira] [Commented] (FLINK-33052) codespeed server is down

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764581#comment-17764581 ] Piotr Nowojski commented on FLINK-33052: We have been always treating benchmarki

[jira] [Closed] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor

2023-09-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-30906. -- Resolution: Fixed master(1.19) via 70f4c40f15f38ed404d8e031a08d534326535ced. > TwoInputStreamTask pas

[jira] [Updated] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor

2023-09-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30906: --- Fix Version/s: 1.19.0 > TwoInputStreamTask passes wrong configuration object when creating input >

[jira] [Updated] (FLINK-33052) codespeed server is down

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-33052: --- Priority: Blocker (was: Critical) > codespeed server is down > > >

[GitHub] [flink] TanYuxin-tyx commented on pull request #23404: [FLINK-33076][network] Reduce serialization overhead of broadcast emit from ChannelSelectorRecordWriter.

2023-09-13 Thread via GitHub
TanYuxin-tyx commented on PR #23404: URL: https://github.com/apache/flink/pull/23404#issuecomment-1717364731 Thanks @reswqa for fixing the bug. LGTM 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

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764581#comment-17764581 ] Piotr Nowojski edited comment on FLINK-33052 at 9/13/23 10:28 AM:

[GitHub] [flink] reswqa commented on pull request #23404: [FLINK-33076][network] Reduce serialization overhead of broadcast emit from ChannelSelectorRecordWriter.

2023-09-13 Thread via GitHub
reswqa commented on PR #23404: URL: https://github.com/apache/flink/pull/23404#issuecomment-1717367967 Thanks for the review! Squashed the fix-up commit. I will merge this if pipeline passed. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Assigned] (FLINK-33084) Migrate globalJobParameter in ExecutionConfig to configuration instance

2023-09-13 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-33084: -- Assignee: Junrui Li > Migrate globalJobParameter in ExecutionConfig to configuration instance

[jira] [Updated] (FLINK-33084) Migrate globalJobParameter in ExecutionConfig to configuration instance

2023-09-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33084: --- Labels: pull-request-available (was: ) > Migrate globalJobParameter in ExecutionConfig to c

[GitHub] [flink] JunRuiLee opened a new pull request, #23409: [FLINK-33084][runtime] Migrate globalJobParameter to configuration.

2023-09-13 Thread via GitHub
JunRuiLee opened a new pull request, #23409: URL: https://github.com/apache/flink/pull/23409 ## What is the purpose of the change Migrate globalJobParameter to configuration. ## Brief change log Migrate globalJobParameter to configuration. ## Verifying

[GitHub] [flink] wangzzu commented on a diff in pull request #23399: [FLINK-33061][docs] Translate failure-enricher documentation to Chinese

2023-09-13 Thread via GitHub
wangzzu commented on code in PR #23399: URL: https://github.com/apache/flink/pull/23399#discussion_r1324344461 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -42,7 +42,7 @@ To implement a custom FailureEnricher plugin, you need to: Then, create a jar whi

[GitHub] [flink] flinkbot commented on pull request #23409: [FLINK-33084][runtime] Migrate globalJobParameter to configuration.

2023-09-13 Thread via GitHub
flinkbot commented on PR #23409: URL: https://github.com/apache/flink/pull/23409#issuecomment-1717412004 ## CI report: * 20e1f350e3ef6dd6a37701317ea7a9feccab9b0e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-21949) Support ARRAY_AGG aggregate function

2023-09-13 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-21949: --- Summary: Support ARRAY_AGG aggregate function (was: Support collect to array aggregate function) >

[jira] [Created] (FLINK-33085) Improve the error message when the invalidate lookupTableSource without primary key is used as temporal join table

2023-09-13 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-33085: - Summary: Improve the error message when the invalidate lookupTableSource without primary key is used as temporal join table Key: FLINK-33085 URL: https://issues.apache.org/jira/

[jira] [Closed] (FLINK-33011) Operator deletes HA data unexpectedly

2023-09-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-33011. -- Fix Version/s: kubernetes-operator-1.7.0 Resolution: Fixed merged to main 82739f62adda33e686da7

[GitHub] [flink] swuferhong opened a new pull request, #23410: [FLINK-33085][table-planner] Improve the error message when the invalidated lookupTableSource without primary key is used as temporal joi

2023-09-13 Thread via GitHub
swuferhong opened a new pull request, #23410: URL: https://github.com/apache/flink/pull/23410 ## What is the purpose of the change Improve the error message when the invalidate `lookupTableSource` without primary key is used as temporal join table. This pr can check the legal

[jira] [Updated] (FLINK-33085) Improve the error message when the invalidate lookupTableSource without primary key is used as temporal join table

2023-09-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33085: --- Labels: pull-request-available (was: ) > Improve the error message when the invalidate look

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

2023-09-13 Thread via GitHub
lindong28 commented on PR #248: URL: https://github.com/apache/flink-ml/pull/248#issuecomment-1717534003 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 the specific

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

2023-09-13 Thread via GitHub
lindong28 merged PR #248: URL: https://github.com/apache/flink-ml/pull/248 -- 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.apac

[jira] [Assigned] (FLINK-32704) Supports spilling to disk when feedback channel memory buffer is full

2023-09-13 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-32704: Assignee: Jiang Xin > Supports spilling to disk when feedback channel memory buffer is full > ---

[jira] [Commented] (FLINK-32704) Supports spilling to disk when feedback channel memory buffer is full

2023-09-13 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764635#comment-17764635 ] Dong Lin commented on FLINK-32704: -- Merged to apache/flink-ml master branch 865404910ca

[GitHub] [flink] flinkbot commented on pull request #23410: [FLINK-33085][table-planner] Improve the error message when the invalidated lookupTableSource without primary key is used as temporal join t

2023-09-13 Thread via GitHub
flinkbot commented on PR #23410: URL: https://github.com/apache/flink/pull/23410#issuecomment-1717541375 ## CI report: * a5f93f4153d0b8430d836a35a6f79b80caa76457 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-13 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764640#comment-17764640 ] Yangze Guo commented on FLINK-33053: JFYI, I'm still investigating the root cause of

[GitHub] [flink-kubernetes-operator] dongwoo6kim commented on pull request #671: [FLINK-33066] Support all k8s methods to configure env variable in operatorPod

2023-09-13 Thread via GitHub
dongwoo6kim commented on PR #671: URL: https://github.com/apache/flink-kubernetes-operator/pull/671#issuecomment-1717548787 Thanks @mbalassi. I have updated the docs -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] hejufang commented on pull request #23403: [FLINK-32863][runtime-web] Improve Flink UI's time precision from sec…

2023-09-13 Thread via GitHub
hejufang commented on PR #23403: URL: https://github.com/apache/flink/pull/23403#issuecomment-1717554816 @masteryhx Thank you for your suggestion. I have adjusted the precision of checkpoint related time. please review. cc @KarmaGYZ ![img_v2_a30822c5-c560-4789-9226-ca3899483b7g](https

[jira] [Closed] (FLINK-32704) Supports spilling to disk when feedback channel memory buffer is full

2023-09-13 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-32704. Resolution: Fixed > Supports spilling to disk when feedback channel memory buffer is full > --

[GitHub] [flink] Jiabao-Sun opened a new pull request, #23411: [FLINK-21949][table] Support ARRAY_AGG aggregate function

2023-09-13 Thread via GitHub
Jiabao-Sun opened a new pull request, #23411: URL: https://github.com/apache/flink/pull/23411 ## What is the purpose of the change [FLINK-21949][table] Support ARRAY_AGG aggregate function Some nosql databases like mongodb and elasticsearch support nested data types.

[jira] [Updated] (FLINK-21949) Support ARRAY_AGG aggregate function

2023-09-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21949: --- Labels: pull-request-available (was: ) > Support ARRAY_AGG aggregate function > ---

[jira] [Commented] (FLINK-21949) Support ARRAY_AGG aggregate function

2023-09-13 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764658#comment-17764658 ] Jiabao Sun commented on FLINK-21949: The pull request is ready for review now. This

[GitHub] [flink] flinkbot commented on pull request #23411: [FLINK-21949][table] Support ARRAY_AGG aggregate function

2023-09-13 Thread via GitHub
flinkbot commented on PR #23411: URL: https://github.com/apache/flink/pull/23411#issuecomment-1717597767 ## CI report: * 10081ad9bdba84b3dac22fb7a6137994cc79622b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33083) SupportsReadingMetadata is not applied when loading a CompiledPlan

2023-09-13 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764666#comment-17764666 ] Yunhong Zheng commented on FLINK-33083: --- It looks like this is a planner bug, and

[jira] [Assigned] (FLINK-33083) SupportsReadingMetadata is not applied when loading a CompiledPlan

2023-09-13 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-33083: Assignee: Dawid Wysakowicz > SupportsReadingMetadata is not applied when loading

[jira] [Commented] (FLINK-28758) FlinkKafkaConsumer fails to stop with savepoint

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764673#comment-17764673 ] Piotr Nowojski commented on FLINK-28758: I will try to take care of that > Flin

[jira] [Assigned] (FLINK-28758) FlinkKafkaConsumer fails to stop with savepoint

2023-09-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-28758: -- Assignee: Piotr Nowojski (was: Mark Cho) > FlinkKafkaConsumer fails to stop with sav

[jira] [Commented] (FLINK-31966) Flink Kubernetes operator lacks TLS support

2023-09-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764674#comment-17764674 ] Gyula Fora commented on FLINK-31966: [~tagarr] I think that sounds reasonable. I thi

[jira] [Commented] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei commented on FLINK-33052: -- # I think this issue is very critical as you mentio

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:30 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:31 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:31 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:31 PM: --- He

[GitHub] [flink-connector-kafka] boring-cyborg[bot] commented on pull request #48: [FLINK-28758] Fix stop-with-savepoint for FlinkKafkaConsumer

2023-09-13 Thread via GitHub
boring-cyborg[bot] commented on PR #48: URL: https://github.com/apache/flink-connector-kafka/pull/48#issuecomment-1717647945 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is a

[jira] [Updated] (FLINK-28758) FlinkKafkaConsumer fails to stop with savepoint

2023-09-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28758: --- Labels: pull-request-available (was: ) > FlinkKafkaConsumer fails to stop with savepoint >

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:35 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:35 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:39 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:41 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:44 PM: --- He

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #672: [FLINK-33081] Apply parallelism overrides in scale

2023-09-13 Thread via GitHub
mxm commented on code in PR #672: URL: https://github.com/apache/flink-kubernetes-operator/pull/672#discussion_r1324308777 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java: ## @@ -74,6 +76,36 @@ public

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764702#comment-17764702 ] Zili Chen commented on FLINK-33053: --- I noticed that the {{TreeCache}}'s close call {{r

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 2:14 PM: --- He

[GitHub] [flink] dawidwys opened a new pull request, #23412: [FLINK-33083] Properly apply ReadingMetadataSpec for a TableSourceScan

2023-09-13 Thread via GitHub
dawidwys opened a new pull request, #23412: URL: https://github.com/apache/flink/pull/23412 ## What is the purpose of the change The PR fixes creating a TableSourceScan to also include a proper ReadingMetadataSpec which has been applied on the source. ## Brief change log

[jira] [Updated] (FLINK-33083) SupportsReadingMetadata is not applied when loading a CompiledPlan

2023-09-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33083: --- Labels: pull-request-available (was: ) > SupportsReadingMetadata is not applied when loadin

[GitHub] [flink] flinkbot commented on pull request #23412: [FLINK-33083] Properly apply ReadingMetadataSpec for a TableSourceScan

2023-09-13 Thread via GitHub
flinkbot commented on PR #23412: URL: https://github.com/apache/flink/pull/23412#issuecomment-1717739419 ## CI report: * 75b651538a1fa083c211ab8c4020822590b89043 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764721#comment-17764721 ] Zili Chen commented on FLINK-33053: --- See https://lists.apache.org/thread/3b9hn9j4c05yf

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-13 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764723#comment-17764723 ] Zili Chen commented on FLINK-33053: --- But we don't have other shared watchers so we can

[GitHub] [flink-kubernetes-operator] sbrother commented on pull request #668: Give cluster/job role access to k8s services API

2023-09-13 Thread via GitHub
sbrother commented on PR #668: URL: https://github.com/apache/flink-kubernetes-operator/pull/668#issuecomment-1717779633 No problem, I just requested an Apache Jira account. And yes, I think that's what I mean. I had created a Flink Session Controller using a basic FlinkDeployment ma

  1   2   >