[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838471#comment-17838471
]
Muhammet Orazov commented on FLINK-34508:
-
The
yuxiqian commented on PR #3235:
URL: https://github.com/apache/flink-cdc/pull/3235#issuecomment-2063041386
cc @lvyanquan
--
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-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-35027:
--
Assignee: Yanfei Lei
> Implement checkpoint drain in AsyncExecutionController
>
[
https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-35026:
--
Assignee: Yanfei Lei
> Introduce async execution configurations
>
flinkbot commented on PR #24676:
URL: https://github.com/apache/flink/pull/24676#issuecomment-2062993344
## CI report:
* bc18939af1ffea146d6f2214d061cca4dc136ca6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35027:
---
Labels: pull-request-available (was: )
> Implement checkpoint drain in
fredia opened a new pull request, #24676:
URL: https://github.com/apache/flink/pull/24676
## What is the purpose of the change
This PR implements checkpoint drain in `AsyncExecutionController`, and
wires it to
[
https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838452#comment-17838452
]
Xin Gong edited comment on FLINK-35151 at 4/18/24 4:46 AM:
---
I get an idea to
[
https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838452#comment-17838452
]
Xin Gong edited comment on FLINK-35151 at 4/18/24 4:44 AM:
---
I get an idea to
[
https://issues.apache.org/jira/browse/FLINK-33460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33460:
---
Labels: pull-request-available (was: )
> Support property authentication connection.
>
RocMarshal opened a new pull request, #115:
URL: https://github.com/apache/flink-connector-jdbc/pull/115
- Support property authentication connection.
--
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-33460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33460:
---
Summary: Support property authentication connection. (was: Support more
authentication connection
[
https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838452#comment-17838452
]
Xin Gong edited comment on FLINK-35151 at 4/18/24 4:43 AM:
---
I get an idea to
[
https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838452#comment-17838452
]
Xin Gong commented on FLINK-35151:
--
I get an idea to address this issue by set
currentTaskRunning ||
[
https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Gong updated FLINK-35151:
-
Description:
Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is
full.
[
https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Gong updated FLINK-35151:
-
Description:
Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is
full.
Xin Gong created FLINK-35151:
Summary: Flink mysql cdc will stuck when suspend binlog split and
ChangeEventQueue is full
Key: FLINK-35151
URL: https://issues.apache.org/jira/browse/FLINK-35151
Project:
[
https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Gong updated FLINK-35151:
-
Environment: I use master branch reproduce it. (was: I use master branch
reproduce it.
Reason is that
Zakelly commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1569904139
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/KeyAccountingUnit.java:
##
@@ -32,6 +32,8 @@
*/
public class KeyAccountingUnit {
+
yuxiqian closed pull request #3235: [hotfix][values] Temporary fix for
ValuesDataSource stuck in infinite…
URL: https://github.com/apache/flink-cdc/pull/3235
--
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
yuxiqian opened a new pull request, #3235:
URL: https://github.com/apache/flink-cdc/pull/3235
… loop
--
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,
yunfengzhou-hub commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1569902836
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java:
##
@@ -117,6 +120,7 @@ public class
Zakelly commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1569850955
##
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java:
##
@@ -140,4 +144,43 @@ public void skipFully(long
[
https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
qyw updated FLINK-35150:
Attachment: (was: image-2024-04-18-11-20-43-126.png)
> The specified upload does not exist. The upload ID may
[
https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
qyw updated FLINK-35150:
Description:
Flink S3 hadoop, write S3 in csv mode, I used this patch FLINK-28513 . But I
don't understand
[
https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
qyw updated FLINK-35150:
Description:
Flink S3 hadoop, write S3 in csv mode, I used this patch FLINK-28513 . But I
don't understand
[
https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
qyw updated FLINK-35150:
Attachment: image-2024-04-18-11-20-43-126.png
> The specified upload does not exist. The upload ID may be invalid
[
https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
qyw updated FLINK-35150:
Attachment: image-2024-04-18-11-20-25-583.png
> The specified upload does not exist. The upload ID may be invalid
[
https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
qyw updated FLINK-35150:
Attachment: (was: image-2024-04-18-11-07-15-555.png)
> The specified upload does not exist. The upload ID may
[
https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
qyw updated FLINK-35150:
Description:
Flink S3 hadoop, write S3 in csv mode, I used this patch FLINK-28513 . But I
don't understand
qyw created FLINK-35150:
---
Summary: The specified upload does not exist. The upload ID may be
invalid
Key: FLINK-35150
URL: https://issues.apache.org/jira/browse/FLINK-35150
Project: Flink
Issue Type:
fredia commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1569864750
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -181,4 +182,73 @@ public class ExecutionOptions {
fredia commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1569863724
##
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##
@@ -1085,6 +1085,54 @@ public void setUseSnapshotCompression(boolean
morazow commented on code in PR #3230:
URL: https://github.com/apache/flink-cdc/pull/3230#discussion_r1569863282
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java:
##
@@ -163,10
morazow commented on code in PR #3230:
URL: https://github.com/apache/flink-cdc/pull/3230#discussion_r1569850914
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java:
##
@@ -163,10
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2062885502
@LadyForest Hi, Could you please take a review? thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-35149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35149:
---
Labels: pull-request-available (was: )
> Fix DataSinkTranslator#sinkTo ignoring pre-write
loserwang1024 commented on PR #3233:
URL: https://github.com/apache/flink-cdc/pull/3233#issuecomment-2062883633
@PatrickRen , CC
--
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
loserwang1024 opened a new pull request, #3233:
URL: https://github.com/apache/flink-cdc/pull/3233
Current , when sink is not instanceof TwoPhaseCommittingSink, use
input.transform rather than stream. It means that pre-write topology will be
ignored.
```
private void sinkTo(
[
https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-34633.
---
Resolution: Fixed
> Support unnesting array constants
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-34633.
-
> Support unnesting array constants
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838429#comment-17838429
]
Jane Chan commented on FLINK-34633:
---
Fixed in master 43a3d50ce3982b9abf04b81407fed46c5c25f819
>
[
https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-34633:
--
Fix Version/s: 1.19.1
> Support unnesting array constants
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-35143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838428#comment-17838428
]
Hongshun Wang commented on FLINK-35143:
---
I'd like to do it
> Expose newly added tables capture in
[
https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838427#comment-17838427
]
Muhammet Orazov commented on FLINK-35129:
-
Hey [~loserwang1024] , I would be happy to work on
LadyForest merged PR #24510:
URL: https://github.com/apache/flink/pull/24510
--
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:
Hongshun Wang created FLINK-35149:
-
Summary: Fix DataSinkTranslator#sinkTo ignoring pre-write topology
if not TwoPhaseCommittingSink
Key: FLINK-35149
URL: https://issues.apache.org/jira/browse/FLINK-35149
GOODBOY008 commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2062859948
@ZmmBigdata @Jiabao-Sun Issue was fixed in pr
https://github.com/apache/flink-cdc/pull/3217 and merged.
--
This is an automated message from the Apache Git Service.
To respond to
xuyangzhong commented on PR #24280:
URL: https://github.com/apache/flink/pull/24280#issuecomment-2062858561
Thanks very much for the bp @snuyanzin
--
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
[
https://issues.apache.org/jira/browse/FLINK-35081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838424#comment-17838424
]
xuyang commented on FLINK-35081:
I think this bug is same with FLINK-28693
> CompileException when
[
https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838422#comment-17838422
]
Hongshun Wang commented on FLINK-35144:
---
You mean that sync multiple sources to same sink?
>
loserwang1024 commented on code in PR #3230:
URL: https://github.com/apache/flink-cdc/pull/3230#discussion_r1569794515
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java:
##
@@
Jiabao-Sun commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2062840911
Thanks @ZmmBigdata for this contribution.
Could you rebase master and resolve conflicts?
--
This is an automated message from the Apache Git Service.
To respond to the message,
yunfengzhou-hub commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1569768663
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -94,19 +103,26 @@ public class
yunfengzhou-hub commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1569768663
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -94,19 +103,26 @@ public class
reswqa commented on PR #24541:
URL: https://github.com/apache/flink/pull/24541#issuecomment-2062837816
@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.
[
https://issues.apache.org/jira/browse/FLINK-34738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun reassigned FLINK-34738:
--
Assignee: Vincent Woo
> "Deployment - YARN" Page for Flink CDC Chinese Documentation
>
Jiabao-Sun merged PR #3223:
URL: https://github.com/apache/flink-cdc/pull/3223
--
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:
Jiabao-Sun merged PR #3217:
URL: https://github.com/apache/flink-cdc/pull/3217
--
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:
flinkbot commented on PR #24675:
URL: https://github.com/apache/flink/pull/24675#issuecomment-2062593439
## CI report:
* fc79b8051c60e2628b2098e82bc945f79b08a3d3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuml07 commented on PR #24675:
URL: https://github.com/apache/flink/pull/24675#issuecomment-2062592367
@snuyanzin could you take a look? 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
liuml07 opened a new pull request, #24675:
URL: https://github.com/apache/flink/pull/24675
…blic constructor
## What is the purpose of the change
https://issues.apache.org/jira/browse/FLINK-35148
InstantiationUtil#hasPublicNullaryConstructor checks whether the
[
https://issues.apache.org/jira/browse/FLINK-35148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35148:
---
Labels: pull-request-available (was: )
> Improve InstantiationUtil for checking nullary
Mingliang Liu created FLINK-35148:
-
Summary: Improve InstantiationUtil for checking nullary public
constructor
Key: FLINK-35148
URL: https://issues.apache.org/jira/browse/FLINK-35148
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharon Xie updated FLINK-35147:
---
Description:
When a field type in the output table is changed from int -> bigint or
timestamp(3)
[
https://issues.apache.org/jira/browse/FLINK-35147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharon Xie updated FLINK-35147:
---
Description:
When a field type in the output table is changed from int -> bigint or
timestamp(3)
[
https://issues.apache.org/jira/browse/FLINK-35147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharon Xie updated FLINK-35147:
---
Description:
When a field type in the output table is changed from int -> bigint or
timestamp(3)
Sharon Xie created FLINK-35147:
--
Summary: SinkMaterializer throws StateMigrationException when
widening the field type in the output table
Key: FLINK-35147
URL: https://issues.apache.org/jira/browse/FLINK-35147
jiangzho commented on PR #817:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/817#issuecomment-2062344434
Thanks @gyfora for quick turnaround !
The commit has been updated with style fix. This patch is validated via
minikube setup.
--
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838379#comment-17838379
]
Xingcan Cui commented on FLINK-34583:
-
Hi [~xuyangzhong], thanks for looking into this. I hit the
[
https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-34583:
Attachment: image-2024-04-17-16-48-49-073.png
> Bug for dynamic table option hints with multiple
[
https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-34583:
Attachment: image-2024-04-17-16-35-06-153.png
> Bug for dynamic table option hints with multiple
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838358#comment-17838358
]
Aleksandr Pilipenko commented on FLINK-35115:
-
snapshotState method in FlinkKinesisConsumer
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838358#comment-17838358
]
Aleksandr Pilipenko edited comment on FLINK-35115 at 4/17/24 7:01 PM:
jiangzho opened a new pull request, #817:
URL: https://github.com/apache/flink-kubernetes-operator/pull/817
## What is the purpose of the change
This patch is to tackle the corner case where `cleanup` of CustomResource is
constantly failing due to event publish failure, and
jeyhunkarimov commented on PR #23470:
URL: https://github.com/apache/flink/pull/23470#issuecomment-2061766848
Thanks a lot @xuyangzhong for your review. I addressed your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
z3d1k commented on PR #138:
URL:
https://github.com/apache/flink-connector-aws/pull/138#issuecomment-2061752988
@dannycranmer, @hlteoh37 please take 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
z3d1k opened a new pull request, #138:
URL: https://github.com/apache/flink-connector-aws/pull/138
## Purpose of the change
Perform snapshot state even after source operator had been cancelled.
This solves the issue when operator state is not being saved during
stor-with-savepoint
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35115:
---
Labels: kinesis pull-request-available (was: kinesis)
> Kinesis connector writes wrong
mbalassi merged PR #816:
URL: https://github.com/apache/flink-kubernetes-operator/pull/816
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838277#comment-17838277
]
Etienne Chauchot commented on FLINK-35124:
--
It was failing on cassandra before the _utils.sh
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838277#comment-17838277
]
Etienne Chauchot edited comment on FLINK-35124 at 4/17/24 4:21 PM:
---
It
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838238#comment-17838238
]
Ryan Skraba commented on FLINK-35041:
-
1.20 test_ci_core
[
https://issues.apache.org/jira/browse/FLINK-35146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated FLINK-35146:
Labels: test-stability (was: )
> CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan
>
Ryan Skraba created FLINK-35146:
---
Summary:
CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan
Key: FLINK-35146
URL: https://issues.apache.org/jira/browse/FLINK-35146
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838235#comment-17838235
]
Ryan Skraba commented on FLINK-33186:
-
1.20 test_cron_hadoop313
[
https://issues.apache.org/jira/browse/FLINK-31421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838234#comment-17838234
]
Ryan Skraba commented on FLINK-31421:
-
1.19 Hadoop 3.1.3: Test (module: misc)
[
https://issues.apache.org/jira/browse/FLINK-34644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838232#comment-17838232
]
Ryan Skraba commented on FLINK-34644:
-
1.20 Java 21: Test (module: core)
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838233#comment-17838233
]
Ryan Skraba commented on FLINK-35041:
-
1.20 Java 8: Test (module: core)
[
https://issues.apache.org/jira/browse/FLINK-34646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838231#comment-17838231
]
Ryan Skraba commented on FLINK-34646:
-
1.18 AdaptiveScheduler: Test (module: table)
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35115:
--
Affects Version/s: aws-connector-4.2.0
aws-connector-4.1.0
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35115:
--
Fix Version/s: aws-connector-4.3.0
(was: aws-connector-4.2.0)
>
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35115:
--
Fix Version/s: aws-connector-4.2.0
> Kinesis connector writes wrong Kinesis sequence number
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35115:
--
Affects Version/s: 1.17.2
1.15.4
> Kinesis connector writes wrong
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35115:
--
Priority: Blocker (was: Major)
> Kinesis connector writes wrong Kinesis sequence number at
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838224#comment-17838224
]
Danny Cranmer commented on FLINK-35124:
---
Actually I still think this is the issue, since it runs
[
https://issues.apache.org/jira/browse/FLINK-35125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu reassigned FLINK-35125:
Assignee: Jinzhong Li
> Implement ValueState for ForStStateBackend
>
[
https://issues.apache.org/jira/browse/FLINK-34987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-34987.
--
Fix Version/s: 1.20.0
Resolution: Fixed
merged 7699a0d2...2c5078bc into master
>
[
https://issues.apache.org/jira/browse/FLINK-33394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838223#comment-17838223
]
Ryan Skraba commented on FLINK-33394:
-
This should be closed as a duplicate of FLINK-31421 (Weirdly
masteryhx closed pull request #24651: [FLINK-34987][state] Introduce Internal
State for Async State API
URL: https://github.com/apache/flink/pull/24651
--
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
1 - 100 of 244 matches
Mail list logo
