[jira] [Commented] (FLINK-26603) [Umbrella] Decouple Hive with Flink planner

2022-12-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646483#comment-17646483 ] Sergey Nuyanzin commented on FLINK-26603: - I'm playing around this area. I also noticed this

[jira] [Updated] (FLINK-30395) Refactor module name and documentation for filesystems

2022-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30395: --- Labels: pull-request-available (was: ) > Refactor module name and documentation for

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #434: [FLINK-30395] Refactor module name and documentation for filesystems

2022-12-12 Thread GitBox
JingsongLi opened a new pull request, #434: URL: https://github.com/apache/flink-table-store/pull/434 - flink-table-store-filesystem => flink-table-store-filesystems - flink-table-store-fs-oss-hadoop => flink-table-store-oss - introduce a new page for oss only -- This is an

[jira] [Updated] (FLINK-30395) Refactor module name and documentation for filesystems

2022-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30395: - Description: * flink-table-store-filesystem => flink-table-store-filesystems *

[jira] [Created] (FLINK-30395) Refactor module name and documentation for filesystems

2022-12-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-30395: Summary: Refactor module name and documentation for filesystems Key: FLINK-30395 URL: https://issues.apache.org/jira/browse/FLINK-30395 Project: Flink Issue

[jira] [Created] (FLINK-30394) [umbrella] Refactor filesystem support in table store

2022-12-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-30394: Summary: [umbrella] Refactor filesystem support in table store Key: FLINK-30394 URL: https://issues.apache.org/jira/browse/FLINK-30394 Project: Flink Issue

[GitHub] [flink-connector-kafka] mas-chen commented on pull request #1: [FLINK-30052][Connectors/Kafka] Move existing Kafka connector code from Flink repo to dedicated Kafka repo

2022-12-12 Thread GitBox
mas-chen commented on PR #1: URL: https://github.com/apache/flink-connector-kafka/pull/1#issuecomment-1347881826 @zentol It's failing after I un-ignored the e2e test. There's an issue related with initializing the Docker image--I'm actively looking at it -- This is an automated message

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #433: [FLINK-30210] Refactor StoreCompactOperator to accept records containing partitions and buckets in Table Store

2022-12-12 Thread GitBox
tsreaper commented on code in PR #433: URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046746710 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreCompactOperator.java: ## @@ -18,99 +18,70 @@ package

[jira] [Comment Edited] (FLINK-30386) Column constraint lacks primary key not enforced check

2022-12-12 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646407#comment-17646407 ] Jane Chan edited comment on FLINK-30386 at 12/13/22 7:23 AM: - Would you help

[jira] [Updated] (FLINK-27284) KafkaSinkITCase$IntegrationTests.testScaleUp failed on azures due to failed to create topic

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-27284: --- Affects Version/s: 1.15.0 > KafkaSinkITCase$IntegrationTests.testScaleUp failed on azures due to

[jira] [Commented] (FLINK-27284) KafkaSinkITCase$IntegrationTests.testScaleUp failed on azures due to failed to create topic

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646472#comment-17646472 ] Leonard Xu commented on FLINK-27284:

[jira] [Comment Edited] (FLINK-27284) KafkaSinkITCase$IntegrationTests.testScaleUp failed on azures due to failed to create topic

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646472#comment-17646472 ] Leonard Xu edited comment on FLINK-27284 at 12/13/22 7:21 AM: -- 1.15:

[jira] [Commented] (FLINK-29859) TPC-DS end-to-end test with adaptive batch scheduler failed due to oo non-empty .out files.

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646471#comment-17646471 ] Leonard Xu commented on FLINK-29859:

[jira] [Created] (FLINK-30393) PulsarSourceUnorderedE2ECase.testScaleDown failed with TimeoutException

2022-12-12 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-30393: - Summary: PulsarSourceUnorderedE2ECase.testScaleDown failed with TimeoutException Key: FLINK-30393 URL: https://issues.apache.org/jira/browse/FLINK-30393 Project:

[jira] [Commented] (FLINK-29755) PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing TaskManagers

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646470#comment-17646470 ] Leonard Xu commented on FLINK-29755:

[GitHub] [flink] flinkbot commented on pull request #21499: [FLINK-30370][runtime][security] Move existing delegation token framework authentication to providers

2022-12-12 Thread GitBox
flinkbot commented on PR #21499: URL: https://github.com/apache/flink/pull/21499#issuecomment-1347844200 ## CI report: * 05ff3323e5988e809d1270ecb691e04365b0bc4b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30370) Move existing delegation token framework authentication to providers

2022-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30370: --- Labels: pull-request-available (was: ) > Move existing delegation token framework

[GitHub] [flink] gaborgsomogyi commented on pull request #21499: [FLINK-30370][runtime][security] Move existing delegation token framework authentication to providers

2022-12-12 Thread GitBox
gaborgsomogyi commented on PR #21499: URL: https://github.com/apache/flink/pull/21499#issuecomment-1347836663 cc @mbalassi -- 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.

[GitHub] [flink] gaborgsomogyi opened a new pull request, #21499: [FLINK-30370][runtime][security] Move existing delegation token framework authentication to providers

2022-12-12 Thread GitBox
gaborgsomogyi opened a new pull request, #21499: URL: https://github.com/apache/flink/pull/21499 ## What is the purpose of the change In order to make a generic delegation token manager all authentication specific things must be extracted. This is such a step. In this PR I've moved

[jira] [Updated] (FLINK-30381) Bump minikube kubernetes version for operator

2022-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30381: --- Labels: pull-request-available (was: ) > Bump minikube kubernetes version for operator >

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #483: [FLINK-30381] Bump minikube kubernetes version for operator

2022-12-12 Thread GitBox
gaborgsomogyi commented on PR #483: URL: https://github.com/apache/flink-kubernetes-operator/pull/483#issuecomment-1347835044 cc @mbalassi @gyfora -- 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

[GitHub] [flink-kubernetes-operator] gaborgsomogyi opened a new pull request, #483: [FLINK-30381] Bump minikube kubernetes version for operator

2022-12-12 Thread GitBox
gaborgsomogyi opened a new pull request, #483: URL: https://github.com/apache/flink-kubernetes-operator/pull/483 ## What is the purpose of the change The operator uses a quite old version of kubernetes for minikube. The latest supported version is v1.25.3. I've bumped it. ##

[GitHub] [flink] 1996fanrui commented on pull request #21447: [FLINK-30185] Provide the flame graph to the subtask level

2022-12-12 Thread GitBox
1996fanrui commented on PR #21447: URL: https://github.com/apache/flink/pull/21447#issuecomment-1347816498 Hi @xintongsong , the PR is ready, and I have updated some pictures here. Please help take a look in your free time, thanks~ I will update the doc after you think it's ok. --

[GitHub] [flink] 1996fanrui commented on pull request #21447: [FLINK-30185] Provide the flame graph to the subtask level

2022-12-12 Thread GitBox
1996fanrui commented on PR #21447: URL: https://github.com/apache/flink/pull/21447#issuecomment-1347814792 The flame graph with this PR: FlameGraph of all subtasks: https://user-images.githubusercontent.com/38427477/207243774-9fc3ff2d-5c39-4643-81e4-b9387367d6fd.png;>

[GitHub] [flink-kubernetes-operator] swathic95 commented on a diff in pull request #481: [FLINK-30361] Cluster deleted and created back while updating replicas

2022-12-12 Thread GitBox
swathic95 commented on code in PR #481: URL: https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1046639775 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/SessionReconciler.java: ## @@ -96,6 +96,19 @@

[GitHub] [flink-kubernetes-operator] swathic95 commented on a diff in pull request #481: [FLINK-30361] Cluster deleted and created back while updating replicas

2022-12-12 Thread GitBox
swathic95 commented on code in PR #481: URL: https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1046706450 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java: ## @@ -171,11 +170,6 @@

[GitHub] [flink] huwh commented on pull request #21496: [FLINK-29869][ResourceManager] make ResourceAllocator declarative.

2022-12-12 Thread GitBox
huwh commented on PR #21496: URL: https://github.com/apache/flink/pull/21496#issuecomment-1347807741 @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. To

[GitHub] [flink] huwh commented on pull request #21496: [FLINK-29869][ResourceManager] make ResourceAllocator declarative.

2022-12-12 Thread GitBox
huwh commented on PR #21496: URL: https://github.com/apache/flink/pull/21496#issuecomment-1347802296 @xintongsong Could you please help review this PR in your free time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot commented on pull request #21498: [FLINK-30392] Replace default thread dump depth to 24

2022-12-12 Thread GitBox
flinkbot commented on PR #21498: URL: https://github.com/apache/flink/pull/21498#issuecomment-1347801647 ## CI report: * 42ea3e7ac469f3f133cb3672953e675286193a9d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30392) Increase the default value of cluster.thread-dump.stacktrace-max-depth

2022-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30392: --- Labels: pull-request-available (was: ) > Increase the default value of

[GitHub] [flink] yuchen-ecnu opened a new pull request, #21498: [FLINK-30392] Replace default thread dump depth to 24

2022-12-12 Thread GitBox
yuchen-ecnu opened a new pull request, #21498: URL: https://github.com/apache/flink/pull/21498 ## What is the purpose of the change Currently, the thread dump function still have the default stack-trace depth as 8, which is the same as before. However, the default value is really too

[GitHub] [flink] mattfysh commented on pull request #21254: Update docker.md

2022-12-12 Thread GitBox
mattfysh commented on PR #21254: URL: https://github.com/apache/flink/pull/21254#issuecomment-1347782454 Is there a desire within the Flink team to ensure that PyFlink achieves similar uptake and robustness as PySpark? -- This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-30253) Introduce io executor for standalone checkpoint store

2022-12-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-30253. Resolution: Invalid [~masteryhx] Thanks for your information, this ticket has been outdated. > Introduce

[GitHub] [flink] flinkbot commented on pull request #21497: [FLINK-30377][table-planner] applySinkProvider use ClientWrapperClassLoader while extracting Type from KeyedStream

2022-12-12 Thread GitBox
flinkbot commented on PR #21497: URL: https://github.com/apache/flink/pull/21497#issuecomment-1347775653 ## CI report: * e4b1f9b8078d9904f2b92f55de472a4fe6089d62 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #433: [FLINK-30210] Refactor StoreCompactOperator to accept records containing partitions and buckets in Table Store

2022-12-12 Thread GitBox
JingsongLi commented on code in PR #433: URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046677047 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWriteImpl.java: ## @@ -0,0 +1,101 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream

2022-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30377: --- Labels: pull-request-available (was: ) > CommonExecSink does not use

[GitHub] [flink] Samrat002 opened a new pull request, #21497: [FLINK-30377][table-planner] applySinkProvider use ClientWrapperClassLoader while extracting Type from KeyedStream

2022-12-12 Thread GitBox
Samrat002 opened a new pull request, #21497: URL: https://github.com/apache/flink/pull/21497 ## 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

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #433: [FLINK-30210] Refactor StoreCompactOperator to accept records containing partitions and buckets in Table Store

2022-12-12 Thread GitBox
JingsongLi commented on code in PR #433: URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046674425 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreCompactOperator.java: ## @@ -18,99 +18,70 @@ package

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #433: [FLINK-30210] Refactor StoreCompactOperator to accept records containing partitions and buckets in Table Store

2022-12-12 Thread GitBox
JingsongLi commented on code in PR #433: URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046673855 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreCompactOperator.java: ## @@ -18,99 +18,70 @@ package

[GitHub] [flink] KarlManong commented on pull request #20937: [FLINK-29478][flink-connector/hive] Flink connector hive upgrade to 3.1.3

2022-12-12 Thread GitBox
KarlManong commented on PR #20937: URL: https://github.com/apache/flink/pull/20937#issuecomment-1347767412 @Samrat002 will this patch port to 1.15, I see https://issues.apache.org/jira/browse/FLINK-28729 reported -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] Myasuka commented on a diff in pull request #21485: [FLINK-29997] Link to the taskmanager page in the expired sub-task of…

2022-12-12 Thread GitBox
Myasuka commented on code in PR #21485: URL: https://github.com/apache/flink/pull/21485#discussion_r1046670197 ## flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/subtask/job-checkpoints-subtask.component.html: ## @@ -181,7 +186,19 @@ {{

[jira] [Resolved] (FLINK-29998) Make the backpressure tab could be sort by the busy percent

2022-12-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-29998. -- Resolution: Fixed merged in master: b6c5534efc8a4b59c3f0993777aa8119af205f0c > Make the backpressure

[GitHub] [flink] Myasuka merged pull request #21466: [FLINK-29998] Make the backpressure tab could be sort by the busy per…

2022-12-12 Thread GitBox
Myasuka merged PR #21466: URL: https://github.com/apache/flink/pull/21466 -- 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] [Assigned] (FLINK-30392) Increase the default value of cluster.thread-dump.stacktrace-max-depth

2022-12-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-30392: Assignee: Yu Chen > Increase the default value of cluster.thread-dump.stacktrace-max-depth >

[jira] [Created] (FLINK-30392) Increase the default value of cluster.thread-dump.stacktrace-max-depth

2022-12-12 Thread Yun Tang (Jira)
Yun Tang created FLINK-30392: Summary: Increase the default value of cluster.thread-dump.stacktrace-max-depth Key: FLINK-30392 URL: https://issues.apache.org/jira/browse/FLINK-30392 Project: Flink

[jira] [Closed] (FLINK-30367) Enrich the thread dump info with deeper stack

2022-12-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-30367. Resolution: Duplicate > Enrich the thread dump info with deeper stack >

[jira] [Commented] (FLINK-30367) Enrich the thread dump info with deeper stack

2022-12-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646443#comment-17646443 ] Yun Tang commented on FLINK-30367: -- [~pvary] Thanks for the information, I did not notice this change

[jira] [Closed] (FLINK-30318) sql-client failed to load jar passed with -j args in flink 1.16.0

2022-12-12 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb closed FLINK-30318. -- Resolution: Invalid > sql-client failed to load jar passed with -j args in flink 1.16.0 >

[jira] [Updated] (FLINK-30391) show jars command doesn't list client wrapper classloader loaded jars

2022-12-12 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-30391: --- Description: passing custom jars for sql-client using -j and -l doesn't gets listed in `show jars`

[jira] [Closed] (FLINK-29419) HybridShuffleITCase.testHybridFullExchangesRestart hangs

2022-12-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29419. Resolution: Fixed > HybridShuffleITCase.testHybridFullExchangesRestart hangs >

[jira] [Commented] (FLINK-29419) HybridShuffleITCase.testHybridFullExchangesRestart hangs

2022-12-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646422#comment-17646422 ] Xintong Song commented on FLINK-29419: -- Both FLINK-29298 and FLINK-30189 have been fixed.

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #433: [FLINK-30210] Refactor StoreCompactOperator to accept records containing partitions and buckets in Table Store

2022-12-12 Thread GitBox
JingsongLi commented on code in PR #433: URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046652886 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWrite.java: ## @@ -0,0 +1,53 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-29419) HybridShuffleITCase.testHybridFullExchangesRestart hangs

2022-12-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29419: - Fix Version/s: 1.17.0 1.16.1 >

[jira] [Closed] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-12-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29923. Fix Version/s: 1.17.0 1.16.1 Resolution: Fixed Should have been fixed

[jira] [Closed] (FLINK-29298) LocalBufferPool request buffer from NetworkBufferPool hanging

2022-12-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29298. Fix Version/s: 1.16.1 Resolution: Fixed - master (1.17):

[GitHub] [flink] xintongsong closed pull request #20924: [FLINK-29298] LocalBufferPool request buffer from NetworkBufferPool hanging.

2022-12-12 Thread GitBox
xintongsong closed pull request #20924: [FLINK-29298] LocalBufferPool request buffer from NetworkBufferPool hanging. URL: https://github.com/apache/flink/pull/20924 -- 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-kubernetes-operator] swathic95 commented on a diff in pull request #481: [FLINK-30361] Cluster deleted and created back while updating replicas

2022-12-12 Thread GitBox
swathic95 commented on code in PR #481: URL: https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1046639775 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/SessionReconciler.java: ## @@ -96,6 +96,19 @@

[jira] [Comment Edited] (FLINK-30318) sql-client failed to load jar passed with -j args in flink 1.16.0

2022-12-12 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646412#comment-17646412 ] Samrat Deb edited comment on FLINK-30318 at 12/13/22 4:05 AM: -- Thank you

[jira] [Comment Edited] (FLINK-30318) sql-client failed to load jar passed with -j args in flink 1.16.0

2022-12-12 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646412#comment-17646412 ] Samrat Deb edited comment on FLINK-30318 at 12/13/22 4:04 AM: -- Thank you

[jira] [Created] (FLINK-30391) show jars command doesn't list client wrapper classloader loaded jars

2022-12-12 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-30391: -- Summary: show jars command doesn't list client wrapper classloader loaded jars Key: FLINK-30391 URL: https://issues.apache.org/jira/browse/FLINK-30391 Project: Flink

[jira] [Commented] (FLINK-30318) sql-client failed to load jar passed with -j args in flink 1.16.0

2022-12-12 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646412#comment-17646412 ] Samrat Deb commented on FLINK-30318: Thank you [~luoyuxia] , for spending time and looking at it . 

[jira] [Closed] (FLINK-30373) Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30373. Resolution: Fixed master: 3e47657054e75d714cd941f502a899e5059cffac > Flink-table-runtime free

[GitHub] [flink-table-store] JingsongLi merged pull request #432: [FLINK-30373] Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread GitBox
JingsongLi merged PR #432: URL: https://github.com/apache/flink-table-store/pull/432 -- 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-30386) Column constraint lacks primary key not enforced check

2022-12-12 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646407#comment-17646407 ] Jane Chan commented on FLINK-30386: --- Would you help verify this issue, is it a bug or by design? cc

[jira] [Closed] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-12-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29461. Fix Version/s: 1.17.0 1.16.1 Resolution: Fixed Merged into master via

[GitHub] [flink] HuangXingBo closed pull request #21491: [FLINK-29461][python] Make the test_process_function more stable

2022-12-12 Thread GitBox
HuangXingBo closed pull request #21491: [FLINK-29461][python] Make the test_process_function more stable URL: https://github.com/apache/flink/pull/21491 -- 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

[GitHub] [flink] flinkbot commented on pull request #21496: [FLINK-29869][ResourceManager] make ResourceAllocator declarative.

2022-12-12 Thread GitBox
flinkbot commented on PR #21496: URL: https://github.com/apache/flink/pull/21496#issuecomment-1347680384 ## CI report: * 04536f0f108d0fd0e16257aa94cbdb272420f10e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-ml] zhipeng93 merged pull request #190: [hotfix] Improve nightly build Github actions

2022-12-12 Thread GitBox
zhipeng93 merged PR #190: URL: https://github.com/apache/flink-ml/pull/190 -- 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:

[GitHub] [flink-ml] zhipeng93 commented on pull request #190: [hotfix] Improve nightly build Github actions

2022-12-12 Thread GitBox
zhipeng93 commented on PR #190: URL: https://github.com/apache/flink-ml/pull/190#issuecomment-1347676182 Thanks for the PR. 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

[jira] [Updated] (FLINK-29869) make ResourceActions declarative

2022-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29869: --- Labels: pull-request-available (was: ) > make ResourceActions declarative >

[GitHub] [flink] huwh opened a new pull request, #21496: [FLINK-29869][ResourceManager] make ResourceAllocator declarative.

2022-12-12 Thread GitBox
huwh opened a new pull request, #21496: URL: https://github.com/apache/flink/pull/21496 ## What is the purpose of the change This pull request makes ResourceAllocator declarative in order to reduce the coupling between the SlotManager and the ResourceManager ## Brief

[jira] [Commented] (FLINK-30318) sql-client failed to load jar passed with -j args in flink 1.16.0

2022-12-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646402#comment-17646402 ] luoyuxia commented on FLINK-30318: -- [~samrat007] Hi, thanks for investigation. To me, show jars don't

[GitHub] [flink] yuzelin commented on a diff in pull request #21187: [FLINK-27837][sql-gateway] Support statement set in the SQL Gateway

2022-12-12 Thread GitBox
yuzelin commented on code in PR #21187: URL: https://github.com/apache/flink/pull/21187#discussion_r1046601074 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/context/SessionContextTest.java: ## @@ -133,6 +139,70 @@ public void

[GitHub] [flink-table-store] zjureel commented on pull request #432: [FLINK-30373] Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread GitBox
zjureel commented on PR #432: URL: https://github.com/apache/flink-table-store/pull/432#issuecomment-1347661426 > > Hi @JingsongLi Left one minor comment > > In addition, I found that `flink-table-store-codegen` module still depends on `flink-table-runtime` in `pom.xml`, is it OK? >

[GitHub] [flink] yuzelin commented on a diff in pull request #21187: [FLINK-27837][sql-gateway] Support statement set in the SQL Gateway

2022-12-12 Thread GitBox
yuzelin commented on code in PR #21187: URL: https://github.com/apache/flink/pull/21187#discussion_r1046600712 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java: ## @@ -405,4 +444,22 @@ private Set

[GitHub] [flink-ml] lindong28 merged pull request #171: [FLINK-29911] Improve performance of AgglomerativeClustering

2022-12-12 Thread GitBox
lindong28 merged PR #171: URL: https://github.com/apache/flink-ml/pull/171 -- 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:

[GitHub] [flink-ml] lindong28 commented on pull request #171: [FLINK-29911] Improve performance of AgglomerativeClustering

2022-12-12 Thread GitBox
lindong28 commented on PR #171: URL: https://github.com/apache/flink-ml/pull/171#issuecomment-1347660877 Thanks for the PR! 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] yuzelin commented on a diff in pull request #21187: [FLINK-27837][sql-gateway] Support statement set in the SQL Gateway

2022-12-12 Thread GitBox
yuzelin commented on code in PR #21187: URL: https://github.com/apache/flink/pull/21187#discussion_r1046600266 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java: ## @@ -144,19 +145,29 @@ public ResultFetcher

[GitHub] [flink] yuzelin commented on a diff in pull request #21187: [FLINK-27837][sql-gateway] Support statement set in the SQL Gateway

2022-12-12 Thread GitBox
yuzelin commented on code in PR #21187: URL: https://github.com/apache/flink/pull/21187#discussion_r1046600050 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java: ## @@ -128,6 +137,26 @@ public SessionState

[GitHub] [flink] yuzelin commented on a diff in pull request #21187: [FLINK-27837][sql-gateway] Support statement set in the SQL Gateway

2022-12-12 Thread GitBox
yuzelin commented on code in PR #21187: URL: https://github.com/apache/flink/pull/21187#discussion_r1046597242 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java: ## @@ -128,6 +137,26 @@ public SessionState

[jira] [Created] (FLINK-30390) Ensure that no compaction is in progress before closing the writer

2022-12-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-30390: Summary: Ensure that no compaction is in progress before closing the writer Key: FLINK-30390 URL: https://issues.apache.org/jira/browse/FLINK-30390 Project: Flink

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #189: [FLINK-30348] Refine Transformer for RandomSplitter

2022-12-12 Thread GitBox
yunfengzhou-hub commented on code in PR #189: URL: https://github.com/apache/flink-ml/pull/189#discussion_r1046592801 ## docs/content/docs/operators/feature/randomsplitter.md: ## @@ -34,6 +34,7 @@ An AlgoOperator which splits a table into N tables according to the given weight

[jira] [Comment Edited] (FLINK-30386) Column constraint lacks primary key not enforced check

2022-12-12 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646395#comment-17646395 ] Jane Chan edited comment on FLINK-30386 at 12/13/22 2:18 AM: - Re

[jira] [Commented] (FLINK-30386) Column constraint lacks primary key not enforced check

2022-12-12 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646395#comment-17646395 ] Jane Chan commented on FLINK-30386: --- Re [~dwysakowicz] . The `NOT ENFORCED` check only performs on the

[GitHub] [flink] swuferhong commented on pull request #21490: [FLINK-30368][table-planner] Fix calcite method RelMdUtil$numDistinctVals() wrongly return zero if the method input domainSize much larger

2022-12-12 Thread GitBox
swuferhong commented on PR #21490: URL: https://github.com/apache/flink/pull/21490#issuecomment-1347641325 Caicite jira link: https://issues.apache.org/jira/browse/CALCITE-5431 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-30389) Add retry to read hints

2022-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30389: - Description: For the oss (object store) filesystem. When writing hint file, delete it first

[jira] [Created] (FLINK-30389) Add retry to read hints

2022-12-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-30389: Summary: Add retry to read hints Key: FLINK-30389 URL: https://issues.apache.org/jira/browse/FLINK-30389 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

2022-12-12 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-30371: - Description: When writing to the target table fails for some reason, for example, the target table

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

2022-12-12 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-30371: - Description: When writing to the target table fails for some reason, for example, the target table

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

2022-12-12 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-30371: - Description: When writing to the target table fails for some reason, for example, the target table

[GitHub] [flink-table-store] JingsongLi commented on pull request #432: [FLINK-30373] Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread GitBox
JingsongLi commented on PR #432: URL: https://github.com/apache/flink-table-store/pull/432#issuecomment-1347634926 > Hi @JingsongLi Left one minor comment > > In addition, I found that `flink-table-store-codegen` module still depends on `flink-table-runtime` in `pom.xml`, is it OK?

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #432: [FLINK-30373] Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread GitBox
JingsongLi commented on code in PR #432: URL: https://github.com/apache/flink-table-store/pull/432#discussion_r1046583371 ## flink-table-store-common/src/main/java/org/apache/flink/table/store/codegen/Projection.java: ## @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-30360) A null pointer exception is thrown when data is written to the HBase table using the specified column name

2022-12-12 Thread Jichao Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646391#comment-17646391 ] Jichao Wang commented on FLINK-30360: - cc [~jark] , Can you help me confirm if this is a problem? >

[jira] [Assigned] (FLINK-29655) Split Flink CRD from flink-kubernates-operator module

2022-12-12 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi reassigned FLINK-29655: - Assignee: Márton Balassi (was: Zhenqiu Huang) > Split Flink CRD from

[jira] [Assigned] (FLINK-29632) Support nodeSelector in helm template for flink operator deployment

2022-12-12 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi reassigned FLINK-29632: - Assignee: Jeesmon Jacob > Support nodeSelector in helm template for flink operator

[jira] [Assigned] (FLINK-29853) Older jackson-databind found in flink-kubernetes-operator-1.2.0-shaded.jar

2022-12-12 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi reassigned FLINK-29853: - Assignee: James Busche > Older jackson-databind found in

[GitHub] [flink-table-store] zjureel commented on pull request #432: [FLINK-30373] Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread GitBox
zjureel commented on PR #432: URL: https://github.com/apache/flink-table-store/pull/432#issuecomment-1347626712 Hi @JingsongLi Left one minor comment In addition, I found that `flink-table-store-codegen` module still depends on `flink-table-runtime` in `pom.xml`, is it OK? --

[jira] [Assigned] (FLINK-29794) Flink Operator Need to Include Cause for Exceptions If Possible

2022-12-12 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi reassigned FLINK-29794: - Assignee: Zhou Jiang > Flink Operator Need to Include Cause for Exceptions If Possible

[jira] [Assigned] (FLINK-29744) Throw DeploymentFailedException on ImagePullBackOff

2022-12-12 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi reassigned FLINK-29744: - Assignee: Matyas Orhidi > Throw DeploymentFailedException on ImagePullBackOff >

[jira] [Assigned] (FLINK-27852) Contribute k8s operator to OperatorHub

2022-12-12 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi reassigned FLINK-27852: - Assignee: Ted Chang (was: James Busche) > Contribute k8s operator to OperatorHub >

  1   2   3   4   >