[jira] [Closed] (FLINK-34135) A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied.

2024-01-23 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov closed FLINK-34135. -- Resolution: Fixed > A number of ci failures with Access to the path >

[jira] [Closed] (FLINK-34098) Not enough Azure Pipeline CI runners available?

2024-01-23 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov closed FLINK-34098. -- Resolution: Fixed It was a disk-full issue. I reported the recurring error (that leads to the

Re: [PR] [FLINK-33263][table-planner] Implement ParallelismProvider for sources in the table planner [flink]

2024-01-23 Thread via GitHub
libenchao commented on code in PR #24128: URL: https://github.com/apache/flink/pull/24128#discussion_r1464205544 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SourceTransformationWrapper.java: ## @@ -0,0 +1,72 @@ +/* +Licensed to the

Re: [PR] [FLINK-34132][runtime] Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. [flink]

2024-01-23 Thread via GitHub
wanglijie95 commented on code in PR #24118: URL: https://github.com/apache/flink/pull/24118#discussion_r1464226470 ## docs/content/docs/deployment/elastic_scaling.md: ## @@ -238,7 +238,7 @@ In addition, there are several related configuration options that may need adjus ###

Re: [PR] [FLINK-34132][runtime] Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. [flink]

2024-01-23 Thread via GitHub
wanglijie95 commented on code in PR #24118: URL: https://github.com/apache/flink/pull/24118#discussion_r1464214787 ## docs/content/docs/deployment/elastic_scaling.md: ## @@ -238,7 +238,7 @@ In addition, there are several related configuration options that may need adjus ###

[jira] [Updated] (FLINK-33198) Add timestamp with local time zone support in Avro converters

2024-01-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-33198: --- Priority: Major (was: Minor) > Add timestamp with local time zone support in Avro converters >

Re: [PR] [FLINK-34144][docs] Update the documentation about dynamic source parallelism inference [flink]

2024-01-23 Thread via GitHub
flinkbot commented on PR #24184: URL: https://github.com/apache/flink/pull/24184#issuecomment-1907311524 ## CI report: * e807815c4ced6ae83dec3c251833a3d4586868cb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-24024][table-planner] support session window tvf in plan [flink]

2024-01-23 Thread via GitHub
xuyangzhong commented on code in PR #23505: URL: https://github.com/apache/flink/pull/23505#discussion_r1464224820 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/agg/WindowAggregateTest.xml: ## @@ -2614,6 +2614,66 @@

[PR] [FLINK-34144][docs] Update the documentation about dynamic source parallelism inference [flink]

2024-01-23 Thread via GitHub
SinBex opened a new pull request, #24184: URL: https://github.com/apache/flink/pull/24184 ## What is the purpose of the change

[jira] [Updated] (FLINK-34144) Update the documentation and configuration description about dynamic source parallelism inference

2024-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34144: --- Labels: pull-request-available (was: ) > Update the documentation and configuration

Re: [PR] [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect, back port to 1.17 [flink]

2024-01-23 Thread via GitHub
luoyuxia merged PR #24148: URL: https://github.com/apache/flink/pull/24148 -- 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] [Closed] (FLINK-31090) Flink SQL fail to select INTERVAL

2024-01-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia closed FLINK-31090. Resolution: Fixed > Flink SQL fail to select INTERVAL > -- > >

[jira] [Updated] (FLINK-31090) Flink SQL fail to select INTERVAL

2024-01-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-31090: - Fix Version/s: 1.18.0 > Flink SQL fail to select INTERVAL > -- > >

Re: [PR] [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect, back port to 1.18 [flink]

2024-01-23 Thread via GitHub
luoyuxia merged PR #24149: URL: https://github.com/apache/flink/pull/24149 -- 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:

Re: [PR] [FLINK-34055][table] Introduce a new annotation for named parameters [flink]

2024-01-23 Thread via GitHub
hackergin commented on code in PR #24106: URL: https://github.com/apache/flink/pull/24106#discussion_r1464193652 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/extraction/TypeInferenceExtractorTest.java: ## @@ -427,8 +428,7 @@ private static Stream

[jira] [Resolved] (FLINK-33198) Add timestamp with local time zone support in Avro converters

2024-01-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-33198. Resolution: Implemented Implemented in master(1.19): 533ead6ae946cbc77525d276b6dea965d390181a >

[jira] [Commented] (FLINK-33233) Null point exception when non-native udf used in join condition

2024-01-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810188#comment-17810188 ] luoyuxia commented on FLINK-33233: -- 1.17:

[jira] [Resolved] (FLINK-33233) Null point exception when non-native udf used in join condition

2024-01-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-33233. -- Fix Version/s: 1.17.3 1.18.2 Resolution: Fixed > Null point exception when

[jira] [Commented] (FLINK-34218) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

2024-01-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810189#comment-17810189 ] Rui Fan commented on FLINK-34218: - Hi [~srichter],

Re: [PR] [FLINK-34115][table-planner] Fix unstable TableAggregateITCase.testFlagAggregateWithOrWithoutIncrementalUpdate [flink]

2024-01-23 Thread via GitHub
LadyForest commented on PR #24178: URL: https://github.com/apache/flink/pull/24178#issuecomment-1907215660 @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-34120] Introduce unified serialization config option for all Kryo, POJO and customized serializers [flink]

2024-01-23 Thread via GitHub
X-czh commented on PR #24182: URL: https://github.com/apache/flink/pull/24182#issuecomment-1907215961 @reswqa Could you help review it? Thx~ -- 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

Re: [PR] [FLINK-33865][runtime] Adding an ITCase to ensure `exponential-delay.attempts-before-reset-backoff` works well [flink]

2024-01-23 Thread via GitHub
1996fanrui commented on PR #23942: URL: https://github.com/apache/flink/pull/23942#issuecomment-1907277744 @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-34132][runtime] Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. [flink]

2024-01-23 Thread via GitHub
JunRuiLee commented on code in PR #24118: URL: https://github.com/apache/flink/pull/24118#discussion_r1464218412 ## docs/content/docs/deployment/elastic_scaling.md: ## @@ -238,7 +238,7 @@ In addition, there are several related configuration options that may need adjus ###

[jira] [Reopened] (FLINK-31409) Hive dialect should use public interfaces in Hive connector

2024-01-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reopened FLINK-31409: -- > Hive dialect should use public interfaces in Hive connector >

Re: [PR] [FLINK-33577][dist] Change the default config file to config.yaml in flink-dist. [flink]

2024-01-23 Thread via GitHub
JunRuiLee commented on PR #24177: URL: https://github.com/apache/flink/pull/24177#issuecomment-1907348848 Hi @HuangXingBo , this pr includes some PyFlink changes related to the adoption of a new configuration file, config.yaml. Could you please help review it? -- This is an automated

Re: [PR] [FLINK-33803] Set observedGeneration at end of reconciliation [flink-kubernetes-operator]

2024-01-23 Thread via GitHub
justin-chen commented on code in PR #755: URL: https://github.com/apache/flink-kubernetes-operator/pull/755#discussion_r1463969344 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java: ## @@ -126,6 +126,9 @@

[jira] [Commented] (FLINK-34135) A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied.

2024-01-23 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810104#comment-17810104 ] Jeyhun Karimov commented on FLINK-34135: Hi [~mapohl] yes CI seems stable again, we can close

Re: [PR] [FLINK-23687][table-planner] Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys [flink]

2024-01-23 Thread via GitHub
yunfan123 commented on PR #24104: URL: https://github.com/apache/flink/pull/24104#issuecomment-1907264935 @LB-Yu Hello. Thanks for your comment. I have resolved the issue in the latest commit and supplemented it with additional unit tests -- This is an automated message from the Apache

[jira] [Commented] (FLINK-33958) Implement restore tests for IntervalJoin node

2024-01-23 Thread Bonnie Varghese (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810141#comment-17810141 ] Bonnie Varghese commented on FLINK-33958: - Apologize for the delayed response. Im trying to

Re: [PR] [FLINK-34210][Runtime/Checkpointing] Fix DefaultExecutionGraphBuilder#isCheckpointingEnabled return wrong value when checkpoint disabled [flink]

2024-01-23 Thread via GitHub
masteryhx commented on PR #24173: URL: https://github.com/apache/flink/pull/24173#issuecomment-1907224952 @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

[PR] Draft: Flip 387 optional argument [flink]

2024-01-23 Thread via GitHub
hackergin opened a new pull request, #24183: URL: https://github.com/apache/flink/pull/24183 ## 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

Re: [PR] [FLINK-33198][Format/Avro] support local timezone timestamp logic type in AVRO [flink]

2024-01-23 Thread via GitHub
leonardBang merged PR #23511: URL: https://github.com/apache/flink/pull/23511 -- 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] [Commented] (FLINK-31409) Hive dialect should use public interfaces in Hive connector

2024-01-23 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810185#comment-17810185 ] Benchao Li commented on FLINK-31409: [~luoyuxia] Could you fill the fixVersion of this issue? >

Re: [PR] introduce BufferBundle for minibatch join [flink]

2024-01-23 Thread via GitHub
xishuaidelin commented on PR #24159: URL: https://github.com/apache/flink/pull/24159#issuecomment-1907309476 @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] [Resolved] (FLINK-31409) Hive dialect should use public interfaces in Hive connector

2024-01-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-31409. -- Fix Version/s: 1.18.0 Resolution: Fixed > Hive dialect should use public interfaces in Hive

[jira] [Commented] (FLINK-31409) Hive dialect should use public interfaces in Hive connector

2024-01-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810187#comment-17810187 ] luoyuxia commented on FLINK-31409: -- [~libenchao] Thanks for reminder. > Hive dialect should use public

[jira] [Created] (FLINK-34218) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

2024-01-23 Thread Rui Fan (Jira)
Rui Fan created FLINK-34218: --- Summary: AutoRescalingITCase#testCheckpointRescalingInKeyedState fails Key: FLINK-34218 URL: https://issues.apache.org/jira/browse/FLINK-34218 Project: Flink Issue

Re: [PR] Draft: Flip 387 optional argument [flink]

2024-01-23 Thread via GitHub
flinkbot commented on PR #24183: URL: https://github.com/apache/flink/pull/24183#issuecomment-1907229799 ## CI report: * 0d402864671fb4dc34f036fc44b71252f66d63db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34143] Modify the effective strategy of `execution.batch.adaptive.auto-parallelism.default-source-parallelism` [flink]

2024-01-23 Thread via GitHub
zhuzhurk closed pull request #24170: [FLINK-34143] Modify the effective strategy of `execution.batch.adaptive.auto-parallelism.default-source-parallelism` URL: https://github.com/apache/flink/pull/24170 -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-34143) Modify the effective strategy of `execution.batch.adaptive.auto-parallelism.default-source-parallelism`

2024-01-23 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-34143. --- Fix Version/s: 1.19.0 Resolution: Done master/release-1.19: 97caa3c251e416640a6f54ea103912839c346f70

Re: [PR] [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption [flink]

2024-01-23 Thread via GitHub
Zakelly commented on PR #24181: URL: https://github.com/apache/flink/pull/24181#issuecomment-1907248389 @fredia @masteryhx Would you please take a look? Thanks! -- 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-33865][runtime] Adding an ITCase to ensure `exponential-delay.attempts-before-reset-backoff` works well [flink]

2024-01-23 Thread via GitHub
1996fanrui merged PR #23942: URL: https://github.com/apache/flink/pull/23942 -- 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:

Re: [PR] [FLINK-33865][runtime] Adding an ITCase to ensure `exponential-delay.attempts-before-reset-backoff` works well [flink]

2024-01-23 Thread via GitHub
1996fanrui commented on PR #23942: URL: https://github.com/apache/flink/pull/23942#issuecomment-1907374215 Thanks @RocMarshal for the review! > Thanks @1996fanrui for the contribution, But the CI failed. could you check it? LGTM +1. I checked it, and it's not related to this

[jira] [Updated] (FLINK-34223) Introduce a migration tool to transfer legacy config file to new config file

2024-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34223: --- Labels: pull-request-available (was: ) > Introduce a migration tool to transfer legacy

[PR] [FLINK-34223][dist] Introduce a migration tool to transfer legacy config file to new config file. [flink]

2024-01-23 Thread via GitHub
JunRuiLee opened a new pull request, #24185: URL: https://github.com/apache/flink/pull/24185 ## What is the purpose of the change As we transition to new configuration files that adhere to the standard YAML format, users are expected to manually migrate their existing

Re: [PR] [FLINK-33803] Set observedGeneration at end of reconciliation [flink-kubernetes-operator]

2024-01-23 Thread via GitHub
gyfora commented on code in PR #755: URL: https://github.com/apache/flink-kubernetes-operator/pull/755#discussion_r1464380455 ## flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/reconciler/ReconciliationMetadata.java: ## @@ -42,6 +42,7 @@

Re: [PR] [FLINK-34145][connector/filesystem] support dynamic source parallelism inference in batch jobs [flink]

2024-01-23 Thread via GitHub
flinkbot commented on PR #24186: URL: https://github.com/apache/flink/pull/24186#issuecomment-1907491277 ## CI report: * cf88c4b65ae73600d8efb25d6273a7ea16ae5b2d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-28915] Support fetching artifacts in native K8s and standalone application mode [flink]

2024-01-23 Thread via GitHub
mbalassi commented on code in PR #24065: URL: https://github.com/apache/flink/pull/24065#discussion_r1464456656 ## docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md: ## @@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar $FLINK_HOME/usrlib/my-flink-job.jar

[jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP

2024-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810247#comment-17810247 ] Matthias Pohl commented on FLINK-33186: ---

[jira] [Resolved] (FLINK-34174) Remove SlotMatchingStrategy related logic

2024-01-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34174. - Fix Version/s: 1.19.0 Resolution: Fixed > Remove SlotMatchingStrategy related logic >

[jira] [Commented] (FLINK-34174) Remove SlotMatchingStrategy related logic

2024-01-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810199#comment-17810199 ] Rui Fan commented on FLINK-34174: - Merged to master(1.19.0) via :

Re: [PR] [FLINK-34223][dist] Introduce a migration tool to transfer legacy config file to new config file. [flink]

2024-01-23 Thread via GitHub
flinkbot commented on PR #24185: URL: https://github.com/apache/flink/pull/24185#issuecomment-1907481027 ## CI report: * 19b6b48ebe252e29200838665e6bbc42583d5f98 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-33760) Group Window agg has different result when only consuming -D records while using or not using minibatch

2024-01-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-33760: - Assignee: Yunhong Zheng > Group Window agg has different result when only consuming -D

[jira] [Created] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out

2024-01-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34224: - Summary: ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Key: FLINK-34224 URL: https://issues.apache.org/jira/browse/FLINK-34224

[jira] [Commented] (FLINK-34218) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

2024-01-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810197#comment-17810197 ] Rui Fan commented on FLINK-34218: - I run it in my local more than 30 times, all of them are successful.

[jira] [Created] (FLINK-34221) Introduce operator for minibatch join

2024-01-23 Thread Shuai Xu (Jira)
Shuai Xu created FLINK-34221: Summary: Introduce operator for minibatch join Key: FLINK-34221 URL: https://issues.apache.org/jira/browse/FLINK-34221 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2024-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810241#comment-17810241 ] Matthias Pohl commented on FLINK-31472: --- Sure, if we are certain that this is a test issue and not

[jira] [Updated] (FLINK-34195) PythonEnvUtils creates python environment instead of python3

2024-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34195: -- Labels: starter (was: ) > PythonEnvUtils creates python environment instead of python3 >

Re: [PR] [FLINK-34007][k8s] Adds workaround that fixes the deadlock when renewing the leadership lease fails [flink]

2024-01-23 Thread via GitHub
XComp commented on PR #24132: URL: https://github.com/apache/flink/pull/24132#issuecomment-1907572028 [ci failure](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=56790) is caused by some infrastructure instability in the compile step of the

Re: [PR] [FLINK-34174][runtime] Remove SlotMatchingStrategy related logic [flink]

2024-01-23 Thread via GitHub
1996fanrui commented on PR #24158: URL: https://github.com/apache/flink/pull/24158#issuecomment-1907376784 No any comments for 2 days, 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

Re: [PR] [FLINK-34174][runtime] Remove SlotMatchingStrategy related logic [flink]

2024-01-23 Thread via GitHub
1996fanrui merged PR #24158: URL: https://github.com/apache/flink/pull/24158 -- 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:

Re: [PR] [FLINK-24024][table-planner] support session window tvf in plan [flink]

2024-01-23 Thread via GitHub
xuyangzhong commented on PR #23505: URL: https://github.com/apache/flink/pull/23505#issuecomment-1907407611 @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-34210][Runtime/Checkpointing] Fix DefaultExecutionGraphBuilder#isCheckpointingEnabled return wrong value when checkpoint disabled [flink]

2024-01-23 Thread via GitHub
mayuehappy commented on PR #24173: URL: https://github.com/apache/flink/pull/24173#issuecomment-1907411370 @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] [Closed] (FLINK-34205) Update flink-docker's Dockerfile and docker-entrypoint.sh to use BashJavaUtils for Flink configuration management

2024-01-23 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-34205. --- Fix Version/s: 1.19.0 Resolution: Done dev-master: 44f058287cc956a620b12b6f8ed214e44dc3db77 >

[jira] [Assigned] (FLINK-34205) Update flink-docker's Dockerfile and docker-entrypoint.sh to use BashJavaUtils for Flink configuration management

2024-01-23 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-34205: --- Assignee: Junrui Li > Update flink-docker's Dockerfile and docker-entrypoint.sh to use >

[jira] [Created] (FLINK-34222) Get minibatch join operator involved

2024-01-23 Thread Shuai Xu (Jira)
Shuai Xu created FLINK-34222: Summary: Get minibatch join operator involved Key: FLINK-34222 URL: https://issues.apache.org/jira/browse/FLINK-34222 Project: Flink Issue Type: Sub-task

Re: [PR] [FLINK-34007][k8s] Adds workaround that fixes the deadlock when renewing the leadership lease fails [flink]

2024-01-23 Thread via GitHub
XComp commented on PR #24132: URL: https://github.com/apache/flink/pull/24132#issuecomment-1907572233 @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.

Re: [PR] [FLINK-34210][Runtime/Checkpointing] Fix DefaultExecutionGraphBuilder#isCheckpointingEnabled return wrong value when checkpoint disabled [flink]

2024-01-23 Thread via GitHub
mayuehappy commented on PR #24173: URL: https://github.com/apache/flink/pull/24173#issuecomment-1907582420 @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] [Commented] (FLINK-33865) exponential-delay.attempts-before-reset-backoff doesn't work when it's set in Job Configuration

2024-01-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810198#comment-17810198 ] Rui Fan commented on FLINK-33865: - Merged to master(1.19.0) via: *

[jira] [Resolved] (FLINK-33865) exponential-delay.attempts-before-reset-backoff doesn't work when it's set in Job Configuration

2024-01-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33865. - Fix Version/s: 1.19.0 Resolution: Fixed > exponential-delay.attempts-before-reset-backoff

Re: [PR] [FLINK-34205] Use BashJavaUtils for Flink configuration management [flink-docker]

2024-01-23 Thread via GitHub
zhuzhurk merged PR #175: URL: https://github.com/apache/flink-docker/pull/175 -- 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] [Created] (FLINK-34220) introduce buffer bundle for minibatch join

2024-01-23 Thread Shuai Xu (Jira)
Shuai Xu created FLINK-34220: Summary: introduce buffer bundle for minibatch join Key: FLINK-34220 URL: https://issues.apache.org/jira/browse/FLINK-34220 Project: Flink Issue Type: Sub-task

Re: [PR] [FLINK-34055][table] Introduce a new annotation for named parameters [flink]

2024-01-23 Thread via GitHub
fsk119 commented on code in PR #24106: URL: https://github.com/apache/flink/pull/24106#discussion_r1464215746 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/ProcedureHint.java: ## @@ -139,6 +139,18 @@ */ String[] argumentNames()

[jira] [Created] (FLINK-34219) Introduce a new join operator to support minibatch

2024-01-23 Thread Shuai Xu (Jira)
Shuai Xu created FLINK-34219: Summary: Introduce a new join operator to support minibatch Key: FLINK-34219 URL: https://issues.apache.org/jira/browse/FLINK-34219 Project: Flink Issue Type: New

[jira] [Created] (FLINK-34223) Introduce a migration tool to transfer legacy config file to new config file

2024-01-23 Thread Junrui Li (Jira)
Junrui Li created FLINK-34223: - Summary: Introduce a migration tool to transfer legacy config file to new config file Key: FLINK-34223 URL: https://issues.apache.org/jira/browse/FLINK-34223 Project:

[PR] [FLINK-34145][connector/filesystem] support dynamic source parallelism inference in batch jobs [flink]

2024-01-23 Thread via GitHub
SinBex opened a new pull request, #24186: URL: https://github.com/apache/flink/pull/24186 ## What is the purpose of the change *[FLIP-379](https://cwiki.apache.org/confluence/display/FLINK/FLIP-379%3A+Dynamic+source+parallelism+inference+for+batch+jobs) has introduced support for

[jira] [Updated] (FLINK-34145) File source connector support dynamic source parallelism inference in batch jobs

2024-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34145: --- Labels: pull-request-available (was: ) > File source connector support dynamic source

[jira] [Commented] (FLINK-33760) Group Window agg has different result when only consuming -D records while using or not using minibatch

2024-01-23 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810232#comment-17810232 ] Yunhong Zheng commented on FLINK-33760: --- [~xuyangzhong]  It looks like a bug,  I want to take this

[jira] [Updated] (FLINK-34155) Recurring SqlExecutionException

2024-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34155: -- Labels: test-stability (was: test) > Recurring SqlExecutionException >

[jira] [Commented] (FLINK-34155) Recurring SqlExecutionException

2024-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810238#comment-17810238 ] Matthias Pohl commented on FLINK-34155: --- How big is the mvn.log? I'm wondering whether it would be

Re: [PR] [FLINK-34210][Runtime/Checkpointing] Fix DefaultExecutionGraphBuilder#isCheckpointingEnabled return wrong value when checkpoint disabled [flink]

2024-01-23 Thread via GitHub
mayuehappy commented on PR #24173: URL: https://github.com/apache/flink/pull/24173#issuecomment-1907564710 @masteryhx I found some unit tests failed after change.

[jira] [Created] (FLINK-34209) Migrate FileSink to the new SinkV2 API

2024-01-23 Thread Peter Vary (Jira)
Peter Vary created FLINK-34209: -- Summary: Migrate FileSink to the new SinkV2 API Key: FLINK-34209 URL: https://issues.apache.org/jira/browse/FLINK-34209 Project: Flink Issue Type: Sub-task

[jira] [Resolved] (FLINK-33403) Bump flink version to 1.18.1 for flink-kubernetes-operator

2024-01-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33403. - Fix Version/s: kubernetes-operator-1.8.0 Resolution: Fixed > Bump flink version to 1.18.1 for

Re: [PR] [FLINK-34165] update the apache download url [flink-docker]

2024-01-23 Thread via GitHub
JingGe merged PR #176: URL: https://github.com/apache/flink-docker/pull/176 -- 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] [Updated] (FLINK-33287) Using the flink shaded jackson for flink-autoscaler

2024-01-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33287: --- Labels: pull-request-available (was: ) > Using the flink shaded jackson for

[jira] [Commented] (FLINK-33842) Publish the Dockerfiles for the new release

2024-01-23 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809850#comment-17809850 ] Jing Ge commented on FLINK-33842: - official-image PR:

[jira] [Resolved] (FLINK-34165) It seems that Apache download link has been changed

2024-01-23 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-34165. - Resolution: Fixed > It seems that Apache download link has been changed >

Re: [PR] [FLINK-33365] include filters with Lookup joins [flink-connector-jdbc]

2024-01-23 Thread via GitHub
libenchao commented on PR #79: URL: https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1905659276 @davidradl > * I don't think we can have 0 key names for a lookup join. Have you a test case that would drive this ? There is no such restriction in semantic

[jira] [Closed] (FLINK-33975) Tests for the new Sink V2 transformations

2024-01-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-33975. -- Fix Version/s: 1.19.0 Resolution: Fixed merged to master

[jira] [Comment Edited] (FLINK-34148) Potential regression (Jan. 13): stringWrite with Java8

2024-01-23 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809796#comment-17809796 ] Sergey Nuyanzin edited comment on FLINK-34148 at 1/23/24 8:28 AM: -- An

[jira] [Commented] (FLINK-32609) Kafka table source supports projection push down

2024-01-23 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809803#comment-17809803 ] SuDewei commented on FLINK-32609: - [~lsy] Hi dalong, do you have time to continue this work? If not, I’m

Re: [PR] [FLINK-34199] Add tracing for durations of rescaling/restoring from local state [flink]

2024-01-23 Thread via GitHub
StefanRRichter commented on PR #24168: URL: https://github.com/apache/flink/pull/24168#issuecomment-1905595304 Besides that, I already merged a PR that measures local/remote state sizes. And in our meeting we found that all of the metrics are useful :) -- This is an automated message

[jira] [Created] (FLINK-34210) DefaultExecutionGraphBuilder#isCheckpointingEnabled may return Wrong Value when checkpoint disabled

2024-01-23 Thread Yue Ma (Jira)
Yue Ma created FLINK-34210: -- Summary: DefaultExecutionGraphBuilder#isCheckpointingEnabled may return Wrong Value when checkpoint disabled Key: FLINK-34210 URL: https://issues.apache.org/jira/browse/FLINK-34210

Re: [PR] [FLINK-34199] Add tracing for durations of rescaling/restoring from local state [flink]

2024-01-23 Thread via GitHub
StefanRRichter commented on PR #24168: URL: https://github.com/apache/flink/pull/24168#issuecomment-1905684111 I wrote the docs slightly different, hope that makes it clearer. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Created] (FLINK-34208) Migrate SinkV1Adapter to the new SinkV2 API

2024-01-23 Thread Peter Vary (Jira)
Peter Vary created FLINK-34208: -- Summary: Migrate SinkV1Adapter to the new SinkV2 API Key: FLINK-34208 URL: https://issues.apache.org/jira/browse/FLINK-34208 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-34145) File source connector support dynamic source parallelism inference in batch jobs

2024-01-23 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-34145: --- Assignee: xingbe > File source connector support dynamic source parallelism inference in batch >

[jira] [Assigned] (FLINK-34059) Add documentation on how to use state TTL hint

2024-01-23 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan reassigned FLINK-34059: - Assignee: Jane Chan > Add documentation on how to use state TTL hint >

[jira] [Assigned] (FLINK-34144) Update the documentation and configuration description about dynamic source parallelism inference

2024-01-23 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-34144: --- Assignee: xingbe > Update the documentation and configuration description about dynamic source >

Re: [PR] [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect, back port to 1.18 [flink]

2024-01-23 Thread via GitHub
yunfan123 commented on PR #24149: URL: https://github.com/apache/flink/pull/24149#issuecomment-1905574397 @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-33365] include filters with Lookup joins [flink-connector-jdbc]

2024-01-23 Thread via GitHub
davidradl commented on PR #79: URL: https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1905665607 > @davidradl > > > * I don't think we can have 0 key names for a lookup join. Have you a test case that would drive this ? > > There is no such restriction in

  1   2   3   >