Abhi Gupta created FLINK-36523:
--
Summary: DDB Streams connector treating LATEST as TRIM_HORIZON for
some cases
Key: FLINK-36523
URL: https://issues.apache.org/jira/browse/FLINK-36523
Project: Flink
gguptp opened a new pull request, #177:
URL: https://github.com/apache/flink-connector-aws/pull/177
## Purpose of the change
Fixing latest behaviour for DDB Connector.
## Verifying this change
Please make sure both new and modified tests in this PR follows
[
https://issues.apache.org/jira/browse/FLINK-36523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36523:
---
Labels: pull-request-available (was: )
> DDB Streams connector treating LATEST as TRIM_HORI
xiangyu feng created FLINK-36521:
Summary: Introduce TtlAwareSerializer to resolve the compatibility
check between ttlSerializer and original serializer
Key: FLINK-36521
URL: https://issues.apache.org/jira/browse
[
https://issues.apache.org/jira/browse/FLINK-33389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33389:
---
Labels: pull-request-available (was: )
> Support tasks balancing at slot level for Adaptive
RocMarshal commented on PR #25504:
URL: https://github.com/apache/flink/pull/25504#issuecomment-2408975076
Hi, @1996fanrui Could you help take a look ? many thx~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
flinkbot commented on PR #25504:
URL: https://github.com/apache/flink/pull/25504#issuecomment-2408976265
## CI report:
* 213414ebbf36c9dd897e601f28b77fa4470d9ec8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888961#comment-17888961
]
Mate Czagany commented on FLINK-35650:
--
[~ammu] that sounds like the expected outpu
gyfora merged PR #883:
URL: https://github.com/apache/flink-kubernetes-operator/pull/883
--
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
[
https://issues.apache.org/jira/browse/FLINK-36264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-36264.
--
Fix Version/s: kubernetes-operator-1.10.0
Resolution: Fixed
merged to main 4d5b2c9a0bd470c03a20
RocMarshal commented on code in PR #25174:
URL: https://github.com/apache/flink/pull/25174#discussion_r1798242400
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/SlotInfo.java:
##
@@ -54,10 +59,27 @@ public interface SlotInfo {
*/
ResourceProfile get
RocMarshal commented on code in PR #25174:
URL: https://github.com/apache/flink/pull/25174#discussion_r1798242400
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/SlotInfo.java:
##
@@ -54,10 +59,27 @@ public interface SlotInfo {
*/
ResourceProfile get
[
https://issues.apache.org/jira/browse/FLINK-35650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889009#comment-17889009
]
Ammu Parvathy commented on FLINK-35650:
---
[~mateczagany] Yes, the comparison functi
noorall commented on code in PR #25366:
URL: https://github.com/apache/flink/pull/25366#discussion_r1798301343
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -220,24 +197,15 @@ private StreamingJobGraphGenerator(
noorall commented on code in PR #25366:
URL: https://github.com/apache/flink/pull/25366#discussion_r1798301444
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -220,24 +197,15 @@ private StreamingJobGraphGenerator(
noorall commented on code in PR #25366:
URL: https://github.com/apache/flink/pull/25366#discussion_r1798302712
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/OperatorChainInfo.java:
##
@@ -0,0 +1,194 @@
+/*
+ * Licensed to the Apache Software Foundation
noorall commented on code in PR #25366:
URL: https://github.com/apache/flink/pull/25366#discussion_r1798304428
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -1830,10 +1950,10 @@ private void setCoLocation() {
noorall commented on code in PR #25366:
URL: https://github.com/apache/flink/pull/25366#discussion_r1798307016
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -355,32 +337,46 @@ private void
waitForSerializationFuturesA
noorall commented on code in PR #25366:
URL: https://github.com/apache/flink/pull/25366#discussion_r1798314260
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/JobVertexBuildContext.java:
##
@@ -0,0 +1,165 @@
+/*
+ * Licensed to the Apache Software Founda
noorall commented on PR #25366:
URL: https://github.com/apache/flink/pull/25366#issuecomment-2408968894
> Thanks for creating the PR! @noorall The works overall looks good. I have
a few comments. PLAT.
Thanks for your review. The PR has been updated according to your comments,
and I'
RocMarshal opened a new pull request, #25504:
URL: https://github.com/apache/flink/pull/25504
## What is the purpose of the change
[FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive
Scheduler
## Brief change log
- Introduce the
Kartik Goyal created FLINK-36522:
Summary: Bump mysql-connector-j version
Key: FLINK-36522
URL: https://issues.apache.org/jira/browse/FLINK-36522
Project: Flink
Issue Type: Improvement
SamBarker opened a new pull request, #899:
URL: https://github.com/apache/flink-kubernetes-operator/pull/899
Rather embarrassingly there is a typo in the new httpclient property luckily
as its still un-released we can freely rename it.
--
This is an automated message from the Apache Git
github-actions[bot] commented on PR #3535:
URL: https://github.com/apache/flink-cdc/pull/3535#issuecomment-2409408634
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.
--
gyfora merged PR #889:
URL: https://github.com/apache/flink-kubernetes-operator/pull/889
--
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
kartik-3513 opened a new pull request, #898:
URL: https://github.com/apache/flink-kubernetes-operator/pull/898
## What is the purpose of the change
Bump mysql-connector-java from 8.0.33 to mysql-connector-j 8.4.0
## Brief change log
mysql-connector-java version 8.0.33
[
https://issues.apache.org/jira/browse/FLINK-36522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36522:
---
Labels: pull-request-available (was: )
> Bump mysql-connector-j version
> -
[
https://issues.apache.org/jira/browse/FLINK-36450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-36450.
--
Fix Version/s: kubernetes-operator-1.10.0
Assignee: Siddharth R
Resolution: Fixed
merg
[
https://issues.apache.org/jira/browse/FLINK-36466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36466:
---
Labels: pull-request-available (was: )
> Change default value of execution.runtime-mode fro
ruanwenjun opened a new pull request, #25505:
URL: https://github.com/apache/flink/pull/25505
## What is the purpose of the change
Change default value of `execution.runtime-mode` from `STREAMING` to
`AUTOMATIC` to fix `shouldExecuteInBatchMode` is incorrect when doesn
flinkbot commented on PR #25505:
URL: https://github.com/apache/flink/pull/25505#issuecomment-2409033454
## CI report:
* 3de9812559fb416b03f6903c7311481362a1cbb1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JunRuiLee opened a new pull request, #25506:
URL: https://github.com/apache/flink/pull/25506
[W.I.P] Disable parallel serial operator factory
--
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 s
flinkbot commented on PR #25506:
URL: https://github.com/apache/flink/pull/25506#issuecomment-2409038582
## CI report:
* 4ca1874da72b33bb49cddac9407ede001f7a5553 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889025#comment-17889025
]
Vinh Pham commented on FLINK-35093:
---
Hi [~loserwang1024] , have you started working on
boring-cyborg[bot] commented on PR #145:
URL:
https://github.com/apache/flink-connector-jdbc/pull/145#issuecomment-2409862571
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
1996fanrui merged PR #145:
URL: https://github.com/apache/flink-connector-jdbc/pull/145
--
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.
FangYongs commented on code in PR #25440:
URL: https://github.com/apache/flink/pull/25440#discussion_r1798667849
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/lineage/DefaultLineageGraph.java:
##
@@ -33,14 +33,15 @@
@Internal
public class DefaultLineageGraph im
RocMarshal commented on code in PR #25174:
URL: https://github.com/apache/flink/pull/25174#discussion_r1798242400
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/SlotInfo.java:
##
@@ -54,10 +59,27 @@ public interface SlotInfo {
*/
ResourceProfile get
reswqa opened a new pull request, #25507:
URL: https://github.com/apache/flink/pull/25507
(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, e-mai
HuangZhenQiu commented on code in PR #25440:
URL: https://github.com/apache/flink/pull/25440#discussion_r1798694472
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/lineage/DefaultLineageGraph.java:
##
@@ -33,14 +33,15 @@
@Internal
public class DefaultLineageGraph
SamBarker opened a new pull request, #900:
URL: https://github.com/apache/flink-kubernetes-operator/pull/900
## What is the purpose of the change
The original FLINK-36332 missed a transitive dependency on
`kubernetes-httpclient-okhttp` via the flink-kubernetes-operatpr-api whi
flinkbot commented on PR #25507:
URL: https://github.com/apache/flink/pull/25507#issuecomment-2409845764
## CI report:
* b8a109c1bbcaad79dade2e1305ce27ada927ff1a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia commented on code in PR #25503:
URL: https://github.com/apache/flink/pull/25503#discussion_r1798745285
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/AbstractAsyncStateStreamOperator.java:
##
@@ -345,6 +365,56 @@ public void processWater
leonardBang merged PR #3640:
URL: https://github.com/apache/flink-cdc/pull/3640
--
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-36151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36151.
Resolution: Resolved
> Add documentations for Schema Evolution related options
> -
[
https://issues.apache.org/jira/browse/FLINK-36151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1798#comment-1798
]
Leonard Xu edited comment on FLINK-36151 at 10/14/24 6:03 AM:
[
https://issues.apache.org/jira/browse/FLINK-33391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33391:
---
Assignee: RocMarshal (was: Rui Fan)
> Support tasks balancing at TM level for Adaptive Scheduler
>
[
https://issues.apache.org/jira/browse/FLINK-33390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33390:
---
Assignee: RocMarshal (was: Rui Fan)
> Support slot balancing at TM level for Adaptive Scheduler
>
[
https://issues.apache.org/jira/browse/FLINK-33389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33389:
---
Assignee: RocMarshal (was: Rui Fan)
> Support tasks balancing at slot level for Adaptive Scheduler
ruanwenjun commented on PR #25505:
URL: https://github.com/apache/flink/pull/25505#issuecomment-2410110836
> To be honest, I didn't realize there was going to be something unexpected
here.
>
> If all source are bounded, flink does not require that the job be executed
in batch mode. I
reswqa merged PR #25379:
URL: https://github.com/apache/flink/pull/25379
--
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-36350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-36350.
Fix Version/s: 2.0.0
Resolution: Fixed
master(2.0) via d6cb8b39aa7818449934d53e1c4c7d4c7dea
yunfengzhou-hub commented on code in PR #25503:
URL: https://github.com/apache/flink/pull/25503#discussion_r1798675305
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/AbstractAsyncStateStreamOperator.java:
##
Review Comment:
Shall we add so
melin created FLINK-36524:
-
Summary: upgrade paimon 0.9.0
Key: FLINK-36524
URL: https://issues.apache.org/jira/browse/FLINK-36524
Project: Flink
Issue Type: Improvement
Components: Flink CD
[
https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889083#comment-17889083
]
Kartik Goyal commented on FLINK-36476:
--
Hi [~xuyangzhong], can I take few of the su
1996fanrui merged PR #872:
URL: https://github.com/apache/flink-kubernetes-operator/pull/872
--
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-unsu
caicancai commented on PR #145:
URL:
https://github.com/apache/flink-connector-jdbc/pull/145#issuecomment-2409702762
@1996fanrui PTAL, 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
[
https://issues.apache.org/jira/browse/FLINK-36426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-36426:
---
Description:
as discussed in
[https://github.com/apache/flink/pull/25218#discussion_r1771187666]
j
wuzexian created FLINK-36525:
Summary: Support for AI Model Integration for Data Processing
Key: FLINK-36525
URL: https://issues.apache.org/jira/browse/FLINK-36525
Project: Flink
Issue Type: Impr
proletarians opened a new pull request, #3642:
URL: https://github.com/apache/flink-cdc/pull/3642
The goal is to extend flink-cdc with the capability to invoke AI models
during the data stream processing workflow, with a particular focus on
supporting array data structures. This feature wil
[
https://issues.apache.org/jira/browse/FLINK-36525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36525:
---
Labels: pull-request-available (was: )
> Support for AI Model Integration for Data Processi
reswqa commented on PR #25507:
URL: https://github.com/apache/flink/pull/25507#issuecomment-2409873171
Because this did not touch any production and test code, merged it to
unblock rc vote.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
reswqa merged PR #25507:
URL: https://github.com/apache/flink/pull/25507
--
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
hadoopkandy commented on PR #3630:
URL: https://github.com/apache/flink-cdc/pull/3630#issuecomment-2409878576
I test this PR, it can indeed solve the problem of cdc EOFException in our
production Mysql.
--
This is an automated message from the Apache Git Service.
To respond to the message
lvyanquan commented on PR #3630:
URL: https://github.com/apache/flink-cdc/pull/3630#issuecomment-2409895178
> method getExecutorService() is not found in binlogReader, method
BinlogSplitReader#getExecutorService should commit
Addressed.
--
This is an automated message from the Apac
yunfengzhou-hub commented on code in PR #25501:
URL: https://github.com/apache/flink/pull/25501#discussion_r1798718504
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/AbstractKeyedStateTestBase.java:
##
@@ -128,6 +133,18 @@ public boolean supportsAsyncKeyedState
fredia commented on code in PR #25503:
URL: https://github.com/apache/flink/pull/25503#discussion_r1798728216
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/AbstractAsyncStateStreamOperator.java:
##
Review Comment:
Thanks for the suggestio
xuyangzhong commented on code in PR #25418:
URL: https://github.com/apache/flink/pull/25418#discussion_r1798730266
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ExprCodeGenerator.scala:
##
@@ -679,13 +679,15 @@ class ExprCodeGenerator(c
Zakelly commented on PR #25479:
URL: https://github.com/apache/flink/pull/25479#issuecomment-2409871174
@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.
69 matches
Mail list logo
