yuxiqian commented on PR #3285:
URL: https://github.com/apache/flink-cdc/pull/3285#issuecomment-2275084939
Rebased to latest `master`.
--
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
[
https://issues.apache.org/jira/browse/FLINK-35432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871875#comment-17871875
]
Ruan Hang commented on FLINK-35432:
---
fix via master(3.2-SNAPSHOT): 21fade0e22155b82fa9
[
https://issues.apache.org/jira/browse/FLINK-35432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-35432.
---
Resolution: Fixed
> Support catch modify-event for mysql-cdc
> -
[
https://issues.apache.org/jira/browse/FLINK-35432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35432:
--
Fix Version/s: cdc-3.2.0
> Support catch modify-event for mysql-cdc
>
宇宙先生 created FLINK-36005:
Summary: Specify to get part of the potgresql field
Key: FLINK-36005
URL: https://issues.apache.org/jira/browse/FLINK-36005
Project: Flink
Issue Type: Bug
Compone
dylanhz commented on code in PR #25163:
URL: https://github.com/apache/flink/pull/25163#discussion_r1708747561
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/EltFunction.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache So
ruanhang1993 merged PR #3352:
URL: https://github.com/apache/flink-cdc/pull/3352
--
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...@flin
ruanhang1993 commented on PR #3511:
URL: https://github.com/apache/flink-cdc/pull/3511#issuecomment-2275045480
> Seems Flink TIMESTAMP has a range limit from -01-01 00:00:00.0
to -12-31 23:59:59.9[1]. According to current binary encoding
format, the millisecond part
jnh5y commented on PR #25170:
URL: https://github.com/apache/flink/pull/25170#issuecomment-2275042683
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871869#comment-17871869
]
Zakelly Lan commented on FLINK-34510:
-
[~spoon-lz] Yes, we could start this now.
>
[
https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871867#comment-17871867
]
liuzhuo edited comment on FLINK-34510 at 8/8/24 6:12 AM:
-
Hi [~z
[
https://issues.apache.org/jira/browse/FLINK-35987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871868#comment-17871868
]
Dylan He edited comment on FLINK-35987 at 8/8/24 6:12 AM:
--
[~li
[
https://issues.apache.org/jira/browse/FLINK-35987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871868#comment-17871868
]
Dylan He commented on FLINK-35987:
--
[~lincoln.86xy] How can we check values like negat
[
https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871867#comment-17871867
]
liuzhuo commented on FLINK-34510:
-
Hi [~zakelly] ,1.20 has been released, can we start t
[
https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871864#comment-17871864
]
Xingcan Cui commented on FLINK-36004:
-
Flink version: 1.18.1 and 1.19.1
Paimon vers
Xingcan Cui created FLINK-36004:
---
Summary: Flink SQL returns wrong results for Paimon tables with
complex schemas
Key: FLINK-36004
URL: https://issues.apache.org/jira/browse/FLINK-36004
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35242:
---
Affects Version/s: cdc-3.1.1
> Add per-type schema evolution behavior configuration
> --
[
https://issues.apache.org/jira/browse/FLINK-35242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35242.
Resolution: Implemented
Implemented in master: 5ed9e05bdf00ae8b6e2df622e5e790a67335aa9d
> Add per
leonardBang merged PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339
--
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
lvyanquan commented on PR #3461:
URL: https://github.com/apache/flink-cdc/pull/3461#issuecomment-2274996291
Done rebase.
--
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
[
https://issues.apache.org/jira/browse/FLINK-35935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871856#comment-17871856
]
Xingcan Cui edited comment on FLINK-35935 at 8/8/24 5:39 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871856#comment-17871856
]
Xingcan Cui commented on FLINK-35935:
-
hi [~xuyangzhong] , it looks like this doesn'
[
https://issues.apache.org/jira/browse/FLINK-35385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871855#comment-17871855
]
xuhaiLong edited comment on FLINK-35385 at 8/8/24 5:27 AM:
---
Is
[
https://issues.apache.org/jira/browse/FLINK-35385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871855#comment-17871855
]
xuhaiLong commented on FLINK-35385:
---
Can I upgrade flink to 1.20? Because he's an LTS.
dylanhz closed pull request #25175: [FLINK-35993][table] Add the built-in
function UNHEX
URL: https://github.com/apache/flink/pull/25175
--
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 #25175:
URL: https://github.com/apache/flink/pull/25175#issuecomment-2274905586
## CI report:
* 33d6062cc332d0ebb25adc9e55c92b9e0a0206f9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan He updated FLINK-35993:
-
Description:
Add UNHEX function.
Converts hexadecimal {{expr}} to BINARY.
Example:
{code:sql}
> SE
[
https://issues.apache.org/jira/browse/FLINK-35615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35615:
---
Labels: pull-request-available (was: )
> CDC3.0, the pipeline of mysql-doris , do not supp
yuxiqian commented on PR #3446:
URL: https://github.com/apache/flink-cdc/pull/3446#issuecomment-2274903614
Addressed in #3511.
--
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
[
https://issues.apache.org/jira/browse/FLINK-35993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35993:
---
Labels: pull-request-available (was: )
> Add UNHEX function
> --
>
>
yuxiqian closed pull request #3446: [FLINK-35615][base] Add a workaround for
timestamp binary en/decoding failure with precisions mismatch
URL: https://github.com/apache/flink-cdc/pull/3446
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
dylanhz opened a new pull request, #25175:
URL: https://github.com/apache/flink/pull/25175
## What is the purpose of the change
Add the built-in function UNHEX.
Examples:
```SQL
> SELECT DECODE(UNHEX('466C696E6B'), 'UTF-8');
Flink
```
## Brief change log
-
anupamaggarwal commented on PR #24967:
URL: https://github.com/apache/flink/pull/24967#issuecomment-2274886204
Thanks @snuyanzin I merged the latest from master and the build is passing
now (It seems CI is a bit flaky since one of the runs post merge failed but the
second went through). The
leonardBang commented on code in PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1708522172
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/event/ApplyOriginalSchemaChangeRequest.java:
##
@@ -0,0 +1,71 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35968:
---
Issue Type: Technical Debt (was: Improvement)
> Remove flink-cdc-runtime depedency from connectors
[
https://issues.apache.org/jira/browse/FLINK-35987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871835#comment-17871835
]
lincoln lee commented on FLINK-35987:
-
[~dylanhz] I propose some adjustments to the
[
https://issues.apache.org/jira/browse/FLINK-33747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871828#comment-17871828
]
Min Zhao commented on FLINK-33747:
--
Hello, is this work still going on? I'm interested
lincoln-lil commented on code in PR #25163:
URL: https://github.com/apache/flink/pull/25163#discussion_r1708428976
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/EltFunction.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-35910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-35910.
---
Resolution: Fixed
> Add BTRIM function
> --
>
> Key: FLINK-35910
>
[
https://issues.apache.org/jira/browse/FLINK-35910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871827#comment-17871827
]
dalongliu commented on FLINK-35910:
---
Merged in master: 72ebee2eb45f598ebd88422f716ae6d
[
https://issues.apache.org/jira/browse/FLINK-35910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35910:
--
Fix Version/s: 2.0.0
> Add BTRIM function
> --
>
> Key: FLINK-35910
>
lsyldliu merged PR #25127:
URL: https://github.com/apache/flink/pull/25127
--
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
flinkbot commented on PR #25174:
URL: https://github.com/apache/flink/pull/25174#issuecomment-2274819717
## CI report:
* 91e9f3542d260e4c53ef03e4c126432f7ba71cd0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35968:
---
Labels: pull-request-available (was: )
> Remove flink-cdc-runtime depedency from connectors
loserwang1024 commented on PR #3517:
URL: https://github.com/apache/flink-cdc/pull/3517#issuecomment-2274805154
@leonardBang @ruanhang1993 @Jiabao-Sun @GOODBOY008 , CC
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
loserwang1024 opened a new pull request, #3517:
URL: https://github.com/apache/flink-cdc/pull/3517
Current, flink-cdc-source-connectors depends on flink-cdc-runtime, which is
not ideal for design and is redundant.
This issue is aimed to remove it.
--
This is an automated message f
[
https://issues.apache.org/jira/browse/FLINK-33387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33387:
---
Labels: pull-request-available (was: )
> Introduce the abstraction and the interface about
RocMarshal opened a new pull request, #25174:
URL: https://github.com/apache/flink/pull/25174
## What is the purpose of the change
Introduce the abstraction and the interface about loading
Support tasks balancing at TaskExecutor level for Default Scheduler without
public
dylanhz commented on code in PR #25138:
URL: https://github.com/apache/flink/pull/25138#discussion_r1708399485
##
flink-test-utils-parent/flink-test-utils/src/test/java/org/apache/flink/types/PojoTestUtilsTest.java:
##
@@ -64,4 +72,20 @@ public static class Pojo {
public st
yuxiqian commented on code in PR #3455:
URL: https://github.com/apache/flink-cdc/pull/3455#discussion_r1708380132
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerITCase.java:
##
@@ -332,8 +332,8 @@ void testTransform(ValuesDataSink.Si
yuxiqian commented on code in PR #3455:
URL: https://github.com/apache/flink-cdc/pull/3455#discussion_r1708380132
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerITCase.java:
##
@@ -332,8 +332,8 @@ void testTransform(ValuesDataSink.Si
[
https://issues.apache.org/jira/browse/FLINK-33875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33875.
-
Fix Version/s: 2.0.0
Resolution: Fixed
Merged to master(2.0.0) via : d033f64b41f1d11edd22b2d70699
yuxiqian commented on code in PR #3455:
URL: https://github.com/apache/flink-cdc/pull/3455#discussion_r1708376615
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerITCase.java:
##
@@ -399,8 +399,8 @@ void testTransformTwice(ValuesDataSi
yuxiqian commented on code in PR #3455:
URL: https://github.com/apache/flink-cdc/pull/3455#discussion_r1708376615
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerITCase.java:
##
@@ -399,8 +399,8 @@ void testTransformTwice(ValuesDataSi
1996fanrui merged PR #25134:
URL: https://github.com/apache/flink/pull/25134
--
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.ap
flinkbot commented on PR #25173:
URL: https://github.com/apache/flink/pull/25173#issuecomment-2274760811
## CI report:
* e288f20a4206bc15bd2cf478370374d6bf0858ac UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25172:
URL: https://github.com/apache/flink/pull/25172#issuecomment-2274760089
## CI report:
* a7eee2242fa34ed29196d26aa5cf2cb68f7518a1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-35987:
---
Assignee: Dylan He
> Add ELT function
>
>
> Key: FLINK-359
aiwenmo commented on PR #3444:
URL: https://github.com/apache/flink-cdc/pull/3444#issuecomment-2274749212
I will rebase it onto master.
--
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 specifi
lincoln-lil opened a new pull request, #25173:
URL: https://github.com/apache/flink/pull/25173
This is a backport pr for 1.19.
--
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
lincoln-lil opened a new pull request, #25172:
URL: https://github.com/apache/flink/pull/25172
This is a backport pr for 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
URL above to go to the specific comment
[
https://issues.apache.org/jira/browse/FLINK-36000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-36000:
Fix Version/s: 1.19.2
1.20.1
> DynamicTableSink#Context's getTargetColumns shou
lincoln-lil merged PR #25165:
URL: https://github.com/apache/flink/pull/25165
--
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
flinkbot commented on PR #25170:
URL: https://github.com/apache/flink/pull/25170#issuecomment-2274408761
## CI report:
* c3d963347c01e1608e96fac9e2c64607105c8c8e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25168:
URL: https://github.com/apache/flink/pull/25168#issuecomment-2274408300
## CI report:
* 54ad77f1487f8603009d28098fe4b74765cc441e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25171:
URL: https://github.com/apache/flink/pull/25171#issuecomment-2274408966
## CI report:
* 5689c2b9d1352c5bd9655f1df817bffc6d4b4876 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25169:
URL: https://github.com/apache/flink/pull/25169#issuecomment-2274408520
## CI report:
* c66b0de31dd2e31dde17d585a86665569c226f01 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35944:
---
Labels: pull-request-available (was: )
> Add CompiledPlan annotations to BatchExecUnion
> -
jnh5y opened a new pull request, #25171:
URL: https://github.com/apache/flink/pull/25171
## What is the purpose of the change
* Adds Compiled Plan annotations to BatchExecMatch.
* Tests the new annotations with the existing TestPrograms.
## Verifying this change
This c
jnh5y opened a new pull request, #25170:
URL: https://github.com/apache/flink/pull/25170
## What is the purpose of the change
* Adds Compiled Plan annotations to BatchExecUnion.
* Tests the new annotations with the existing TestPrograms.
## Verifying this change
This c
[
https://issues.apache.org/jira/browse/FLINK-36002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36002:
---
Labels: pull-request-available (was: )
> Add CompiledPlan annotations to BatchExecMatch
> -
jnh5y commented on code in PR #25169:
URL: https://github.com/apache/flink/pull/25169#discussion_r1707967812
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/batch/JoinBatchRestoreTest.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-35943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35943:
---
Labels: pull-request-available (was: )
> Add CompiledPlan annotations to BatchExecHashJoin
jnh5y opened a new pull request, #25169:
URL: https://github.com/apache/flink/pull/25169
## What is the purpose of the change
* Adds Compiled Plan annotations to BatchExecHashJoin and
BatchExecNestedLoopJoin.
* Tests the new annotations with the existing TestPrograms.
## Ver
[
https://issues.apache.org/jira/browse/FLINK-35941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35941:
---
Labels: pull-request-available (was: )
> Add CompiledPlan annotations to BatchExecLimit
> -
jnh5y opened a new pull request, #25168:
URL: https://github.com/apache/flink/pull/25168
## What is the purpose of the change
* Adds Compiled Plan annotations to BatchExecLimit.
* Tests the new annotations with the existing TestPrograms.
## Verifying this change
This c
Jim Hughes created FLINK-36003:
--
Summary: Add CompiledPlan annotations to BatchExecExpand and
BatchExecSortAggregate
Key: FLINK-36003
URL: https://issues.apache.org/jira/browse/FLINK-36003
Project: Flink
Jim Hughes created FLINK-36002:
--
Summary: Add CompiledPlan annotations to BatchExecMatch
Key: FLINK-36002
URL: https://issues.apache.org/jira/browse/FLINK-36002
Project: Flink
Issue Type: Sub-ta
19priyadhingra commented on PR #141:
URL:
https://github.com/apache/flink-connector-aws/pull/141#issuecomment-2273989296
@hlteoh37 All workflows passed in last trigger. is there any other blocker
in merging this? Thanks!
--
This is an automated message from the Apache Git Service.
To res
anupamaggarwal commented on PR #24967:
URL: https://github.com/apache/flink/pull/24967#issuecomment-2273960780
@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-35942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-35942:
-
Component/s: Table SQL / Planner
> Add CompiledPlan annotations to BatchExecCorrelate
>
[
https://issues.apache.org/jira/browse/FLINK-35942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-35942.
Fix Version/s: 2.0.0
Resolution: Fixed
Fixed in master: 783150aa9abc9b26f06db04b6807d0a57ae
twalthr merged PR #25162:
URL: https://github.com/apache/flink/pull/25162
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apach
leonardBang commented on code in PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1707234423
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/exceptions/SchemaEvolveException.java:
##
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software F
[
https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-35885:
Fix Version/s: 1.20.1
1.19.2
> proctime aggregate window triggered by watermark
[
https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871704#comment-17871704
]
lincoln lee commented on FLINK-35885:
-
[~xuyangzhong] Could you also do the backport
[
https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee resolved FLINK-35885.
-
Resolution: Fixed
Fixed in master: b3b709f46ca7b12d9a26192a60cdde790d8523b9
> proctime aggregat
[
https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-35885:
Fix Version/s: 2.0.0
> proctime aggregate window triggered by watermark
>
lincoln-lil merged PR #25119:
URL: https://github.com/apache/flink/pull/25119
--
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
leonardBang commented on code in PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1706988311
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/exceptions/SchemaEvolveException.java:
##
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software F
flinkbot commented on PR #25167:
URL: https://github.com/apache/flink/pull/25167#issuecomment-2273648765
## CI report:
* 2ede821d430e5bdcb148e56dd2815cc39993 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35886:
---
Labels: pull-request-available (was: )
> Incorrect watermark idleness timeout accounting wh
pnowojski opened a new pull request, #25167:
URL: https://github.com/apache/flink/pull/25167
## What is the purpose of the change
https://cwiki.apache.org/confluence/x/oQvOEg
This fixes a problem with idleness being incorrectly detected if
subtasks/splits are backpressured or b
lincoln-lil commented on code in PR #25138:
URL: https://github.com/apache/flink/pull/25138#discussion_r1707101343
##
flink-test-utils-parent/flink-test-utils/src/test/java/org/apache/flink/types/PojoTestUtilsTest.java:
##
@@ -64,4 +72,20 @@ public static class Pojo {
publi
[
https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-35969.
-
> Remove deprecated dataset based API from State Processor API
> ---
[
https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871663#comment-17871663
]
Gabor Somogyi commented on FLINK-35969:
---
2c48175 on master
> Remove deprecated da
[
https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-35969.
---
Fix Version/s: 2.0.0
Resolution: Fixed
> Remove deprecated dataset based API from Sta
gaborgsomogyi merged PR #25149:
URL: https://github.com/apache/flink/pull/25149
--
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-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-36001:
-
Assignee: Gabor Somogyi
> Store operator name and UID in state metadata
> -
Gabor Somogyi created FLINK-36001:
-
Summary: Store operator name and UID in state metadata
Key: FLINK-36001
URL: https://issues.apache.org/jira/browse/FLINK-36001
Project: Flink
Issue Type: I
1 - 100 of 164 matches
Mail list logo
