[jira] [Commented] (FLINK-31856) Add support for Opensearch Connector REST client customization

2023-06-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731895#comment-17731895 ] Michael Hempel-Jørgensen commented on FLINK-31856: -- [~reta] we have tested the PR and

[jira] [Commented] (FLINK-32320) Same correlate can not be reused due to the different correlationId

2023-06-12 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731876#comment-17731876 ] Benchao Li commented on FLINK-32320: [~aitozi] Then you need to open dedicated Calcite issue, and

[GitHub] [flink-connector-kafka] yuxiqian opened a new pull request, #32: [FLINK-32289][docs] Fix incorrect metadata column type in examples

2023-06-12 Thread via GitHub
yuxiqian opened a new pull request, #32: URL: https://github.com/apache/flink-connector-kafka/pull/32 This PR fixes incorrect metadata column type in Kafka connector examples. ## Brief change log Changed timestamp metadata column type from TIMESTAMP to TIMESTAMP_LTZ (with

[GitHub] [flink] Myasuka commented on a diff in pull request #22767: FLIP-296: Extend watermark-related features for SQL

2023-06-12 Thread via GitHub
Myasuka commented on code in PR #22767: URL: https://github.com/apache/flink/pull/22767#discussion_r1227481717 ## docs/content.zh/docs/dev/table/concepts/time_attributes.md: ## @@ -272,6 +272,99 @@ GROUP BY TUMBLE(time_ltz, INTERVAL '10' MINUTE); ``` +

[GitHub] [flink] flinkbot commented on pull request #22768: [FLINK-32309][sql-gateway] Use independent resource manager for table environment

2023-06-12 Thread via GitHub
flinkbot commented on PR #22768: URL: https://github.com/apache/flink/pull/22768#issuecomment-1588509273 ## CI report: * f4d5c01b209db532ed82e2cd9d50941abe5dfb01 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32309) Shared classpaths and jars manager for jobs in sql gateway cause confliction

2023-06-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32309: --- Labels: pull-request-available (was: ) > Shared classpaths and jars manager for jobs in

[GitHub] [flink] FangYongs opened a new pull request, #22768: [FLINK-32309][sql-gateway] Use independent resource manager for table environment

2023-06-12 Thread via GitHub
FangYongs opened a new pull request, #22768: URL: https://github.com/apache/flink/pull/22768 ## What is the purpose of the change This PR aims to create new resource manager for table environment in sql gateway ## Brief change log - Create new resource manager

[jira] [Created] (FLINK-32321) Temporal Join job missing condition after “ON”

2023-06-12 Thread macdoor615 (Jira)
macdoor615 created FLINK-32321: -- Summary: Temporal Join job missing condition after “ON” Key: FLINK-32321 URL: https://issues.apache.org/jira/browse/FLINK-32321 Project: Flink Issue Type: Bug

[GitHub] [flink] leonardBang commented on pull request #22760: [FLINK-32289][kafka] Fix incorrect metadata column type in docs

2023-06-12 Thread via GitHub
leonardBang commented on PR #22760: URL: https://github.com/apache/flink/pull/22760#issuecomment-1588469379 @yuxiqian Could you also open a PR for https://github.com/apache/flink-connector-kafka repo as we plan to move kafka connector there from flink main repo? -- This is an automated

[GitHub] [flink] leonardBang merged pull request #22760: [FLINK-32289][kafka] Fix incorrect metadata column type in docs

2023-06-12 Thread via GitHub
leonardBang merged PR #22760: URL: https://github.com/apache/flink/pull/22760 -- 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-32320) Same correlate can not be reused due to the different correlationId

2023-06-12 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731832#comment-17731832 ] Aitozi commented on FLINK-32320: [~libenchao] Thanks for your attention. I just made a quick fix on

[jira] [Commented] (FLINK-32319) flink can't the partition of network after restart

2023-06-12 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731830#comment-17731830 ] Wencong Liu commented on FLINK-32319: - If this exception occurs, it indicates that the upstream

[jira] [Commented] (FLINK-32320) Same correlate can not be reused due to the different correlationId

2023-06-12 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731829#comment-17731829 ] Benchao Li commented on FLINK-32320: You are correct, this will miss some opportunity of reusing

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #22137: [FLINK-31233][Rest] Return 404 when task manager stdout/log files not exist.

2023-06-12 Thread via GitHub
KarmaGYZ commented on code in PR #22137: URL: https://github.com/apache/flink/pull/22137#discussion_r1227428286 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskmanager/AbstractTaskManagerFileHandlerTest.java: ## @@ -116,12 +85,11 @@ public class

[GitHub] [flink] flinkbot commented on pull request #22767: FLIP-296: Extend watermark-related features for SQL

2023-06-12 Thread via GitHub
flinkbot commented on PR #22767: URL: https://github.com/apache/flink/pull/22767#issuecomment-1588429310 ## CI report: * 26d4747481a26ae4b192b7744e48a6757ddb2391 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-connector-jdbc] WenDing-Y commented on pull request #49: [FLINK-32068] connector jdbc support clickhouse

2023-06-12 Thread via GitHub
WenDing-Y commented on PR #49: URL: https://github.com/apache/flink-connector-jdbc/pull/49#issuecomment-1588427649 @MartijnVisser the pr is ready -- 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

[GitHub] [flink] yuchengxin opened a new pull request, #22767: Feature/watermark params

2023-06-12 Thread via GitHub
yuchengxin opened a new pull request, #22767: URL: https://github.com/apache/flink/pull/22767 ## What is the purpose of the change The PR proposes to extend watermark-related features in SQL layer, these fetures have been implemented on the datastream API, but not available

[jira] [Commented] (FLINK-32319) flink can't the partition of network after restart

2023-06-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731827#comment-17731827 ] wgcn commented on FLINK-32319: -- hi~ [~Wencong Liu] thanks for your response, I will try the config, I

[jira] [Updated] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

2023-06-12 Thread Cai Liuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cai Liuyang updated FLINK-32316: Description: When we try SourceAlignment feature, we found there will be a duplicated

[jira] [Commented] (FLINK-28076) StreamFaultToleranceTestBase runs into timeout

2023-06-12 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731828#comment-17731828 ] Rui Fan commented on FLINK-28076: -

[jira] [Commented] (FLINK-32320) Same correlate can not be reused due to the different correlationId

2023-06-12 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731823#comment-17731823 ] Aitozi commented on FLINK-32320: In production, multi sink job are very common, if the table from UDTF

[jira] [Created] (FLINK-32320) Same correlate can not be reused due to the different correlationId

2023-06-12 Thread Aitozi (Jira)
Aitozi created FLINK-32320: -- Summary: Same correlate can not be reused due to the different correlationId Key: FLINK-32320 URL: https://issues.apache.org/jira/browse/FLINK-32320 Project: Flink

[jira] [Commented] (FLINK-32319) flink can't the partition of network after restart

2023-06-12 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731822#comment-17731822 ] Wencong Liu commented on FLINK-32319: - Hi [~1026688210] , maybe you could try this config

[jira] [Commented] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

2023-06-12 Thread Natea Eshetu Beshada (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731817#comment-17731817 ] Natea Eshetu Beshada commented on FLINK-32318: -- Hi [~luismacosta], I believe you need to

[jira] [Updated] (FLINK-32319) flink can't the partition of network after restart

2023-06-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn updated FLINK-32319: - Environment: centos 7. jdk 8. flink1.17.1 application mode on yarn flink configuration : ```

[jira] [Updated] (FLINK-32319) flink can't the partition of network after restart

2023-06-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn updated FLINK-32319: - Attachment: image-2023-06-13-07-14-48-958.png Component/s: Runtime / Network Affects

[jira] [Created] (FLINK-32319) flink can't the partition of network after restart

2023-06-12 Thread wgcn (Jira)
wgcn created FLINK-32319: Summary: flink can't the partition of network after restart Key: FLINK-32319 URL: https://issues.apache.org/jira/browse/FLINK-32319 Project: Flink Issue Type: Bug

[GitHub] [flink] architgyl commented on a diff in pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-06-12 Thread via GitHub
architgyl commented on code in PR #22509: URL: https://github.com/apache/flink/pull/22509#discussion_r1227304307 ## flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java: ## @@ -60,6 +60,12 @@ class YARNSessionFIFOITCase extends YarnTestBase {

[GitHub] [flink-training] ness-marichamyramachandran opened a new pull request, #62: FLK-1036 - Flink Level 1 - Module 1 Lab Exercises

2023-06-12 Thread via GitHub
ness-marichamyramachandran opened a new pull request, #62: URL: https://github.com/apache/flink-training/pull/62 RideCleansingExercise - Changes made to filter the rides only in New York City area. RidesAndFaresExercise - Below Changes have been made:

[GitHub] [flink-training] ness-marichamyramachandran closed pull request #62: FLK-1036 - Flink Level 1 - Module 1 Lab Exercises

2023-06-12 Thread via GitHub
ness-marichamyramachandran closed pull request #62: FLK-1036 - Flink Level 1 - Module 1 Lab Exercises URL: https://github.com/apache/flink-training/pull/62 -- 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] [Updated] (FLINK-31990) Use Flink Configuration to specify KDS Source configuration object

2023-06-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31990: --- Labels: pull-request-available (was: ) > Use Flink Configuration to specify KDS Source

[GitHub] [flink-connector-aws] hlteoh37 opened a new pull request, #77: [FLINK-31990][Connectors/Kinesis] Use Configuration object instead of…

2023-06-12 Thread via GitHub
hlteoh37 opened a new pull request, #77: URL: https://github.com/apache/flink-connector-aws/pull/77 … properties in KDS Source ## Purpose of the change Use Configuration object for specifying Source config instead of Properties. ## Verifying this change This

[GitHub] [flink] architgyl closed pull request #22766: Yarn acl

2023-06-12 Thread via GitHub
architgyl closed pull request #22766: Yarn acl URL: https://github.com/apache/flink/pull/22766 -- 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] architgyl opened a new pull request, #22766: Yarn acl

2023-06-12 Thread via GitHub
architgyl opened a new pull request, #22766: URL: https://github.com/apache/flink/pull/22766 ## 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] architgyl closed pull request #22765: Yarn acl

2023-06-12 Thread via GitHub
architgyl closed pull request #22765: Yarn acl URL: https://github.com/apache/flink/pull/22765 -- 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] architgyl opened a new pull request, #22765: Yarn acl

2023-06-12 Thread via GitHub
architgyl opened a new pull request, #22765: URL: https://github.com/apache/flink/pull/22765 ## 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] pvary commented on a diff in pull request #22694: [FLINK-32223][runtime][security] Add Hive delegation token support

2023-06-12 Thread via GitHub
pvary commented on code in PR #22694: URL: https://github.com/apache/flink/pull/22694#discussion_r1227217764 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/security/token/HiveDelegationTokenProvider.java: ## @@ -0,0 +1,148 @@ +/* + * Licensed to

[GitHub] [flink-connector-jdbc] MartijnVisser merged pull request #57: [BP-3.1][FLINK-30790][Connector/JDBC] Add DatabaseExtension with TableManaged or testing.

2023-06-12 Thread via GitHub
MartijnVisser merged PR #57: URL: https://github.com/apache/flink-connector-jdbc/pull/57 -- 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-connector-jdbc] snuyanzin opened a new pull request, #57: [BP-3.1][FLINK-30790][Connector/JDBC] Add DatabaseExtension with TableManaged or testing.

2023-06-12 Thread via GitHub
snuyanzin opened a new pull request, #57: URL: https://github.com/apache/flink-connector-jdbc/pull/57 This is a cherry-pick backport of https://github.com/apache/flink-connector-jdbc/pull/22 to 3.1 -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-32313) CrateDB relies on flink-shaded in flink-connector-jdbc

2023-06-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32313. -- Fix Version/s: jdbc-3.2.0 Assignee: Sergey Nuyanzin Resolution: Fixed Fixed

[GitHub] [flink-connector-jdbc] boring-cyborg[bot] commented on pull request #56: [FLINK-32313] Remove usage of flink-shaded from the code, add deprecation on checkstyle level

2023-06-12 Thread via GitHub
boring-cyborg[bot] commented on PR #56: URL: https://github.com/apache/flink-connector-jdbc/pull/56#issuecomment-1587890117 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-connector-jdbc] MartijnVisser merged pull request #56: [FLINK-32313] Remove usage of flink-shaded from the code, add deprecation on checkstyle level

2023-06-12 Thread via GitHub
MartijnVisser merged PR #56: URL: https://github.com/apache/flink-connector-jdbc/pull/56 -- 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] hanyuzheng7 commented on pull request #22717: [FLINK-31665] [table] Add ARRAY_CONCAT function

2023-06-12 Thread via GitHub
hanyuzheng7 commented on PR #22717: URL: https://github.com/apache/flink/pull/22717#issuecomment-1587886884 @snuyanzin @bvarghese1 For 2. different types and case 3.wrong(incompatible) types, if array exists null elements, I don't find a effective way to solve this problem because you

[jira] [Updated] (FLINK-31980) Implement support for EFO in new Source

2023-06-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31980: --- Labels: pull-request-available (was: ) > Implement support for EFO in new Source >

[GitHub] [flink-connector-aws] hlteoh37 opened a new pull request, #76: [FLINK-31980] Implement support for EFO in Kinesis consumer

2023-06-12 Thread via GitHub
hlteoh37 opened a new pull request, #76: URL: https://github.com/apache/flink-connector-aws/pull/76 ## Purpose of the change Implement support for EFO in the new KDS source ## Verifying this change This change added tests and can be verified as follows: - Added unit

[jira] [Commented] (FLINK-31813) Initial implementation of Kinesis Source using FLIP-27

2023-06-12 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731720#comment-17731720 ] Danny Cranmer commented on FLINK-31813: --- Merged commit

[jira] [Assigned] (FLINK-31813) Initial implementation of Kinesis Source using FLIP-27

2023-06-12 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-31813: - Assignee: Hong Liang Teoh > Initial implementation of Kinesis Source using FLIP-27 >

[jira] [Resolved] (FLINK-31813) Initial implementation of Kinesis Source using FLIP-27

2023-06-12 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-31813. --- Resolution: Done > Initial implementation of Kinesis Source using FLIP-27 >

[GitHub] [flink-connector-aws] dannycranmer merged pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-06-12 Thread via GitHub
dannycranmer merged PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49 -- 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-connector-aws] dannycranmer commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-06-12 Thread via GitHub
dannycranmer commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1227015927 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSourceBuilder.java: ## @@ -0,0 +1,92 @@ +/*

[GitHub] [flink] reswqa commented on a diff in pull request #22743: [FLINK-26515][test] Add exception handling for RetryingExecutorTest#testDiscardOnTimeout

2023-06-12 Thread via GitHub
reswqa commented on code in PR #22743: URL: https://github.com/apache/flink/pull/22743#discussion_r1227024446 ## flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/RetryingExecutorTest.java: ## @@ -118,6 +123,7 @@ public void handleFailure(Throwable

[jira] [Updated] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

2023-06-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luís Costa updated FLINK-32318: --- Description: Greetings, I'm trying to configure [Flink's Kubernetes HA

[jira] [Closed] (FLINK-32213) Add get off heap buffer in memory segment

2023-06-12 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-32213. -- Fix Version/s: 1.18.0 Resolution: Done master(1.18) via

[jira] [Updated] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

2023-06-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luís Costa updated FLINK-32318: --- Description: Greetings, I'm trying to configure [Flink's Kubernetes HA

[jira] [Updated] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

2023-06-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luís Costa updated FLINK-32318: --- Description: Greetings, I'm trying to configure [Flink's Kubernetes HA

[jira] [Updated] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

2023-06-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luís Costa updated FLINK-32318: --- Description: Greetings, I'm trying to configure [Flink's Kubernetes HA

[jira] [Created] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

2023-06-12 Thread Jira
Luís Costa created FLINK-32318: -- Summary: [flink-operator] missing s3 plugin in folder plugins Key: FLINK-32318 URL: https://issues.apache.org/jira/browse/FLINK-32318 Project: Flink Issue Type:

[jira] [Updated] (FLINK-32317) Enrich metadata in CR error field

2023-06-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32317: --- Labels: pull-request-available (was: ) > Enrich metadata in CR error field >

[GitHub] [flink-kubernetes-operator] darenwkt opened a new pull request, #620: [FLINK-32317] Enrich metadata in CR error field

2023-06-12 Thread via GitHub
darenwkt opened a new pull request, #620: URL: https://github.com/apache/flink-kubernetes-operator/pull/620 ## What is the purpose of the change CR Error field is improved in https://issues.apache.org/jira/browse/FLINK-29708. The error field is more structured

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #617: [FLINK-32271] Report RECOMMENDED_PARALLELISM as an autoscaler metric V2

2023-06-12 Thread via GitHub
morhidi commented on code in PR #617: URL: https://github.com/apache/flink-kubernetes-operator/pull/617#discussion_r1226911859 ## flink-kubernetes-operator-autoscaler/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/RecommendedParallelismTest.java: ## @@ -0,0

[GitHub] [flink-docker] daniel-packard commented on pull request #158: [ADD-SYMLINKS] Add symlinks for FLINK_VERSION to FLINK_RELEASE jars

2023-06-12 Thread via GitHub
daniel-packard commented on PR #158: URL: https://github.com/apache/flink-docker/pull/158#issuecomment-1587654571 Hey @zentol - Right now we have two proposed changes on the table: 1. add symlinks from e.g. `1.16.jar` -> `1.16.2.jar` 2. add support for pattern matching e.g.

[GitHub] [flink] hanyuzheng7 commented on pull request #22730: [FLINK-32257]-table-Add-ARRAY_MAX-function

2023-06-12 Thread via GitHub
hanyuzheng7 commented on PR #22730: URL: https://github.com/apache/flink/pull/22730#issuecomment-1587632051 @dawidwys Yes concatenates is a mistake, I have already fixed it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] dawidwys commented on a diff in pull request #22730: [FLINK-32257]-table-Add-ARRAY_MAX-function

2023-06-12 Thread via GitHub
dawidwys commented on code in PR #22730: URL: https://github.com/apache/flink/pull/22730#discussion_r1226894432 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -272,6 +281,61 @@ ANY,

[jira] [Created] (FLINK-32317) Enrich metadata in CR error field

2023-06-12 Thread Daren Wong (Jira)
Daren Wong created FLINK-32317: -- Summary: Enrich metadata in CR error field Key: FLINK-32317 URL: https://issues.apache.org/jira/browse/FLINK-32317 Project: Flink Issue Type: Improvement

[GitHub] [flink] dawidwys commented on pull request #22730: [FLINK-32257]-table-Add-ARRAY_MAX-function

2023-06-12 Thread via GitHub
dawidwys commented on PR #22730: URL: https://github.com/apache/flink/pull/22730#issuecomment-1587592181 Thank you @hanyuzheng7 for the contribution. Could you please fill in the description template correctly? It helps reviewers tremendously. You have a nice overview what your changes do,

[jira] [Closed] (FLINK-32300) Support get object for result set

2023-06-12 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li closed FLINK-32300. -- Fix Version/s: 1.18.0 Resolution: Fixed Fixed via

[GitHub] [flink] libenchao closed pull request #22757: [FLINK-32300][jdbc-driver] Support get object for result set

2023-06-12 Thread via GitHub
libenchao closed pull request #22757: [FLINK-32300][jdbc-driver] Support get object for result set URL: https://github.com/apache/flink/pull/22757 -- 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

[jira] [Comment Edited] (FLINK-32311) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement and DefaultLeaderElectionService.onGrantLeadership fell into dead lock

2023-06-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731623#comment-17731623 ] Matthias Pohl edited comment on FLINK-32311 at 6/12/23 2:10 PM: This

[jira] [Comment Edited] (FLINK-32311) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement and DefaultLeaderElectionService.onGrantLeadership fell into dead lock

2023-06-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731623#comment-17731623 ] Matthias Pohl edited comment on FLINK-32311 at 6/12/23 2:08 PM: This

[jira] [Commented] (FLINK-32311) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement and DefaultLeaderElectionService.onGrantLeadership fell into dead lock

2023-06-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731623#comment-17731623 ] Matthias Pohl commented on FLINK-32311: --- This can, indeed, happen in the new implementation (even

[GitHub] [flink] hanyuzheng7 commented on pull request #22717: [FLINK-31665] [table] Add ARRAY_CONCAT function

2023-06-12 Thread via GitHub
hanyuzheng7 commented on PR #22717: URL: https://github.com/apache/flink/pull/22717#issuecomment-1587333488 @snuyanzin for this case `SELECT array_concat(ARRAY[1], ARRAY[CAST(NULL AS INT)]); -- returns [1, 0]` other method has same problem such as array_union, I cannot solve it up to

[jira] [Updated] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

2023-06-12 Thread Cai Liuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cai Liuyang updated FLINK-32316: Description: When we try SourceAlignment feature, we found there will be a duplicated

[jira] [Updated] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

2023-06-12 Thread Cai Liuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cai Liuyang updated FLINK-32316: Description: When we try SourceAlignment feature, we found there will be a duplicated

[jira] [Commented] (FLINK-31665) Add ARRAY_CONCAT supported in SQL & Table API

2023-06-12 Thread Mara Steiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731607#comment-17731607 ] Mara Steiu commented on FLINK-31665: I personally think that ARRAY_CONCAT is most intuitive option

[jira] [Commented] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

2023-06-12 Thread Cai Liuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731608#comment-17731608 ] Cai Liuyang commented on FLINK-32316: - [~pnowojski]  please take a look? thks~ > Duplicated

[jira] [Resolved] (FLINK-32222) Cassandra Source uses DataInputDeserializer and DataOutputSerializer non public apis

2023-06-12 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot resolved FLINK-3. -- Fix Version/s: cassandra-3.2.0 Resolution: Fixed merged master: 4f1cdfa >

[jira] [Resolved] (FLINK-31806) Prod architecture tests didn't detect non-public API usage

2023-06-12 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot resolved FLINK-31806. -- Fix Version/s: 1.18.0 Resolution: Fixed merged: 28abe81 > Prod architecture

[jira] [Created] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

2023-06-12 Thread Cai Liuyang (Jira)
Cai Liuyang created FLINK-32316: --- Summary: Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover Key: FLINK-32316 URL: https://issues.apache.org/jira/browse/FLINK-32316

[jira] [Created] (FLINK-32315) Support local file upload in K8s mode

2023-06-12 Thread Paul Lin (Jira)
Paul Lin created FLINK-32315: Summary: Support local file upload in K8s mode Key: FLINK-32315 URL: https://issues.apache.org/jira/browse/FLINK-32315 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot commented on pull request #22764: [FLINK-32314][rpc] Ignore classloading errors after actorsystem shutdown

2023-06-12 Thread via GitHub
flinkbot commented on PR #22764: URL: https://github.com/apache/flink/pull/22764#issuecomment-1587277700 ## CI report: * 95de63ef5c02258d5f8fff9654daada0b49b2652 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zentol opened a new pull request, #22764: [FLINK-32314][rpc] Ignore classloading errors after actorsystem shutdown

2023-06-12 Thread via GitHub
zentol opened a new pull request, #22764: URL: https://github.com/apache/flink/pull/22764 Stray threads in akka/netty can run into classloading errors because they aren't shut down (for some reason) despite the actor system having shut down. Ignore errors in this specific situation. --

[jira] [Updated] (FLINK-32314) Ignore class-loading errors after RPC system shutdown

2023-06-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32314: --- Labels: pull-request-available (was: ) > Ignore class-loading errors after RPC system

[jira] [Created] (FLINK-32314) Ignore class-loading errors after RPC system shutdown

2023-06-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32314: Summary: Ignore class-loading errors after RPC system shutdown Key: FLINK-32314 URL: https://issues.apache.org/jira/browse/FLINK-32314 Project: Flink

[GitHub] [flink-connector-jdbc] snuyanzin opened a new pull request, #56: [FLINK-32313] Remove usage of flink-shaded from the code, add deprecation on checkstyle level

2023-06-12 Thread via GitHub
snuyanzin opened a new pull request, #56: URL: https://github.com/apache/flink-connector-jdbc/pull/56 After that any code with import of `flink-shaded` should fail at compilation on checkstyle task -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-32313) CrateDB relies on flink-shaded in flink-connector-jdbc

2023-06-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32313: --- Labels: pull-request-available (was: ) > CrateDB relies on flink-shaded in

[jira] [Closed] (FLINK-32308) RestClusterClient submit job to remote cluster

2023-06-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32308. -- Resolution: Invalid [~SpongebobZ] This request for help should be asked via the User mailing

[jira] [Assigned] (FLINK-32311) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement and DefaultLeaderElectionService.onGrantLeadership fell into dead lock

2023-06-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-32311: - Assignee: Matthias Pohl >

[jira] [Created] (FLINK-32313) CrateDB relies on flink-shaded in flink-connector-jdbc

2023-06-12 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-32313: -- Summary: CrateDB relies on flink-shaded in flink-connector-jdbc Key: FLINK-32313 URL: https://issues.apache.org/jira/browse/FLINK-32313 Project: Flink

[jira] [Commented] (FLINK-32313) CrateDB relies on flink-shaded in flink-connector-jdbc

2023-06-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731579#comment-17731579 ] Martijn Visser commented on FLINK-32313: [~matriv] This is a blocker for JDBC, can you make sure

[jira] [Commented] (FLINK-32312) SSLConnectionSocketFactory produced no output for 900 seconds

2023-06-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731578#comment-17731578 ] Sergey Nuyanzin commented on FLINK-32312: -

[jira] [Created] (FLINK-32312) SSLConnectionSocketFactory produced no output for 900 seconds

2023-06-12 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32312: --- Summary: SSLConnectionSocketFactory produced no output for 900 seconds Key: FLINK-32312 URL: https://issues.apache.org/jira/browse/FLINK-32312 Project: Flink

[jira] [Assigned] (FLINK-32299) Upload python jar when sql contains python udf jar

2023-06-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-32299: - Assignee: FangYong > Upload python jar when sql contains python udf jar >

[jira] [Assigned] (FLINK-32309) Shared classpaths and jars manager for jobs in sql gateway cause confliction

2023-06-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-32309: - Assignee: FangYong > Shared classpaths and jars manager for jobs in sql gateway cause

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

2023-06-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731575#comment-17731575 ] Sergey Nuyanzin commented on FLINK-27284: -

[jira] [Commented] (FLINK-32036) TableEnvironmentTest.test_explain is unstable on azure ci

2023-06-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731573#comment-17731573 ] Sergey Nuyanzin commented on FLINK-32036: -

[jira] [Updated] (FLINK-32049) CoordinatedSourceRescaleITCase.testDownscaling fails on AZP

2023-06-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32049: Affects Version/s: 1.18.0 > CoordinatedSourceRescaleITCase.testDownscaling fails on AZP >

[jira] [Commented] (FLINK-32049) CoordinatedSourceRescaleITCase.testDownscaling fails on AZP

2023-06-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731571#comment-17731571 ] Sergey Nuyanzin commented on FLINK-32049: - Same for testUpscaling

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2023-06-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-28440: Affects Version/s: 1.18.0 > EventTimeWindowCheckpointingITCase failed with restore >

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2023-06-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731569#comment-17731569 ] Sergey Nuyanzin commented on FLINK-28440: - Redirected to here from FLINK-30107

[jira] [Updated] (FLINK-32311) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement and DefaultLeaderElectionService.onGrantLeadership fell into dead lock

2023-06-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32311: Fix Version/s: (was: 1.18.0) >

  1   2   >