Sergey Nuyanzin created FLINK-36919:
---
Summary: Add missing dropTable/dropView methods to TableEnvironment
Key: FLINK-36919
URL: https://issues.apache.org/jira/browse/FLINK-36919
Project: Flink
flinkbot commented on PR #25807:
URL: https://github.com/apache/flink/pull/25807#issuecomment-2547735581
## CI report:
* 4dce496a2343eb22a24b6996f3967b6e46da6b5d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Samrat002 commented on PR #25793:
URL: https://github.com/apache/flink/pull/25793#issuecomment-2547740879
@rmetzger Please review whenever time
--
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 th
[
https://issues.apache.org/jira/browse/FLINK-36916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-36916:
---
Assignee: Yiyu Tian
> Unexpected error in type inference logic of function 'TYPEOF'
yuxiqian commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888029795
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java:
##
@@ -78,6 +78,8 @@ public class YamlPipelineDefinitionParser impl
dependabot[bot] commented on PR #25741:
URL: https://github.com/apache/flink/pull/25741#issuecomment-2547855684
Looks like these dependencies are up-to-date now, so this is no longer
needed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
dependabot[bot] closed pull request #25741: Bump ws and socket.io in
/flink-runtime-web/web-dashboard
URL: https://github.com/apache/flink/pull/25741
--
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
dependabot[bot] commented on PR #25740:
URL: https://github.com/apache/flink/pull/25740#issuecomment-2547855664
Looks like these dependencies are up-to-date now, so this is no longer
needed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-36912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906330#comment-17906330
]
Weijie Guo commented on FLINK-36912:
> This was an infrastructure issue that was fix
dependabot[bot] closed pull request #25740: Bump d3-color, @antv/g-base and
d3-interpolate in /flink-runtime-web/web-dashboard
URL: https://github.com/apache/flink/pull/25740
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
dependabot[bot] closed pull request #25751: Bump cookie and socket.io in
/flink-runtime-web/web-dashboard
URL: https://github.com/apache/flink/pull/25751
--
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
dependabot[bot] opened a new pull request, #25808:
URL: https://github.com/apache/flink/pull/25808
Bumps
[com.nimbusds:nimbus-jose-jwt](https://bitbucket.org/connect2id/nimbus-jose-jwt)
from 4.41.1 to 9.37.2.
Changelog
Sourced from https://bitbucket.org/connect2id/nimbus-jose-jwt/
rmetzger commented on code in PR #25793:
URL: https://github.com/apache/flink/pull/25793#discussion_r1888139433
##
docs/content/docs/ops/production_ready.md:
##
@@ -81,4 +81,11 @@ It is a single point of failure within the cluster, and if
it crashes, no new jo
Configuring [H
Anupam Aggarwal created FLINK-36920:
---
Summary: Update org.quartz-schedule:quartz
Key: FLINK-36920
URL: https://issues.apache.org/jira/browse/FLINK-36920
Project: Flink
Issue Type: Improveme
rmetzger merged PR #25718:
URL: https://github.com/apache/flink/pull/25718
--
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
[
https://issues.apache.org/jira/browse/FLINK-36740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-36740.
Resolution: Fixed
Merged to master (2.0.0) in
https://github.com/apache/flink/commit/1c2e
flinkbot commented on PR #25808:
URL: https://github.com/apache/flink/pull/25808#issuecomment-2547869110
## CI report:
* 6cd0e581df8053fae08c710dd126a0bdbd2881f8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] commented on PR #25751:
URL: https://github.com/apache/flink/pull/25751#issuecomment-2547855649
Looks like these dependencies are up-to-date now, so this is no longer
needed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
XComp commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1888127410
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -83,9 +83,16 @@ public Collection getJobManagerRunners() {
snuyanzin commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1888463167
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -661,6 +673,18 @@ public boolean dropTemporaryV
rmetzger merged PR #25793:
URL: https://github.com/apache/flink/pull/25793
--
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
[
https://issues.apache.org/jira/browse/FLINK-36889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-36889.
Fix Version/s: 2.0.0
Resolution: Fixed
Merged to master (2.0.0) in
https://github.
twalthr commented on PR #25805:
URL: https://github.com/apache/flink/pull/25805#issuecomment-2548723724
@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 #25595:
URL: https://github.com/apache/flink/pull/25595#discussion_r1888720082
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/CatalogTestBase.java:
##
@@ -177,20 +177,8 @@ protected Map
getStreamingTablePropert
davidradl commented on code in PR #25595:
URL: https://github.com/apache/flink/pull/25595#discussion_r1888720082
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/CatalogTestBase.java:
##
@@ -177,20 +177,8 @@ protected Map
getStreamingTablePropert
RocMarshal commented on code in PR #25800:
URL: https://github.com/apache/flink/pull/25800#discussion_r1888725463
##
flink-core/src/test/java/org/apache/flink/configuration/TaskManagerLoadBalanceModeTest.java:
##
@@ -1,49 +0,0 @@
-/*
- * Licensed to the Apache Software Foundatio
davidradl commented on code in PR #25595:
URL: https://github.com/apache/flink/pull/25595#discussion_r1888721096
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/CatalogTestBase.java:
##
@@ -168,7 +168,7 @@ protected Map getBatchTableProperties()
[
https://issues.apache.org/jira/browse/FLINK-35721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906445#comment-17906445
]
Alexander Fedulov commented on FLINK-35721:
---
I verified on 1.19.1 that casts w
[
https://issues.apache.org/jira/browse/FLINK-35721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906445#comment-17906445
]
Alexander Fedulov edited comment on FLINK-35721 at 12/17/24 3:40 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906419#comment-17906419
]
Sergey Nuyanzin commented on FLINK-36916:
-
FYI the root cause of this task seems
ruanhang1993 commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888103827
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java:
##
@@ -316,6 +318,10 @@ private TransformDef toTransformDef(Jso
[
https://issues.apache.org/jira/browse/FLINK-33921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-33921:
-
Fix Version/s: 2.0.0
> Cleanup deprecated IdleStateRetentionTime related method in
> org.apache.flink.t
[
https://issues.apache.org/jira/browse/FLINK-36912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906322#comment-17906322
]
Matthias Pohl commented on FLINK-36912:
---
This was an infrastructure issue that was
[
https://issues.apache.org/jira/browse/FLINK-36912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-36912.
---
Resolution: Fixed
I'm closing this one. Feel free to open it again if you think that it's no
ruanhang1993 commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888103827
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java:
##
@@ -316,6 +318,10 @@ private TransformDef toTransformDef(Jso
[
https://issues.apache.org/jira/browse/FLINK-36919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36919:
---
Labels: pull-request-available (was: )
> Add missing dropTable/dropView methods to TableEnv
ammu20-dev opened a new pull request, #25809:
URL: https://github.com/apache/flink/pull/25809
## What is the purpose of the change
This pull request fixes the class loading issues when using udf in add jar
and enabling checkpointing. This is a back port of the fix to 1.19.2
snuyanzin opened a new pull request, #25810:
URL: https://github.com/apache/flink/pull/25810
## What is the purpose of the change
FLIP-489 [1] adds two methods to TableEnvironment
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=332499781
## Verifying this
yuxiqian commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888179373
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java:
##
@@ -316,6 +318,10 @@ private TransformDef toTransformDef(JsonNod
[
https://issues.apache.org/jira/browse/FLINK-36746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906338#comment-17906338
]
raoraoxiong commented on FLINK-36746:
-
[~yunta] It's right. I am happy to take this
flinkbot commented on PR #25810:
URL: https://github.com/apache/flink/pull/25810#issuecomment-2548193698
## CI report:
* 7df8fa81518b37809a24e5c72887c50328859ac6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25809:
URL: https://github.com/apache/flink/pull/25809#issuecomment-2548193207
## CI report:
* f12f137ae259824341b6bbac537e9503ab5f3ace UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Robert Metzger created FLINK-36921:
--
Summary:
AdaptiveExecutionPlanSchedulingContextTest.testGetParallelismAndMaxParallelism
fails
Key: FLINK-36921
URL: https://issues.apache.org/jira/browse/FLINK-36921
yuxiqian commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888227512
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/transform/converter/PostTransformConverter.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Sof
yuxiqian commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888227512
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/transform/converter/PostTransformConverter.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Sof
lvyanquan commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888249961
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/transform/converter/PostTransformConverter.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache So
lvyanquan commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888249961
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/transform/converter/PostTransformConverter.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache So
lvyanquan commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888249961
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/transform/converter/PostTransformConverter.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache So
lvyanquan commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888249961
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/transform/converter/PostTransformConverter.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache So
xiaochen-zhou commented on PR #141:
URL:
https://github.com/apache/flink-connector-kafka/pull/141#issuecomment-2548084763
> Afaik this doesn't work and was the main reason for #100. If you last
message is a transaction marker, then you would never check the stop condition
on that partition
gustavodemorais commented on PR #25806:
URL: https://github.com/apache/flink/pull/25806#issuecomment-2547929083
Lint seems to have failed, taking a look
--
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
[
https://issues.apache.org/jira/browse/FLINK-36917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36917:
--
Assignee: ChaomingZhang
> Add OceanBase DataSource to Flink CDC
> ---
[
https://issues.apache.org/jira/browse/FLINK-36920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-36920:
---
Summary: Update org.quartz-schedule:quartz in flink-autoscaler module from
2.3.2 to 2.4.0 (
lvyanquan commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888249961
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/transform/converter/PostTransformConverter.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-36913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36913:
---
Labels: pull-request-available (was: )
> Add an option in Kafka Sink to manual map table to
coopstah13 opened a new pull request, #150:
URL: https://github.com/apache/flink-connector-jdbc/pull/150
Only instantiate the provider from the connection options builder if no
provider was set on the builder
--
This is an automated message from the Apache Git Service.
To respond to the m
boring-cyborg[bot] commented on PR #150:
URL:
https://github.com/apache/flink-connector-jdbc/pull/150#issuecomment-2548447332
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-36236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36236:
---
Labels: pull-request-available (was: )
> JdbcSourceBuilder overrides set connection provide
snuyanzin merged PR #25759:
URL: https://github.com/apache/flink/pull/25759
--
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
[
https://issues.apache.org/jira/browse/FLINK-35241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-35241.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Support SQL FLOOR and CEIL functions wit
[
https://issues.apache.org/jira/browse/FLINK-35241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906416#comment-17906416
]
Sergey Nuyanzin commented on FLINK-35241:
-
Merged as
[c7d8515c0285fc0019571a1f6
[
https://issues.apache.org/jira/browse/FLINK-30975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-30975:
---
Description:
Currently, *Flink's S3 FileSystem* is limited to using AWS SDK V1. However, AWS
strong
davidradl commented on PR #25769:
URL: https://github.com/apache/flink/pull/25769#issuecomment-2548134819
@rmetzger @donPain I had a quick look at the docs, it seems that Hugo does
allow templating which supports variables. I can see the Flink code referencing
the predefined variables with
davidradl commented on code in PR #25800:
URL: https://github.com/apache/flink/pull/25800#discussion_r1888317764
##
flink-core/src/test/java/org/apache/flink/configuration/TaskManagerLoadBalanceModeTest.java:
##
@@ -1,49 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1888663499
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -661,6 +673,18 @@ public boolean dropTemporaryV
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1888663499
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -661,6 +673,18 @@ public boolean dropTemporaryV
[
https://issues.apache.org/jira/browse/FLINK-36916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906439#comment-17906439
]
Yiyu Tian commented on FLINK-36916:
---
Hi [~Sergey Nuyanzin] , got it. Thank you for the
davidradl commented on PR #25794:
URL: https://github.com/apache/flink/pull/25794#issuecomment-2548013021
@mehdid93 are you ok to look into this ?
--
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
[
https://issues.apache.org/jira/browse/FLINK-36898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-36898:
Description: Currently, Flink does not support nanosecond precision for the
CEIL and FLOOR functio
XComp commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1888147138
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -83,9 +83,16 @@ public Collection getJobManagerRunners() {
ruanhang1993 commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1888161102
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java:
##
@@ -316,6 +318,10 @@ private TransformDef toTransformDef(Jso
[
https://issues.apache.org/jira/browse/FLINK-36873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36873:
---
Labels: pull-request-available (was: )
> Adapting batch job progress recovery to Apache Cel
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1888439721
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1040,6 +1047,13 @@ void createTemporarySystemFunction(
JunRuiLee opened a new pull request, #25811:
URL: https://github.com/apache/flink/pull/25811
## What is the purpose of the change
[FLINK-36873][runtime] Adapting batch job progress recovery to Apache
Celeborn.
## Brief change log
Adapting batch job pr
flinkbot commented on PR #25811:
URL: https://github.com/apache/flink/pull/25811#issuecomment-2548346343
## CI report:
* b868c0a44f00036e62d0a37ac4f74b525ecb855c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1888448176
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -661,6 +673,18 @@ public boolean dropTemporaryV
twalthr commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1888450395
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1030,6 +1030,13 @@ void createTemporarySystemFunction(
afedulov closed pull request #25812: Flink 33117
URL: https://github.com/apache/flink/pull/25812
--
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-
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1889030551
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -365,6 +368,38 @@ public static TimestampData toTimestampData(d
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1889033882
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -421,6 +456,21 @@ public static TimestampData parseTimestampDat
[
https://issues.apache.org/jira/browse/FLINK-35721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-35721:
--
Fix Version/s: 1.20.1
> I found out that in the Flink SQL documentation it says that D
afedulov merged PR #23439:
URL: https://github.com/apache/flink/pull/23439
--
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
lincoln-lil merged PR #23980:
URL: https://github.com/apache/flink/pull/23980
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-33921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-33921.
---
Resolution: Fixed
fixed in master: 6248fd4fd61a0d76f1b6160abff19fdfdc0f4c63
> Cleanup deprecated Id
supalle commented on PR #25813:
URL: https://github.com/apache/flink/pull/25813#issuecomment-2550105113
I need it too
--
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 uns
ruanhang1993 commented on code in PR #3804:
URL: https://github.com/apache/flink-cdc/pull/3804#discussion_r1889487420
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/transform/converter/PostTransformConverter.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache
liuyongvs commented on PR #22745:
URL: https://github.com/apache/flink/pull/22745#issuecomment-2550125041
Hi @snuyanzin i rebase to fix conflict and squash the commits, will you
help look it again?
--
This is an automated message from the Apache Git Service.
To respond to the mes
flinkbot commented on PR #25814:
URL: https://github.com/apache/flink/pull/25814#issuecomment-2550439863
## CI report:
* 1f3e464799a52457b45e23b6bdb174a3fc9c13d7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
noorall commented on PR #25551:
URL: https://github.com/apache/flink/pull/25551#issuecomment-2550443470
@JunRuiLee Thanks for review. The PR has been updated based on your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
yuxiqian commented on PR #3633:
URL: https://github.com/apache/flink-cdc/pull/3633#issuecomment-2550456391
Thanks for @GOODBOY008's review, fixed and rebased.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
github-actions[bot] commented on PR #3654:
URL: https://github.com/apache/flink-cdc/pull/3654#issuecomment-2549943981
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.
--
github-actions[bot] commented on PR #3650:
URL: https://github.com/apache/flink-cdc/pull/3650#issuecomment-2549944007
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.
--
Wang Qilong created FLINK-36925:
---
Summary: Introduce SemiAntiJoinOperator in Join with Async State
API
Key: FLINK-36925
URL: https://issues.apache.org/jira/browse/FLINK-36925
Project: Flink
Is
Au-Miner opened a new pull request, #25814:
URL: https://github.com/apache/flink/pull/25814
## What is the purpose of the change
Introduce SemiAntiJoinOperator in Join with async state api.
## Brief change log
- *Introduce SemiAntiJoinOperator in Join with async state a
GOODBOY008 commented on code in PR #3633:
URL: https://github.com/apache/flink-cdc/pull/3633#discussion_r1889667552
##
.github/workflows/flink_cdc_migration_test_base.yml:
##
@@ -13,22 +13,36 @@
# See the License for the specific language governing permissions and
# limitation
ChaomingZhangCN commented on PR #3211:
URL: https://github.com/apache/flink-cdc/pull/3211#issuecomment-2550294278
> @whhe RichSourceFunction is Deprecated interface，We can implements use
Source interface？
JdbcIncrementalSource implements new Source interface :)
--
This is an automa
LEONID ILYEVSKY created FLINK-36922:
---
Summary: Add warning when creating KryoSerializer for generic type
Key: FLINK-36922
URL: https://issues.apache.org/jira/browse/FLINK-36922
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-36907:
---
Parent: FLINK-36641
Issue Type: Sub-task (was: New Feature)
> Bump flink-connector-aws to 1
[
https://issues.apache.org/jira/browse/FLINK-36887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-36887:
---
Parent: FLINK-36641
Issue Type: Sub-task (was: New Feature)
> Add support for Flink 1.20 in
[
https://issues.apache.org/jira/browse/FLINK-36641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-36641:
---
Description:
This is a parent task to trace all external connectors support and release for
Flink 1
1 - 100 of 155 matches
Mail list logo
