Re: [PR] [FLINK-35167][cdc-connector] Introduce MaxCompute pipeline DataSink [flink-cdc]

2024-11-05 Thread via GitHub
lvyanquan commented on code in PR #3254: URL: https://github.com/apache/flink-cdc/pull/3254#discussion_r1829218514 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SchemaEvolutionUti

Re: [PR] [FLINK-35167][cdc-connector] Introduce MaxCompute pipeline DataSink [flink-cdc]

2024-11-05 Thread via GitHub
lvyanquan commented on code in PR #3254: URL: https://github.com/apache/flink-cdc/pull/3254#discussion_r1829218514 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SchemaEvolutionUti

Re: [PR] [FLINK-23595][formats / json] JSON format support deserialize non-numeric numbe fields [flink]

2024-11-05 Thread via GitHub
loyispa closed pull request #16813: [FLINK-23595][formats / json] JSON format support deserialize non-numeric numbe fields URL: https://github.com/apache/flink/pull/16813 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Commented] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-11-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895568#comment-17895568 ] Matthias Pohl commented on FLINK-36451: --- Thanks for sharing, [~xiechenling]. I wil

Re: [PR] [hotfix] [docs] Add lead()/lag() Table API agg functions to docs [flink]

2024-11-05 Thread via GitHub
fhueske merged PR #25608: URL: https://github.com/apache/flink/pull/25608 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

[jira] [Closed] (FLINK-36002) Add CompiledPlan annotations to BatchExecMatch

2024-11-05 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-36002. Resolution: Implemented Implemented in 37642307128a83cdc83630bc286e2936decf7426 > Add Com

Re: [PR] [FLINK-35136] Bump connector version to 4.0, adapt CI workflows [flink-connector-hbase]

2024-11-05 Thread via GitHub
JuliaBogdan commented on PR #46: URL: https://github.com/apache/flink-connector-hbase/pull/46#issuecomment-2456808836 > > Great to see the PR merged, thanks for moving it forward @ferenc-csaky ! How does the release process and the timeline look? Is there anything I can help with to make i

[jira] [Assigned] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-11-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-36451: - Assignee: Matthias Pohl > Kubernetes Application JobManager Potential Deadlock and Task

Re: [PR] [FLINK-33137][Connectors/Prometheus] Prometheus connector docs [flink-connector-prometheus]

2024-11-05 Thread via GitHub
hlteoh37 commented on PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3#issuecomment-2457230128 @nicusX could we add `[FLINK-33137][Connectors/Prometheus][docs]` to the commit ID? -- This is an automated message from the Apache Git Service. To respond to the message

[jira] [Comment Edited] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs

2024-11-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895628#comment-17895628 ] Piotr Nowojski edited comment on FLINK-36099 at 11/5/24 2:19 PM: -

[jira] [Updated] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL

2024-11-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36662: Description: Currently, for the following case: {code:java} val groupingSetsQuery = """ |SELECT |

[jira] [Updated] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL

2024-11-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36662: Description: Currently, for the following case: {code:java} val groupingSetsQuery = """ |SELECT |

[jira] [Created] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL

2024-11-05 Thread lincoln lee (Jira)
lincoln lee created FLINK-36662: --- Summary: Incorrect constant pull up when group keys in aggregate are NULL Key: FLINK-36662 URL: https://issues.apache.org/jira/browse/FLINK-36662 Project: Flink

[PR] [FLINK-35780][state] Support state ttl migration [flink]

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

Re: [PR] [FLINK-35780][state] Support state ttl migration [flink]

2024-11-05 Thread via GitHub
xiangyuf commented on PR #25611: URL: https://github.com/apache/flink/pull/25611#issuecomment-2457579637 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Updated] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL

2024-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36662: --- Labels: pull-request-available (was: ) > Incorrect constant pull up when group keys in aggr

Re: [PR] [FLINK-36662][table-planner] Port CALCITE-6317 to fix the incorrectly constant pullup when group keys in aggregate are NULL [flink]

2024-11-05 Thread via GitHub
flinkbot commented on PR #25612: URL: https://github.com/apache/flink/pull/25612#issuecomment-2457590308 ## CI report: * 6ae95ef131f97250ebe7b3cb0cdd98d588544f97 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35780][state] Support state ttl migration [flink]

2024-11-05 Thread via GitHub
flinkbot commented on PR #25611: URL: https://github.com/apache/flink/pull/25611#issuecomment-2457589698 ## CI report: * d35824f9401420cb34bccff562a1b32a222fbff4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-36662][table-planner] Port CALCITE-6317 to fix the incorrectly constant pullup when group keys in aggregate are NULL [flink]

2024-11-05 Thread via GitHub
lincoln-lil opened a new pull request, #25612: URL: https://github.com/apache/flink/pull/25612 ## What is the purpose of the change This pr port the bugfix of CALCITE-6317 to fix the incorrectly constant pullup when group keys in aggregate are NULL Before upgraded corresponding calcite

Re: [PR] [FLINK-35332][yarn] Removed setting rest.address to the actual IP add… [flink]

2024-11-05 Thread via GitHub
ferenc-csaky commented on PR #24775: URL: https://github.com/apache/flink/pull/24775#issuecomment-2457582149 @paul8263 pls. rebase your PR against the latest `master` and force-push again. The error that failed the CI is already addressed. -- This is an automated message from the Apache G

Re: [PR] [FLINK-36662][table-planner] Port CALCITE-6317 to fix the incorrectly constant pullup when group keys in aggregate are NULL [flink]

2024-11-05 Thread via GitHub
snuyanzin commented on code in PR #25612: URL: https://github.com/apache/flink/pull/25612#discussion_r1829639312 ## flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/metadata/RelMdPredicates.java: ## @@ -0,0 +1,1001 @@ +/* + * Licensed to the Apache Software F

[jira] [Resolved] (FLINK-33142) Prometheus Sink Connector - Update Documentation

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33142. - Resolution: Fixed {color:#FF} {color}merged commit [{{08dd161}}|https://github.com/

Re: [PR] [FLINK-33137][Connectors/Prometheus] Prometheus connector docs [flink-connector-prometheus]

2024-11-05 Thread via GitHub
hlteoh37 merged PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr.

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
jnh5y commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829644347 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java: ## @@ -50,74 +67,43 @@ void testUpsertInto() {

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
jnh5y commented on PR #25316: URL: https://github.com/apache/flink/pull/25316#issuecomment-2457624570 Would it make sense to add a test case to something like `TableSinkITCase` to validate things end-to-end and also prevent regressions? -- This is an automated message from the Apache Git

[PR] [hotfix] [docs] Add lead()/lag() Table API agg functions to docs [flink]

2024-11-05 Thread via GitHub
fhueske opened a new pull request, #25608: URL: https://github.com/apache/flink/pull/25608 ## What is the purpose of the change Update the docs to include the Table API aggregation functions `lead()` and `lag()` (added with #25582) ## Brief change log Adds syntax for

Re: [PR] [hotfix] [docs] Add lead()/lag() Table API agg functions to docs [flink]

2024-11-05 Thread via GitHub
flinkbot commented on PR #25608: URL: https://github.com/apache/flink/pull/25608#issuecomment-2456574946 ## CI report: * cb22534b7d438da4d707b9bfc465e0ce34c99934 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [hotfix] Replace System.out.println with logger for better log management [flink-connector-gcp-pubsub]

2024-11-05 Thread via GitHub
boring-cyborg[bot] commented on PR #31: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/31#issuecomment-2456467184 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 lo

Re: [PR] [FLINK-36592][state/forst] Support file cache for ForStStateBackend [flink]

2024-11-05 Thread via GitHub
fredia commented on code in PR #25561: URL: https://github.com/apache/flink/pull/25561#discussion_r1828883909 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java: ## @@ -75,7 +111,22 @@ public ForStFlinkFileSys

[jira] [Resolved] (FLINK-36077) Implement Table API support for PubSubSink V2

2024-11-05 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-36077. - Resolution: Fixed Merged as [303f4dbe1817f57646caaba377d35742859dec65|https://github.co

Re: [PR] [FLINK-33137][Connectors/Prometheus] Prometheus connector docs [flink-connector-prometheus]

2024-11-05 Thread via GitHub
hlteoh37 commented on code in PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3#discussion_r1829043534 ## docs/content/docs/connectors/datastream/prometheus.md: ## @@ -0,0 +1,473 @@ +--- +title: Prometheus +weight: 5 +type: docs +aliases: + - /dev/connect

Re: [PR] [FLINK-36288][Connectors/Prometheus]Set up archunit tests [flink-connector-prometheus]

2024-11-05 Thread via GitHub
hlteoh37 merged PR #12: URL: https://github.com/apache/flink-connector-prometheus/pull/12 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubsc

[jira] [Resolved] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33137. - Resolution: Fixed > FLIP-312: Prometheus Sink Connector > --

Re: [PR] [FLINK-36099][task] Log jobID in TaskExecutor#failTask [flink]

2024-11-05 Thread via GitHub
flinkbot commented on PR #25609: URL: https://github.com/apache/flink/pull/25609#issuecomment-2456713844 ## CI report: * 5af77a469ec2edbdf98c2cf8c89b2ec5d873c000 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35136] Bump connector version to 4.0, adapt CI workflows [flink-connector-hbase]

2024-11-05 Thread via GitHub
ferenc-csaky commented on PR #46: URL: https://github.com/apache/flink-connector-hbase/pull/46#issuecomment-2456749670 > Great to see the PR merged, thanks for moving it forward @ferenc-csaky ! How does the release process and the timeline look? Is there anything I can help with to make it

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails

2024-11-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895627#comment-17895627 ] Piotr Nowojski commented on FLINK-18476: https://dev.azure.com/apache-flink/apac

[jira] [Closed] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs

2024-11-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36099. -- Fix Version/s: 2.0.0 Resolution: Fixed merged commit 0b64b57 into apache:master > JobI

Re: [PR] [FLINK-36099][task] Log jobID in TaskExecutor#failTask [flink]

2024-11-05 Thread via GitHub
pnowojski merged PR #25609: URL: https://github.com/apache/flink/pull/25609 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apa

[jira] [Updated] (FLINK-34341) Add support for DDB Streams for DataStream API

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-34341: Parent: (was: FLINK-24438) Issue Type: New Feature (was: Sub-task) > Add supp

Re: [PR] [FLINK-33137][Connectors/Prometheus] Prometheus connector docs [flink-connector-prometheus]

2024-11-05 Thread via GitHub
nicusX commented on PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3#issuecomment-2457198460 @hlteoh37 I fixed the typos and improved the readability of the data structure -- This is an automated message from the Apache Git Service. To respond to the message, pleas

Re: [PR] [FLINK-36623] Improve logging in DefaultStateTransitionManager [flink]

2024-11-05 Thread via GitHub
XComp merged PR #25610: URL: https://github.com/apache/flink/pull/25610 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.

[jira] [Resolved] (FLINK-36623) Improve logging in DefaultStateTransitionManager

2024-11-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-36623. --- Fix Version/s: 2.0.0 Resolution: Fixed master: [21eea0d2ddeea14a791c13c9595d8cb54e9f

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
snuyanzin commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829676623 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java: ## @@ -50,74 +67,43 @@ void testUpsertInto(

Re: [PR] [FLINK-35780][state] Support state ttl migration [flink]

2024-11-05 Thread via GitHub
xiangyuf commented on PR #25611: URL: https://github.com/apache/flink/pull/25611#issuecomment-2457653564 @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-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
jnh5y commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829716133 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java: ## @@ -50,74 +67,43 @@ void testUpsertInto() {

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
twalthr commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829717408 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/SqlRewriterUtils.scala: ## @@ -130,8 +131,11 @@ object SqlRewriterUtils {

Re: [PR] [FLINK-36099][task] Log jobID in TaskExecutor#failTask [flink]

2024-11-05 Thread via GitHub
pnowojski commented on PR #25609: URL: https://github.com/apache/flink/pull/25609#issuecomment-2457299456 Test failure unrelated: https://issues.apache.org/jira/browse/FLINK-18476 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

Re: [PR] [FLINK-36651][Connectors/Elasticsearch] Fix IT test not compatible with 1.20, drop main branch tests for 1.18 [flink-connector-elasticsearch]

2024-11-05 Thread via GitHub
vahmed-hamdy commented on PR #110: URL: https://github.com/apache/flink-connector-elasticsearch/pull/110#issuecomment-2457790813 @snuyanzin yeah, I guess we can update the arch rules separately, could you please rereun the CI and check now? -- This is an automated message from the Apache

[jira] [Updated] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0

2024-11-05 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LvYanquan updated FLINK-36648: -- Affects Version/s: 2.0.0 > Release flink-connector-kafka v4.0.0 for Flink 2.0 > --

Re: [PR] [FLINK-36649] Fix oracle connection close error by OracleIncrementalSource read [flink-cdc]

2024-11-05 Thread via GitHub
JNSimba commented on PR #3678: URL: https://github.com/apache/flink-cdc/pull/3678#issuecomment-2456528985 @leonardBang Thanks for your reviewd, I added a description. I see that there are similar cases already in ITCase, such as **testConsumingAllEvents** in **OracleConnectorITCase** class.

[jira] [Commented] (FLINK-25921) Support different input parallelism for preCommit topology

2024-11-05 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895532#comment-17895532 ] Fabian Paul commented on FLINK-25921: - [~poorvank] I assigned the ticket to you. Do

[jira] [Assigned] (FLINK-25921) Support different input parallelism for preCommit topology

2024-11-05 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-25921: --- Assignee: Poorvank Bhatia > Support different input parallelism for preCommit topology > --

Re: [PR] [FLINK-36315][cdc-base]The flink-cdc-base module supports source metric statistics [flink-cdc]

2024-11-05 Thread via GitHub
liuxiao2shf commented on code in PR #3619: URL: https://github.com/apache/flink-cdc/pull/3619#discussion_r1828970845 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/test/java/org/apache/flink/cdc/connectors/base/experimental/config/MySqlSourceConfigFactory.java:

Re: [PR] [FLINK-36592][state/forst] Support file cache for ForStStateBackend [flink]

2024-11-05 Thread via GitHub
Zakelly commented on code in PR #25561: URL: https://github.com/apache/flink/pull/25561#discussion_r1829002947 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java: ## @@ -46,21 +58,45 @@ public class ForStFlink

Re: [PR] [FLINK-36068][runtime] Support for adaptive job scheduling based on StreamGraph [flink]

2024-11-05 Thread via GitHub
JunRuiLee closed pull request #25591: [FLINK-36068][runtime] Support for adaptive job scheduling based on StreamGraph URL: https://github.com/apache/flink/pull/25591 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-36615] Support LEAD/LAG functions in Table API [flink]

2024-11-05 Thread via GitHub
dawidwys merged PR #25582: URL: https://github.com/apache/flink/pull/25582 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

[jira] [Updated] (FLINK-36400) 403 and 404 responses should be fatal

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-36400: Fix Version/s: prometheus-connector-1.0.0 > 403 and 404 responses should be fatal > --

[jira] [Updated] (FLINK-36286) Set up validation workflows

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-36286: Fix Version/s: prometheus-connector-1.0.0 > Set up validation workflows >

[jira] [Assigned] (FLINK-36400) 403 and 404 responses should be fatal

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-36400: --- Assignee: Lorenzo Nicora > 403 and 404 responses should be fatal >

[jira] [Updated] (FLINK-36603) Inconsistent spelling of "behavior" and "retryable" across the API

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-36603: Fix Version/s: prometheus-connector-1.0.0 > Inconsistent spelling of "behavior" and "retry

[jira] [Updated] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33137: Fix Version/s: prometheus-connector-1.0.0 > FLIP-312: Prometheus Sink Connector >

[jira] [Closed] (FLINK-36288) Set up architectural test

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh closed FLINK-36288. --- Resolution: Fixed  merged commit 60aa7ee into apache:main > Set up architectural test > ---

[jira] [Updated] (FLINK-36288) Set up architectural test

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-36288: Fix Version/s: prometheus-connector-1.0.0 > Set up architectural test > --

[jira] [Assigned] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs

2024-11-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-36099: -- Assignee: Piotr Nowojski > JobIDLoggingITCase fails due to "Cannot find task to fail

[jira] [Commented] (FLINK-36289) Create Prometheus Flink connector release

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895556#comment-17895556 ] Hong Liang Teoh commented on FLINK-36289: - Closing as we don't need a Jira to tr

[jira] [Updated] (FLINK-33140) Prometheus Sink Connector - E2E example on AWS

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33140: Parent: (was: FLINK-33137) Issue Type: Bug (was: Sub-task) > Prometheus Sink

[jira] [Updated] (FLINK-33152) Prometheus Sink Connector - Integration tests

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33152: Parent: (was: FLINK-33137) Issue Type: Bug (was: Sub-task) > Prometheus Sink

[jira] [Updated] (FLINK-33139) Prometheus Sink Connector - Table API support

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33139: Parent: (was: FLINK-33137) Issue Type: Bug (was: Sub-task) > Prometheus Sink

[jira] [Closed] (FLINK-36289) Create Prometheus Flink connector release

2024-11-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh closed FLINK-36289. --- Resolution: Done > Create Prometheus Flink connector release > -

Re: [PR] [FLINK-35136] Bump connector version to 4.0, adapt CI workflows [flink-connector-hbase]

2024-11-05 Thread via GitHub
JuliaBogdan commented on PR #46: URL: https://github.com/apache/flink-connector-hbase/pull/46#issuecomment-2456683061 Great to see the PR merged, thanks for moving it forward @ferenc-csaky ! How does the release process and the timeline look? Is there anything I can help with to make it

[jira] [Updated] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs

2024-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36099: --- Labels: pull-request-available test-stability (was: test-stability) > JobIDLoggingITCase fa

[PR] [FLINK-36099][task] Log jobID in TaskExecutor#failTask [flink]

2024-11-05 Thread via GitHub
pnowojski opened a new pull request, #25609: URL: https://github.com/apache/flink/pull/25609 ## What is the purpose of the change Log jobID in TaskExecutor#failTask ## Brief change log Log jobID in TaskExecutor#failTask ## Verifying this change None directly

Re: [PR] [FLINK-33137][Connectors/Prometheus] Prometheus connector docs [flink-connector-prometheus]

2024-11-05 Thread via GitHub
nicusX commented on code in PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3#discussion_r1829116325 ## docs/content/docs/connectors/datastream/prometheus.md: ## @@ -0,0 +1,473 @@ +--- +title: Prometheus +weight: 5 +type: docs +aliases: + - /dev/connector

Re: [PR] [FLINK-33137][Connectors/Prometheus] Prometheus connector docs [flink-connector-prometheus]

2024-11-05 Thread via GitHub
nicusX commented on code in PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3#discussion_r1829138048 ## docs/content/docs/connectors/datastream/prometheus.md: ## @@ -0,0 +1,473 @@ +--- +title: Prometheus +weight: 5 +type: docs +aliases: + - /dev/connector

Re: [PR] [FLINK-33137][Connectors/Prometheus] Prometheus connector docs [flink-connector-prometheus]

2024-11-05 Thread via GitHub
nicusX commented on code in PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3#discussion_r1829138048 ## docs/content/docs/connectors/datastream/prometheus.md: ## @@ -0,0 +1,473 @@ +--- +title: Prometheus +weight: 5 +type: docs +aliases: + - /dev/connector

[PR] Flink 36623 [flink]

2024-11-05 Thread via GitHub
ztison opened a new pull request, #25610: URL: https://github.com/apache/flink/pull/25610 ## Brief change log - Exposed the JobID in `Adaptive Scheduler` states - Added JobID to logs in `DefaultStateTransitionManager` ## Verifying this change This change is a trivial rewor

Re: [PR] [FLINK-33137][Connectors/Prometheus] Prometheus connector docs [flink-connector-prometheus]

2024-11-05 Thread via GitHub
nicusX commented on code in PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3#discussion_r1829138048 ## docs/content/docs/connectors/datastream/prometheus.md: ## @@ -0,0 +1,473 @@ +--- +title: Prometheus +weight: 5 +type: docs +aliases: + - /dev/connector

Re: [PR] [FLINK-36623] Improve logging in DefaultStateTransitionManager [flink]

2024-11-05 Thread via GitHub
flinkbot commented on PR #25610: URL: https://github.com/apache/flink/pull/25610#issuecomment-2456861519 ## CI report: * 6dfa8c04a33326dbb4203365d2c817f173851283 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-36623) Improve logging in DefaultStateTransitionManager

2024-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36623: --- Labels: pull-request-available (was: ) > Improve logging in DefaultStateTransitionManager >

Re: [PR] [FLINK-33137][Connectors/Prometheus] Prometheus connector docs [flink-connector-prometheus]

2024-11-05 Thread via GitHub
nicusX commented on code in PR #3: URL: https://github.com/apache/flink-connector-prometheus/pull/3#discussion_r1829138048 ## docs/content/docs/connectors/datastream/prometheus.md: ## @@ -0,0 +1,473 @@ +--- +title: Prometheus +weight: 5 +type: docs +aliases: + - /dev/connector

[jira] [Updated] (FLINK-33967) Remove/Rename log4j2-test.properties in flink-streaming-java's test bundle

2024-11-05 Thread Kenneth William Krugler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth William Krugler updated FLINK-33967: Issue Type: Bug (was: Improvement) > Remove/Rename log4j2-test.properties

[jira] [Updated] (FLINK-33967) Remove/Rename log4j2-test.properties in flink-streaming-java's test bundle

2024-11-05 Thread Kenneth William Krugler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth William Krugler updated FLINK-33967: Priority: Minor (was: Major) > Remove/Rename log4j2-test.properties in fl

[jira] [Commented] (FLINK-33967) Remove/Rename log4j2-test.properties in flink-streaming-java's test bundle

2024-11-05 Thread Kenneth William Krugler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895725#comment-17895725 ] Kenneth William Krugler commented on FLINK-33967: - I think this should b

[PR] [hotfix][Connector/Elasticsearch] Update version to 3.1-SNAPSHOT [flink-connector-elasticsearch]

2024-11-05 Thread via GitHub
vahmed-hamdy opened a new pull request, #111: URL: https://github.com/apache/flink-connector-elasticsearch/pull/111 ## Notes - since there are no breaking changes from the latest release v3.0.1 the version should be v3.1 -- This is an automated message from the Apache Git Service. To

[PR] [backport][FLINK-36332] Fix okhttp dependency handling [flink-kubernetes-operator]

2024-11-05 Thread via GitHub
SamBarker opened a new pull request, #909: URL: https://github.com/apache/flink-kubernetes-operator/pull/909 ## What is the purpose of the change * Backport a fix (cherry picked from commit c821b48a75c601c3a64bc03bfbada218a68a0e0d) to ensure OKHttp is cleanly excluded

Re: [PR] [backport][FLINK-36332] Fix okhttp dependency handling [flink-kubernetes-operator]

2024-11-05 Thread via GitHub
SamBarker commented on PR #909: URL: https://github.com/apache/flink-kubernetes-operator/pull/909#issuecomment-2458058560 @gyfora backport of the webhook fix. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
snuyanzin commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829801746 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java: ## @@ -50,74 +67,43 @@ void testUpsertInto(

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
snuyanzin commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829780691 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/SqlRewriterUtils.scala: ## @@ -130,8 +131,11 @@ object SqlRewriterUtils {

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
snuyanzin commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829780200 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java: ## @@ -50,74 +67,43 @@ void testUpsertInto(

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
snuyanzin commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829790186 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/SqlRewriterUtils.scala: ## @@ -157,9 +161,14 @@ object SqlRewriterUtils {

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
jnh5y commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829778233 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/SqlRewriterUtils.scala: ## @@ -131,7 +131,7 @@ object SqlRewriterUtils { cal

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
snuyanzin commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829788023 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/SqlRewriterUtils.scala: ## @@ -131,7 +131,7 @@ object SqlRewriterUtils {

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
jnh5y commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829826534 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java: ## @@ -50,74 +67,43 @@ void testUpsertInto() {

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
jnh5y commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829793928 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidatorTest.java: ## @@ -50,74 +67,43 @@ void testUpsertInto() {

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
snuyanzin commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1830063028 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/SqlRewriterUtils.scala: ## @@ -173,69 +207,73 @@ object SqlRewriterUtils {

Re: [PR] [FLINK-36271] Support reading json and jsonb types in PostgreSQL dialect [flink-connector-jdbc]

2024-11-05 Thread via GitHub
grzegorz8 commented on PR #141: URL: https://github.com/apache/flink-connector-jdbc/pull/141#issuecomment-2458120435 @matriv I think `Caused by: org.postgresql.util.PSQLException: FATAL: sorry, too many clients already` error is irrelevant. I ofter see the error when I run tests locally,

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-11-05 Thread via GitHub
snuyanzin commented on code in PR #25316: URL: https://github.com/apache/flink/pull/25316#discussion_r1829790186 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/SqlRewriterUtils.scala: ## @@ -157,9 +161,14 @@ object SqlRewriterUtils {

Re: [PR] [FLINK-35463]Fixed issue for route rule changed when restored from checkpoint. [flink-cdc]

2024-11-05 Thread via GitHub
github-actions[bot] commented on PR #3364: URL: https://github.com/apache/flink-cdc/pull/3364#issuecomment-2458440160 This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encou

Re: [PR] [FLINK-36224][docs] Add the version mapping between pipeline connectors and flink [flink-cdc]

2024-11-05 Thread via GitHub
github-actions[bot] commented on PR #3598: URL: https://github.com/apache/flink-cdc/pull/3598#issuecomment-2458439947 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [FLINK-35071][cdc-connector][cdc-base] Shade guava31 to avoid dependency conflict with flink below 1.18 [flink-cdc]

2024-11-05 Thread via GitHub
github-actions[bot] commented on PR #3083: URL: https://github.com/apache/flink-cdc/pull/3083#issuecomment-2458440213 This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encou

  1   2   >