[
https://issues.apache.org/jira/browse/FLINK-32483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879451#comment-17879451
]
Matthias Pohl edited comment on FLINK-32483 at 9/5/24 6:45 AM:
---
Thorne created FLINK-36224:
--
Summary: Add the version mapping between pipeline connectors and
flink
Key: FLINK-36224
URL: https://issues.apache.org/jira/browse/FLINK-36224
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-36223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjf updated FLINK-36223:
Attachment: image-2024-09-05-14-39-07-070.png
> SplitFetcher thread 0 received unexpected exception while polling
[
https://issues.apache.org/jira/browse/FLINK-36223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjf updated FLINK-36223:
Description:
1.SQL Server dynamic table error occurred，The triggering condition is that
after I save the checkpoi
gtk96 commented on code in PR #3575:
URL: https://github.com/apache/flink-cdc/pull/3575#discussion_r1730587567
##
docs/content.zh/docs/core-concept/schema-evolution.md:
##
@@ -0,0 +1,115 @@
+---
+title: "Schema Evolution"
+weight: 7
+type: docs
+aliases:
+ - /core-concept/schem
gtk96 commented on PR #3575:
URL: https://github.com/apache/flink-cdc/pull/3575#issuecomment-2330716899
LGTM !
--
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 unsubscri
[
https://issues.apache.org/jira/browse/FLINK-36223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjf updated FLINK-36223:
Attachment: image-2024-09-05-14-36-12-672.png
> SplitFetcher thread 0 received unexpected exception while polling
[
https://issues.apache.org/jira/browse/FLINK-26821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879442#comment-17879442
]
Robert Metzger commented on FLINK-26821:
I've unassigned Marco, Lorenzo, are you
LvYanquan created FLINK-36222:
-
Summary: Support the use of LLM models for data processing in the
transform module.
Key: FLINK-36222
URL: https://issues.apache.org/jira/browse/FLINK-36222
Project: Flink
xuyangzhong commented on PR #25229:
URL: https://github.com/apache/flink/pull/25229#issuecomment-2330686539
@lincoln-lil Agree with you. I have updated this pr and removed the first
commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
fredia commented on code in PR #24812:
URL: https://github.com/apache/flink/pull/24812#discussion_r1744859290
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBMapEntryIterRequest.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879439#comment-17879439
]
Xintong Song commented on FLINK-36201:
--
Hi [~dmvk], for code changes merged before
[
https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-36201:
-
Fix Version/s: 2.0-preview
(was: 2.0.0)
> StateLocalitySlotAssigner shoul
JunRuiLee commented on PR #25288:
URL: https://github.com/apache/flink/pull/25288#issuecomment-2330639410
@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.
Zakelly commented on code in PR #24812:
URL: https://github.com/apache/flink/pull/24812#discussion_r1744799308
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBGetRequest.java:
##
@@ -45,6 +47,12 @@ public abstract class ForStDBG
fredia commented on code in PR #24812:
URL: https://github.com/apache/flink/pull/24812#discussion_r174481
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBGetRequest.java:
##
@@ -45,6 +47,12 @@ public abstract class ForStDBGe
[
https://issues.apache.org/jira/browse/FLINK-36221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36221:
---
Labels: pull-request-available (was: )
> Add specification about CAST ... AS ... built-in f
yuxiqian opened a new pull request, #3596:
URL: https://github.com/apache/flink-cdc/pull/3596
This closes FLINK-36221.
[FLINK-34877](https://issues.apache.org/jira/browse/FLINK-34877) adds `CAST
... AS ...` syntax in transform expressions, but there's no corresponding
documentations
yux created FLINK-36221:
---
Summary: Add specification about CAST ... AS ... built-in functions
Key: FLINK-36221
URL: https://issues.apache.org/jira/browse/FLINK-36221
Project: Flink
Issue Type: Sub-task
yux created FLINK-36219:
---
Summary: Add Flink compatibility matrix of CDC releases
Key: FLINK-36219
URL: https://issues.apache.org/jira/browse/FLINK-36219
Project: Flink
Issue Type: Sub-task
yuxiqian commented on PR #3594:
URL: https://github.com/apache/flink-cdc/pull/3594#issuecomment-2330513582
cc @leonardBang @lincoln-lil
--
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 specif
Zakelly commented on code in PR #24812:
URL: https://github.com/apache/flink/pull/24812#discussion_r1742988791
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBGetRequest.java:
##
@@ -45,6 +47,12 @@ public abstract class ForStDBG
[
https://issues.apache.org/jira/browse/FLINK-36214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879401#comment-17879401
]
yux commented on FLINK-36214:
-
Seems it was brought in by FLINK-34876, will investigate this
[
https://issues.apache.org/jira/browse/FLINK-29240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879383#comment-17879383
]
Georgios Kousouris commented on FLINK-29240:
Hi [~lsy], do you know if there
[
https://issues.apache.org/jira/browse/FLINK-36191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878475#comment-17878475
]
Sergey Nuyanzin edited comment on FLINK-36191 at 9/4/24 9:57 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36191:
Fix Version/s: 1.19.2
> FsMergingCheckpointStorageLocationTest generates test data not in
[
https://issues.apache.org/jira/browse/FLINK-36191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878475#comment-17878475
]
Sergey Nuyanzin edited comment on FLINK-36191 at 9/4/24 9:17 PM:
-
snuyanzin commented on PR #25278:
URL: https://github.com/apache/flink/pull/25278#issuecomment-2330160555
the reason of failure was the improper base commit, after rebase ci passed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/FLINK-36217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36217:
---
Labels: pull-request-available (was: )
> Remove powermock usage
> --
>
snuyanzin opened a new pull request, #25287:
URL: https://github.com/apache/flink/pull/25287
## What is the purpose of the change
Remove `powermock` from usages
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
[
https://issues.apache.org/jira/browse/FLINK-36217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-36217:
Description:
Most of the tests are either moved to a different repo like connectors or
re
Sergey Nuyanzin created FLINK-36217:
---
Summary: Remove powermock usage
Key: FLINK-36217
URL: https://issues.apache.org/jira/browse/FLINK-36217
Project: Flink
Issue Type: Technical Debt
XComp commented on code in PR #25261:
URL: https://github.com/apache/flink/pull/25261#discussion_r1744113081
##
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala:
##
@@ -70,7 +71,7 @@ class AllWindowedStream[T, W <: Window](javaStr
[
https://issues.apache.org/jira/browse/FLINK-36169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879296#comment-17879296
]
Gang Li commented on FLINK-36169:
-
Thanks for bringing this up.
> Support namespace lev
XComp commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1703278478
##
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/TestingJobManagerRunnerRegistry.java:
##
@@ -188,11 +197,26 @@ public static class Builder {
p
[
https://issues.apache.org/jira/browse/FLINK-36216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879221#comment-17879221
]
Robert Metzger edited comment on FLINK-36216 at 9/4/24 12:48 PM:
-
hlteoh37 merged PR #159:
URL: https://github.com/apache/flink-connector-aws/pull/159
--
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...@
gguptp commented on code in PR #159:
URL:
https://github.com/apache/flink-connector-aws/pull/159#discussion_r1743591005
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java:
##
@@ -194,7 +196,7 @@ S createAwsSyncClient(
final
hlteoh37 commented on code in PR #159:
URL:
https://github.com/apache/flink-connector-aws/pull/159#discussion_r1743584656
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java:
##
@@ -194,7 +196,7 @@ S createAwsSyncClient(
fin
gguptp commented on code in PR #159:
URL:
https://github.com/apache/flink-connector-aws/pull/159#discussion_r1743580734
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java:
##
@@ -207,6 +207,39 @@ S createAwsSyncClient(
hlteoh37 commented on code in PR #159:
URL:
https://github.com/apache/flink-connector-aws/pull/159#discussion_r1743572674
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java:
##
@@ -207,6 +207,39 @@ S createAwsSyncClient(
[
https://issues.apache.org/jira/browse/FLINK-36206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36206:
---
Labels: pull-request-available (was: )
> Support flink-connector-aws-base to allow custom o
gguptp opened a new pull request, #159:
URL: https://github.com/apache/flink-connector-aws/pull/159
## Purpose of the change
Adding support for custom override configuration in AWSClientUtil.java
## Verifying this change
Please make sure both new and modified test
[
https://issues.apache.org/jira/browse/FLINK-36215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-36215.
-
Resolution: Fixed
merged commit
[{{4d847fe}}|https://github.com/apache/flink-connector
[
https://issues.apache.org/jira/browse/FLINK-36195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-36195:
Summary: Generalized retry configuration in flink-connector-base (was:
Migrate DDB Stream
[
https://issues.apache.org/jira/browse/FLINK-36196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-36196.
-
Resolution: Duplicate
https://issues.apache.org/jira/browse/FLINK-36205
> DDB Streams c
[
https://issues.apache.org/jira/browse/FLINK-36196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-36196:
Summary: DDB Streams connector should be able to resolve the stream ARN
from given Table n
[
https://issues.apache.org/jira/browse/FLINK-36215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-36215:
---
Assignee: Abhi Gupta
> Child shards are getting started with LATEST shard iterator
Abhi Gupta created FLINK-36215:
--
Summary: Child shards are getting started with LATEST shard
iterator even when parents are not expired
Key: FLINK-36215
URL: https://issues.apache.org/jira/browse/FLINK-36215
lincoln lee created FLINK-36214:
---
Summary: Error log when building flink-cdc-pipeline-udf-examples
from source code
Key: FLINK-36214
URL: https://issues.apache.org/jira/browse/FLINK-36214
Project: Flink
gguptp opened a new pull request, #158:
URL: https://github.com/apache/flink-connector-aws/pull/158
…lits
## Purpose of the change
Removing dependency on sorting of splits. This also makes sure that if
parent and child come in same describestream call, we get TRIM_HORIZ
[
https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879116#comment-17879116
]
Rui Fan edited comment on FLINK-36201 at 9/4/24 8:34 AM:
-
master
[
https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879136#comment-17879136
]
Rui Fan commented on FLINK-36201:
-
{quote} This makes me wonder whether we should defaul
[
https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879116#comment-17879116
]
David Morávek commented on FLINK-36201:
---
master: 57bc16948bef75cf0fb483efb8bb9959d
[
https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek resolved FLINK-36201.
---
Fix Version/s: 2.0.0
Resolution: Fixed
> StateLocalitySlotAssigner should be only use
55 matches
Mail list logo
