anupamaggarwal commented on PR #25890:
URL: https://github.com/apache/flink/pull/25890#issuecomment-2840935863
@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 com
[
https://issues.apache.org/jira/browse/FLINK-37734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv closed FLINK-37734.
--
Resolution: Fixed
Fixed in master via ecaf82e435052570d78fd92a41b195b287504079
> Update version to 3.
[
https://issues.apache.org/jira/browse/FLINK-37734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv reassigned FLINK-37734:
--
Assignee: Yanquan Lv
> Update version to 3.5-SNAPSHOT and update related docs
> -
[
https://issues.apache.org/jira/browse/FLINK-37728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reopened FLINK-37728:
> Incorrect import in EmbeddedPythonWindowOperator.java
>
[
https://issues.apache.org/jira/browse/FLINK-37728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen resolved FLINK-37728.
Resolution: Fixed
> Incorrect import in EmbeddedPythonWindowOperator.java
> --
ferenc-csaky merged PR #791:
URL: https://github.com/apache/flink-web/pull/791
--
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.
[
https://issues.apache.org/jira/browse/FLINK-37370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948304#comment-17948304
]
Jakob Homan edited comment on FLINK-37370 at 4/30/25 12:06 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-37370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948304#comment-17948304
]
Jakob Homan commented on FLINK-37370:
-
Hey [~rmetzger] - we've hit this. Do you ex
ferenc-csaky commented on code in PR #791:
URL: https://github.com/apache/flink-web/pull/791#discussion_r2067429195
##
docs/content/posts/2025-04-30-introducing-the-externalized-kudu-connector.md:
##
@@ -0,0 +1,89 @@
+---
+title: "Introducing the externalized Kudu connector"
+d
[
https://issues.apache.org/jira/browse/FLINK-37751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sai Sharath Dandi updated FLINK-37751:
--
Priority: Minor (was: Major)
> Add vertex name to autoscaler metrics
> --
autophagy commented on PR #26520:
URL: https://github.com/apache/flink/pull/26520#issuecomment-2840059080
@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.
Sai Sharath Dandi created FLINK-37751:
-
Summary: Add vertex name to autoscaler metrics
Key: FLINK-37751
URL: https://issues.apache.org/jira/browse/FLINK-37751
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-37751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948268#comment-17948268
]
Sai Sharath Dandi commented on FLINK-37751:
---
Hi [~fanrui] , Could you please r
darenwkt commented on code in PR #203:
URL:
https://github.com/apache/flink-connector-aws/pull/203#discussion_r2067097654
##
flink-connector-aws/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/table/RowDataToAttributeValueConverterTest.java:
##
@@ -21
maxime-menard commented on PR #764:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/764#issuecomment-2839790198
While doing the migration to Flink 2.0, I had to make the change otherwise I
was getting this
```
WARN Config uses deprecated configuration key 'high-ava
gustavodemorais commented on code in PR #26474:
URL: https://github.com/apache/flink/pull/26474#discussion_r2067090762
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/JsonFunctionsITCase.java:
##
@@ -821,12 +821,18 @@ private static List
pchoudhury22 commented on PR #968:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/968#issuecomment-2839727922
Thanks so much for all the notes!!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-3:
---
Labels: pull-request-available (was: )
> CI/CD should check NOTICE files for discrepancies.
darenwkt opened a new pull request, #204:
URL: https://github.com/apache/flink-connector-aws/pull/204
## Purpose of the change
[FLINK-3] Add unit test to verify dependencies in META-INF/NOTICE
- Currently, META-INF/NOTICE file is verified manually
- This change in
lihaosky commented on code in PR #26474:
URL: https://github.com/apache/flink/pull/26474#discussion_r2066987345
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/JsonFunctionsITCase.java:
##
@@ -821,12 +821,18 @@ private static List jsonSp
gustavodemorais commented on code in PR #26474:
URL: https://github.com/apache/flink/pull/26474#discussion_r2066973510
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/JsonFunctionsITCase.java:
##
@@ -821,12 +821,18 @@ private static List
mbalassi commented on code in PR #791:
URL: https://github.com/apache/flink-web/pull/791#discussion_r2066950306
##
docs/content/posts/2025-04-30-introducing-the-externalized-kudu-connector.md:
##
@@ -0,0 +1,89 @@
+---
+title: "Introducing the externalized Kudu connector"
+date:
flinkbot commented on PR #26520:
URL: https://github.com/apache/flink/pull/26520#issuecomment-2839503780
## CI report:
* 0ef58034bdc18b0bd4efbc3d88bcebae6f644e07 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
autophagy opened a new pull request, #26520:
URL: https://github.com/apache/flink/pull/26520
## What is the purpose of the change
I noticed that building the Flink Python API docs by running `make html` in
`flink-python/docs` can take longer than I expected - often well over 1 minute,
fruska commented on code in PR #791:
URL: https://github.com/apache/flink-web/pull/791#discussion_r2066879049
##
docs/content/posts/2025-04-30-introducing-the-externalized-kudu-connector.md:
##
@@ -0,0 +1,89 @@
+---
+title: "Introducing the externalized Kudu connector"
+date: "
fruska commented on code in PR #791:
URL: https://github.com/apache/flink-web/pull/791#discussion_r2066879049
##
docs/content/posts/2025-04-30-introducing-the-externalized-kudu-connector.md:
##
@@ -0,0 +1,89 @@
+---
+title: "Introducing the externalized Kudu connector"
+date: "
fruska commented on code in PR #791:
URL: https://github.com/apache/flink-web/pull/791#discussion_r2066877804
##
docs/content/posts/2025-04-30-introducing-the-externalized-kudu-connector.md:
##
@@ -0,0 +1,89 @@
+---
+title: "Introducing the externalized Kudu connector"
Review
lihaosky commented on code in PR #26474:
URL: https://github.com/apache/flink/pull/26474#discussion_r2066877602
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/JsonFunctionsITCase.java:
##
@@ -821,12 +821,18 @@ private static List jsonSp
ferenc-csaky commented on code in PR #791:
URL: https://github.com/apache/flink-web/pull/791#discussion_r2066875547
##
docs/content/posts/2025-04-30-introducing-the-externalized-kudu-connector.md:
##
@@ -0,0 +1,89 @@
+---
+title: "Introducing the externalized Kudu connector"
+d
fruska commented on code in PR #791:
URL: https://github.com/apache/flink-web/pull/791#discussion_r2066871128
##
docs/content/posts/2025-04-30-introducing-the-externalized-kudu-connector.md:
##
@@ -0,0 +1,89 @@
+---
+title: "Introducing the externalized Kudu connector"
+date: "
fruska commented on code in PR #791:
URL: https://github.com/apache/flink-web/pull/791#discussion_r2066871128
##
docs/content/posts/2025-04-30-introducing-the-externalized-kudu-connector.md:
##
@@ -0,0 +1,89 @@
+---
+title: "Introducing the externalized Kudu connector"
+date: "
ferenc-csaky opened a new pull request, #791:
URL: https://github.com/apache/flink-web/pull/791
(no comment)
--
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,
pranav234 closed pull request #26519: [FLINK-37750] Remove unused method
FutureUtils.runIfNotDoneAndGet()
URL: https://github.com/apache/flink/pull/26519
--
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
alkagin opened a new pull request, #976:
URL: https://github.com/apache/flink-kubernetes-operator/pull/976
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment` cust
[
https://issues.apache.org/jira/browse/FLINK-37747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948176#comment-17948176
]
Arvid Heise commented on FLINK-37747:
-
https://github.com/apache/flink/pull/26518#is
AHeise commented on PR #26518:
URL: https://github.com/apache/flink/pull/26518#issuecomment-2839056740
Here are some pointers for the IT.
I recently added a [rescale test for KafkaSink
](https://github.com/apache/flink-connector-kafka/blob/5384ab2f3a0bc42e6c3019c151f3b72bb4983926/flin
flinkbot commented on PR #26519:
URL: https://github.com/apache/flink/pull/26519#issuecomment-2838980391
## CI report:
* 02711a5fe8ece436bf74929293b40fd25c31be29 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37750:
---
Labels: pull-request-available (was: )
> Remove legacy function runIfNotDoneAndGet() in Fut
pranav234 opened a new pull request, #26519:
URL: https://github.com/apache/flink/pull/26519
The runIfNotDoneAndGet function is no longer used in the codebase. Removing
this function will reduce technical debt and improve code maintainability
## What is the purpose of the change
Pranav Mahajan created FLINK-37750:
--
Summary: Remove legacy function runIfNotDoneAndGet() in
FutureUtils class
Key: FLINK-37750
URL: https://issues.apache.org/jira/browse/FLINK-37750
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-37605.
-
Fix Version/s: 1.19.3
Resolution: Fixed
> SinkWriter may incorrectly infer end of input d
[
https://issues.apache.org/jira/browse/FLINK-37605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948164#comment-17948164
]
Arvid Heise commented on FLINK-37605:
-
Merged into 1.19 as
f869ae8e7ccd2d257f7cb5b2
AHeise merged PR #26458:
URL: https://github.com/apache/flink/pull/26458
--
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
[
https://issues.apache.org/jira/browse/FLINK-37747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-37747:
---
Assignee: David
> GlobalCommitterOperator cannot commit after scaling writer/committer
> --
[
https://issues.apache.org/jira/browse/FLINK-37605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-37605:
Fix Version/s: 1.20.2
> SinkWriter may incorrectly infer end of input during rescale
> ---
[
https://issues.apache.org/jira/browse/FLINK-37605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948160#comment-17948160
]
Arvid Heise commented on FLINK-37605:
-
Merged into 1.20 as
0b6da412cc33b25f9f1ab812
AHeise merged PR #26457:
URL: https://github.com/apache/flink/pull/26457
--
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
mxm commented on PR #966:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/966#issuecomment-2838608059
+1 Let's remove the weighting completely for now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
pranav234 commented on code in PR #26515:
URL: https://github.com/apache/flink/pull/26515#discussion_r2066170710
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MapTypeInfo.java:
##
@@ -39,6 +39,8 @@
@PublicEvolving
public class MapTypeInfo extends TypeInformat
gyfora commented on PR #901:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/901#issuecomment-2838530885
Closing this in favor of updating the beam dependency later. Please re-open
when necessary :)
--
This is an automated message from the Apache Git Service.
To respond to
gyfora closed pull request #901: [FLINK-36528] [Kubernetes Operator] Update
org.apache.avro from 1.8.2 to 1.12.0
URL: https://github.com/apache/flink-kubernetes-operator/pull/901
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
[
https://issues.apache.org/jira/browse/FLINK-31406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-31406.
--
Resolution: Won't Do
The gain from this feature is pretty limited as newer Flink versions all
support
gyfora commented on PR #968:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/968#issuecomment-2838497510
Based on offline discussions, due to the introduced complexity and the very
limited benefit we decided to drop this feature and close this jira for now.
--
This is an au
gyfora closed pull request #968: [FLINK-31406] Do not delete jobgraph on scale
only last-state upgrades
URL: https://github.com/apache/flink-kubernetes-operator/pull/968
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
gyfora commented on PR #966:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/966#issuecomment-2838495767
> Thank you @pchoudhury22, this is a great addition! Code looks very clean.
@mxm We discussed this with @pchoudhury22 offline a little and came to the
conclusion tha
Fred Teunissen created FLINK-37749:
--
Summary: FileSystem Connector fails writing to S3 bucket
Key: FLINK-37749
URL: https://issues.apache.org/jira/browse/FLINK-37749
Project: Flink
Issue Typ
darenwkt commented on PR #22:
URL:
https://github.com/apache/flink-connector-prometheus/pull/22#issuecomment-2838314070
> Thanks for the updates, loving the work to migrate the AWS specific
Prometheus behaviour out. I've added additional comments on the updates.
Thanks for the review
darenwkt commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-prometheus/pull/22#discussion_r2066049547
##
flink-connector-prometheus-request-signer-amp/src/test/java/org/apache/flink/connector/prometheus/sink/aws/AmazonManagedPrometheusWriteRequestSignerFactoryT
mxm commented on code in PR #966:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/966#discussion_r2066005803
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -236,6 +248,97 @@ public ParallelismChange computeScaleTargetPara
nicusX commented on code in PR #188:
URL:
https://github.com/apache/flink-connector-aws/pull/188#discussion_r2066006151
##
flink-connector-aws/flink-connector-aws-kinesis-streams/pom.xml:
##
@@ -52,6 +60,11 @@ under the License.
kinesis
+
+
bjlovegithub commented on PR #26518:
URL: https://github.com/apache/flink/pull/26518#issuecomment-2838222314
hey @AHeise I updated the PR with extra UT cases to cover scale up/down and
no scaling.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948135#comment-17948135
]
Zhanghao Chen commented on FLINK-30513:
---
[~xinchen147] We imlemented this feature
lvyanquan merged PR #4013:
URL: https://github.com/apache/flink-cdc/pull/4013
--
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
lvyanquan commented on PR #4013:
URL: https://github.com/apache/flink-cdc/pull/4013#issuecomment-2838129536
The failure case of OceanBaseE2eITCase.testOceanBaseCDC is unrelated to the
change here, and is traced in https://issues.apache.org/jira/browse/FLINK-37307.
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-37552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948128#comment-17948128
]
Yue Ma commented on FLINK-37552:
[~Zakelly] I have updated this PR. Can you please help
MOBIN-F commented on code in PR #4006:
URL: https://github.com/apache/flink-cdc/pull/4006#discussion_r2065903217
##
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java:
##
@@ -254,4 +251,27 @@ private Optional getContainingJar(Class cl
MOBIN-F commented on code in PR #4006:
URL: https://github.com/apache/flink-cdc/pull/4006#discussion_r2065880889
##
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java:
##
@@ -59,32 +60,28 @@ public class FlinkPipelineComposer implemen
twalthr commented on code in PR #26516:
URL: https://github.com/apache/flink/pull/26516#discussion_r2065864255
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ChangelogModeJsonDeserializer.java:
##
@@ -49,8 +51,14 @@ public C
foxus commented on code in PR #22:
URL:
https://github.com/apache/flink-connector-prometheus/pull/22#discussion_r2065830625
##
flink-connector-prometheus-request-signer-amp/src/test/java/org/apache/flink/connector/prometheus/sink/aws/AmazonManagedPrometheusWriteRequestSignerFactoryTest
gyfora commented on PR #25788:
URL: https://github.com/apache/flink/pull/25788#issuecomment-2838034219
@chenyuzhi459 can you please rebase on the latest master to retrigger the
tests before we merge this?
--
This is an automated message from the Apache Git Service.
To respond to the messa
chenyuzhi459 commented on PR #956:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2837981756
It depends on when will the pr https://github.com/apache/flink/pull/25788
could be merged.
If necessary, I can submit the pr fix in both 1.20 and 2.x versions
davidradl commented on code in PR #975:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/975#discussion_r2065811570
##
helm/flink-kubernetes-operator/conf/flink-conf.yaml:
##
@@ -24,8 +24,8 @@ parallelism.default: 1
# These should be kept in-sync with the flink di
gyfora commented on PR #975:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/975#issuecomment-2837962953
Makes sense @ekazakas thanks for the explanation :) Let's try this
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
[
https://issues.apache.org/jira/browse/FLINK-37747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948068#comment-17948068
]
David commented on FLINK-37747:
---
Thanks [~arvid] . We are using FLINK 1.20.1. Could you gi
HuangXingBo merged PR #26506:
URL: https://github.com/apache/flink/pull/26506
--
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
ekazakas commented on PR #975:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/975#issuecomment-2837903339
It doesn't make the compatibility better, since Flink jobs do not require
compiler modules. In case of very specific applications that for some reason
would need to acce
[
https://issues.apache.org/jira/browse/FLINK-37747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948051#comment-17948051
]
Arvid Heise commented on FLINK-37747:
-
Thank you for raising the issue and your deta
snuyanzin commented on code in PR #26516:
URL: https://github.com/apache/flink/pull/26516#discussion_r2065732308
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ChangelogModeJsonDeserializer.java:
##
@@ -49,8 +51,14 @@ public
snuyanzin commented on code in PR #26516:
URL: https://github.com/apache/flink/pull/26516#discussion_r2065732308
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ChangelogModeJsonDeserializer.java:
##
@@ -49,8 +51,14 @@ public
gyfora merged PR #973:
URL: https://github.com/apache/flink-kubernetes-operator/pull/973
--
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
kornys commented on PR #973:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/973#issuecomment-2837842698
GitHub is retiring the old cache service on 1 Feb 2025. ->
https://stackoverflow.com/questions/77897660/github-actions-node-js-16-actions-are-deprecated-warning
Olde
autophagy commented on code in PR #26510:
URL: https://github.com/apache/flink/pull/26510#discussion_r2065715763
##
flink-python/docs/conf.py:
##
@@ -102,6 +103,11 @@
autosummary_generate = True
autodoc_docstring_signature = True
+# Map to external docs for type annotations
gyfora commented on code in PR #966:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/966#discussion_r2065705970
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -236,6 +248,97 @@ public ParallelismChange computeScaleTargetP
[
https://issues.apache.org/jira/browse/FLINK-37740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-37740.
---
Resolution: Fixed
master (flink-docker):
[6e226503dbb228467905c70ccfb6f33f4c676872|https://
XComp commented on PR #224:
URL: https://github.com/apache/flink-docker/pull/224#issuecomment-2837781051
I triggered a [test
run](https://github.com/apache/flink-docker/actions/runs/14724358848) which
went through. Thanks for picking this up, @morazow 👍
--
This is an automated message f
morazow commented on PR #224:
URL: https://github.com/apache/flink-docker/pull/224#issuecomment-2837806801
Ahh great, no need to wait for schedule, thanks @XComp!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
dannycranmer commented on code in PR #188:
URL:
https://github.com/apache/flink-connector-aws/pull/188#discussion_r2065697710
##
flink-connector-aws/flink-connector-aws-kinesis-streams/pom.xml:
##
@@ -52,6 +60,11 @@ under the License.
kinesis
+
joyCurry30 commented on code in PR #4006:
URL: https://github.com/apache/flink-cdc/pull/4006#discussion_r2065689400
##
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java:
##
@@ -254,4 +251,27 @@ private Optional getContainingJar(Class
[
https://issues.apache.org/jira/browse/FLINK-37739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37739:
---
Labels: pull-request-available (was: )
> flink-conf is not obtained in local mode
> ---
joyCurry30 commented on code in PR #4006:
URL: https://github.com/apache/flink-cdc/pull/4006#discussion_r2065686169
##
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java:
##
@@ -59,32 +60,28 @@ public class FlinkPipelineComposer imple
joyCurry30 opened a new pull request, #4013:
URL: https://github.com/apache/flink-cdc/pull/4013
Fix environment variable check for FLINK_CDC_HOME in
YarnApplicationDeploymentExecutor. (#4012)
(cherry picked from commit ceffbc0ea1a223bb2a81bd63c507be5978dee7f3)
--
This is an automa
gyfora commented on PR #975:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/975#issuecomment-2837732076
> > These were added to improve java 17 compatibility for Flink apps, will
this affect that? If so having the warnings doesn't seem like a big deal
>
> It should not
lvyanquan merged PR #4012:
URL: https://github.com/apache/flink-cdc/pull/4012
--
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
93 matches
Mail list logo
