Kunal Rohitas created FLINK-36818:
-
Summary: Securing credentials in SQL connectors
Key: FLINK-36818
URL: https://issues.apache.org/jira/browse/FLINK-36818
Project: Flink
Issue Type: Improvem
Yanfei Lei created FLINK-36819:
--
Summary: [state/forst] Support link() in ForStFlinkFileSystem
Key: FLINK-36819
URL: https://issues.apache.org/jira/browse/FLINK-36819
Project: Flink
Issue Type:
RocMarshal commented on code in PR #134:
URL:
https://github.com/apache/flink-connector-kafka/pull/134#discussion_r1863022748
##
docs/content.zh/docs/connectors/table/upsert-kafka.md:
##
@@ -180,6 +180,14 @@ of all available metadata fields.
+
+
RocMarshal commented on code in PR #134:
URL:
https://github.com/apache/flink-connector-kafka/pull/134#discussion_r1863022594
##
docs/content.zh/docs/connectors/table/kafka.md:
##
@@ -342,6 +342,14 @@ CREATE TABLE KafkaTable (
Duration
Consumer 定期探测动态创建的 Kafka top
gustavodemorais commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1861756363
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -745,6 +745,35 @@ void createTemporarySystemFunction(
SML0127 commented on code in PR #3658:
URL: https://github.com/apache/flink-cdc/pull/3658#discussion_r1861728840
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/resources/ddl/column_type_test_mysql8.sql:
##
Review Comment:
it was my mista
twalthr opened a new pull request, #25707:
URL: https://github.com/apache/flink/pull/25707
## What is the purpose of the change
Adds the initial interfaces of `ProcessTableFunction` and `StateHint`
mentioned in FLIP-440 to the code base. This is a requirement to continue with
the `Ty
[
https://issues.apache.org/jira/browse/FLINK-36705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36705:
---
Labels: pull-request-available (was: )
> Add ProcessTableFunction class and annotations
> -
[
https://issues.apache.org/jira/browse/FLINK-36801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-36801.
Resolution: Duplicate
> Update CI image to Ubuntu 22.04
> ---
[
https://issues.apache.org/jira/browse/FLINK-34194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-34194:
Assignee: Chesnay Schepler (was: Matthias Pohl)
> Upgrade Flink CI Docker contai
Levani Kokhreidze created FLINK-36817:
-
Summary: Give users ability to provide their own KafkaConsumer
when using flink-connector-kafka
Key: FLINK-36817
URL: https://issues.apache.org/jira/browse/FLINK-36817
boring-cyborg[bot] commented on PR #137:
URL:
https://github.com/apache/flink-connector-kafka/pull/137#issuecomment-2505689926
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
[
https://issues.apache.org/jira/browse/FLINK-36817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36817:
---
Labels: pull-request-available (was: )
> Give users ability to provide their own KafkaConsu
lkokhreidze commented on PR #137:
URL:
https://github.com/apache/flink-connector-kafka/pull/137#issuecomment-2505694480
Will add the javadocs. But first wanted to get the initial feedback if this
makes sense.
--
This is an automated message from the Apache Git Service.
To respond to the
lkokhreidze commented on code in PR #137:
URL:
https://github.com/apache/flink-connector-kafka/pull/137#discussion_r1861855542
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaConsumerFactory.java:
##
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the A
snuyanzin commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1861852208
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/FunctionHint.java:
##
@@ -175,13 +178,40 @@
ArgumentHint[] arguments() default
snuyanzin commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1861853852
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/StateHint.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache Software Foundati
ferenc-csaky merged PR #25702:
URL: https://github.com/apache/flink/pull/25702
--
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.
snuyanzin commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1861953820
##
azure-pipelines.yml:
##
@@ -73,16 +73,16 @@ stages:
parameters: # see template file for a definition of the parameters.
stage_name: ci_build
tomncooper opened a new pull request, #25709:
URL: https://github.com/apache/flink/pull/25709
## What is the purpose of the change
This is backport of #25600.
The current version of `aws-java-sdk-core`, used in the `flink-s3-fs-base`
module, has a high severity vulnerability
davidradl commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1862049614
##
azure-pipelines.yml:
##
@@ -73,16 +73,16 @@ stages:
parameters: # see template file for a definition of the parameters.
stage_name: ci_build
naferx commented on PR #24829:
URL: https://github.com/apache/flink/pull/24829#issuecomment-2505902456
@snuyanzin just rebased this PR
--
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
flinkbot commented on PR #25709:
URL: https://github.com/apache/flink/pull/25709#issuecomment-2505933359
## CI report:
* f04105fca97ddc88b5e4359b428ec5a8455bdfdf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
davidradl commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862058735
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/FunctionHint.java:
##
@@ -175,13 +178,40 @@
ArgumentHint[] arguments() default
davidradl commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862058735
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/FunctionHint.java:
##
@@ -175,13 +178,40 @@
ArgumentHint[] arguments() default
davidradl commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862058735
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/FunctionHint.java:
##
@@ -175,13 +178,40 @@
ArgumentHint[] arguments() default
davidradl commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862076676
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java:
##
@@ -0,0 +1,239 @@
+/*
+ * Licensed to the Apache Softwa
SML0127 commented on code in PR #3658:
URL: https://github.com/apache/flink-cdc/pull/3658#discussion_r1861766911
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java:
##
flinkbot commented on PR #25708:
URL: https://github.com/apache/flink/pull/25708#issuecomment-2505643498
## CI report:
* 3a9c69c677f25a4be5a3168d830e3ced77ff4369 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mehdid93 commented on PR #25670:
URL: https://github.com/apache/flink/pull/25670#issuecomment-2505664022
@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.
Grzegorz Kołakowski created FLINK-36816:
---
Summary: Support source parallelism setting for JDBC connector
Key: FLINK-36816
URL: https://issues.apache.org/jira/browse/FLINK-36816
Project: Flink
SML0127 commented on code in PR #3658:
URL: https://github.com/apache/flink-cdc/pull/3658#discussion_r1861726630
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlFullTypesITCase.java:
##
[
https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901640#comment-17901640
]
Ammu Parvathy commented on FLINK-28897:
---
[~Jiangang] [~lsy] I have raised a PR
[h
gustavodemorais commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1861751435
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -100,6 +101,55 @@ void testCreateTableFromDescript
flinkbot commented on PR #25707:
URL: https://github.com/apache/flink/pull/25707#issuecomment-2505633651
## CI report:
* e8c2ec88bf59239f3c40a88d228905772eab9459 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
grzegorz8 opened a new pull request, #148:
URL: https://github.com/apache/flink-connector-jdbc/pull/148
# Purpose of the change
Add new option `scan.parallelism` support for JDBC connector.
Part of [FLINK-33261](https://issues.apache.org/jira/browse/FLINK-33261)
FLIP-367: Suppo
[
https://issues.apache.org/jira/browse/FLINK-36816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36816:
---
Labels: pull-request-available (was: )
> Support source parallelism setting for JDBC connec
dawidwys commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1861980546
##
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/extraction/TypeInferenceExtractorTest.java:
##
@@ -632,7 +633,9 @@ private static Stream f
mxm commented on code in PR #920:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/920#discussion_r1861986603
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -181,15 +178,15 @@ private void updateRecommendedParallelism(
mxm commented on code in PR #920:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/920#discussion_r1861985148
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -289,21 +274,26 @@ private ParallelismChange applyScaleDownInterv
zentol commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1861989731
##
azure-pipelines.yml:
##
@@ -73,16 +73,16 @@ stages:
parameters: # see template file for a definition of the parameters.
stage_name: ci_build
davidradl commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862082959
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/FunctionHint.java:
##
@@ -175,13 +178,40 @@
ArgumentHint[] arguments() default
[
https://issues.apache.org/jira/browse/FLINK-35114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-35114:
-
Summary: Remove old Table API implementations, update Schema stack (was:
Remove old Table API i
twalthr commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862101386
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java:
##
@@ -0,0 +1,239 @@
+/*
+ * Licensed to the Apache Software
twalthr commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862101386
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java:
##
@@ -0,0 +1,239 @@
+/*
+ * Licensed to the Apache Software
ferenc-csaky opened a new pull request, #3:
URL: https://github.com/apache/flink-connector-kudu/pull/3
Main logical changes:
- Removed old Table API source/sink/factory.
- Moved the Dynamic implementations up from the `dymanic` package.
- Updated the schema stack from `TableSchema` t
twalthr commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862114539
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java:
##
@@ -0,0 +1,239 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-35114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35114:
---
Labels: pull-request-available (was: )
> Remove old Table API implementations, update Schem
twalthr commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862103659
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/FunctionHint.java:
##
@@ -175,13 +178,40 @@
ArgumentHint[] arguments() default {}
twalthr commented on PR #25707:
URL: https://github.com/apache/flink/pull/25707#issuecomment-2506035053
> ideally testing the behavior documented in the comments.
This is a feature under development. The behavior in comments is not fully
implemented yet. As can be seen in the umbrella
twalthr commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862089260
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
*/
zentol commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1862177938
##
azure-pipelines.yml:
##
@@ -73,16 +73,16 @@ stages:
parameters: # see template file for a definition of the parameters.
stage_name: ci_build
zentol commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1862177938
##
azure-pipelines.yml:
##
@@ -73,16 +73,16 @@ stages:
parameters: # see template file for a definition of the parameters.
stage_name: ci_build
zentol commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1862177938
##
azure-pipelines.yml:
##
@@ -73,16 +73,16 @@ stages:
parameters: # see template file for a definition of the parameters.
stage_name: ci_build
zentol commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1862185553
##
.github/workflows/template.flink-ci.yml:
##
@@ -72,7 +72,7 @@ jobs:
name: "Compile"
runs-on: ubuntu-22.04
container:
- image: mapohl/flink-ci:FLIN
zentol commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1862177938
##
azure-pipelines.yml:
##
@@ -73,16 +73,16 @@ stages:
parameters: # see template file for a definition of the parameters.
stage_name: ci_build
zentol commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1862177938
##
azure-pipelines.yml:
##
@@ -73,16 +73,16 @@ stages:
parameters: # see template file for a definition of the parameters.
stage_name: ci_build
snuyanzin commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1862207540
##
.github/workflows/template.flink-ci.yml:
##
@@ -72,7 +72,7 @@ jobs:
name: "Compile"
runs-on: ubuntu-22.04
container:
- image: mapohl/flink-ci:F
snuyanzin commented on code in PR #25708:
URL: https://github.com/apache/flink/pull/25708#discussion_r1862207540
##
.github/workflows/template.flink-ci.yml:
##
@@ -72,7 +72,7 @@ jobs:
name: "Compile"
runs-on: ubuntu-22.04
container:
- image: mapohl/flink-ci:F
twalthr commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862211415
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/FunctionHint.java:
##
@@ -175,13 +178,40 @@
ArgumentHint[] arguments() default {}
twalthr commented on code in PR #25707:
URL: https://github.com/apache/flink/pull/25707#discussion_r1862212335
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/StateHint.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache Software Foundation
snuyanzin commented on PR #25708:
URL: https://github.com/apache/flink/pull/25708#issuecomment-2506147084
one minor comment which probably relates to image rather than this PR: since
jdk8 support was dropped (https://github.com/apache/flink/pull/25406) it could
be removed from image as well
zentol commented on PR #25708:
URL: https://github.com/apache/flink/pull/25708#issuecomment-2506155540
So long as we maintain 1.x branches I'd suggest to keep java 8 in there so
we are able to use the same CI image for all versions (in case the need arised
to bump the CI image in the 1.x br
gyfora merged PR #918:
URL: https://github.com/apache/flink-kubernetes-operator/pull/918
--
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
gustavodemorais commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862788331
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -745,6 +745,35 @@ void createTemporarySystemFunction(
gustavodemorais commented on PR #25704:
URL: https://github.com/apache/flink/pull/25704#issuecomment-2506886668
@twalthr @davidradl thanks for the reviews 👍 I think I've addressed all
comments, take a look.
Updating the python api was a bit tricky with the setup (curious to see if
l
herunkang2018 commented on PR #3656:
URL: https://github.com/apache/flink-cdc/pull/3656#issuecomment-2506898687
@leonardBang @yuxiqian Would you like to review again since the CI is
passed? Thanks a lot.
--
This is an automated message from the Apache Git Service.
To respond to the messag
Jiabao-Sun commented on PR #3707:
URL: https://github.com/apache/flink-cdc/pull/3707#issuecomment-2506910528
Thanks @herunkang2018 for this contribution.
Hi @yuxiqian, could you help review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message,
LiuBodong closed pull request #2985: [fix][cdc-connector][oracle] Fix oracle
server time zone option missing in table api.
URL: https://github.com/apache/flink-cdc/pull/2985
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
beryllw commented on PR #3728:
URL: https://github.com/apache/flink-cdc/pull/3728#issuecomment-2506921020
@lvyanquan @proletarians cc, thanks.
--
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
gustavodemorais commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862771988
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
gustavodemorais commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862772602
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
github-actions[bot] commented on PR #3569:
URL: https://github.com/apache/flink-cdc/pull/3569#issuecomment-2506867619
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
github-actions[bot] closed pull request #3569:
[FLINK-35444][pipeline-connector][paimon] Paimon Pipeline Connector support
changing column names to lowercase for Hive metastore
URL: https://github.com/apache/flink-cdc/pull/3569
--
This is an automated message from the Apache Git Service.
To
gustavodemorais commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862775007
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
gustavodemorais commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862779370
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -49,55 +50,78 @@ class TableEnvironmentTest {
davidradl commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862341867
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
MartijnVisser commented on PR #25602:
URL: https://github.com/apache/flink/pull/25602#issuecomment-2506290502
It looks like we've pivoted from the original intent of the Jira ticket
(upgrade to Calcite 1.38). That means that we'll either have to create a new
Jira ticket for what's done in t
[
https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-36602:
---
Labels: (was: pull-request-available)
> Upgrade Calcite version to 1.38.0
> --
davidradl commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862333839
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
davidradl commented on code in PR #25692:
URL: https://github.com/apache/flink/pull/25692#discussion_r1862403736
##
flink-filesystems/pom.xml:
##
@@ -34,7 +34,7 @@ under the License.
pom
- 3.3.4
+ 3.3.6
Review Comment:
There are
davidradl commented on code in PR #25681:
URL: https://github.com/apache/flink/pull/25681#discussion_r1862411403
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ScanReuser.java:
##
@@ -165,7 +166,7 @@ public List reuseDuplicatedScan(Lis
davidradl commented on code in PR #25705:
URL: https://github.com/apache/flink/pull/25705#discussion_r1862326643
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/util/SqlGatewayRestAPIVersion.java:
##
@@ -51,7 +51,10 @@ public enum SqlGatewayRes
davidradl commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862384619
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
snuyanzin merged PR #24829:
URL: https://github.com/apache/flink/pull/24829
--
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
snuyanzin commented on PR #24829:
URL: https://github.com/apache/flink/pull/24829#issuecomment-2506518447
@naferx can you please also create backports for 1.19, 1.20?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-36529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-36529.
--
Fix Version/s: kubernetes-operator-1.11.0
Resolution: Fixed
merged to main 9bab0286dc152ba5dbf8
davidradl commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862354231
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
davidradl commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862333839
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
mehdid93 commented on PR #25670:
URL: https://github.com/apache/flink/pull/25670#issuecomment-2506492367
@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.
ammu20-dev commented on code in PR #25656:
URL: https://github.com/apache/flink/pull/25656#discussion_r1861721487
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/FunctionITCase.java:
##
@@ -1542,6 +1542,19 @@ void testUsingAddJa
SML0127 commented on code in PR #3658:
URL: https://github.com/apache/flink-cdc/pull/3658#discussion_r1861726630
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlFullTypesITCase.java:
##
davidradl commented on code in PR #25676:
URL: https://github.com/apache/flink/pull/25676#discussion_r1862415650
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/StateBackendTestV2Base.java:
##
@@ -177,8 +182,8 @@ protected AsyncKeyedStateBackend
restoreAsyncKe
XComp commented on code in PR #25679:
URL: https://github.com/apache/flink/pull/25679#discussion_r1862280134
##
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionServiceTest.java:
##
@@ -1246,6 +1200,62 @@ private void testNonBlockingCall(
davidradl commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862333839
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -718,6 +718,36 @@ void createTemporarySystemFunction(
twalthr commented on PR #25707:
URL: https://github.com/apache/flink/pull/25707#issuecomment-2506316008
@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.
davidradl commented on code in PR #25700:
URL: https://github.com/apache/flink/pull/25700#discussion_r1862393806
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/application/ScriptExecutor.java:
##
@@ -0,0 +1,332 @@
+/*
+ * Licensed to the Ap
davidradl commented on code in PR #25704:
URL: https://github.com/apache/flink/pull/25704#discussion_r1862391147
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -49,55 +50,78 @@ class TableEnvironmentTest {
@Test
snuyanzin commented on PR #24829:
URL: https://github.com/apache/flink/pull/24829#issuecomment-2506443102
@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.
davidradl commented on code in PR #25656:
URL: https://github.com/apache/flink/pull/25656#discussion_r1862450447
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/FunctionITCase.java:
##
@@ -1542,6 +1542,19 @@ void testUsingAddJar
1 - 100 of 102 matches
Mail list logo
