[
https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34962:
---
Labels: easyfix pull-request-available (was: easyfix)
> flink-connector-pulsa starts
[
https://issues.apache.org/jira/browse/FLINK-35055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiqian YU updated FLINK-35055:
--
Summary: Flink CDC connector release contains dependency with incompatible
licenses (was: Flink CDC
[
https://issues.apache.org/jira/browse/FLINK-34997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34997:
---
Description:
{code}
Apr 03 03:12:37
Laffery commented on PR #3208:
URL: https://github.com/apache/flink-cdc/pull/3208#issuecomment-2044144359
> @Laffery Please add `/` before `fig`. And ci will pass.
Thanks for your kind tips, I've finished and hope you review and trigger the
CI again
--
This is an automated
yandufeng created FLINK-35056:
-
Summary: when initial sqlserver table that
Key: FLINK-35056
URL: https://issues.apache.org/jira/browse/FLINK-35056
Project: Flink
Issue Type: Bug
Sergey Nuyanzin created FLINK-35057:
---
Summary: Bump org.apache.commons:commons-compress from 1.25.0 to
1.26.1 for Flink jdbc connector
Key: FLINK-35057
URL: https://issues.apache.org/jira/browse/FLINK-35057
Zakelly commented on PR #24614:
URL: https://github.com/apache/flink/pull/24614#issuecomment-2044191108
Rebased master. Extracting `StateRequestType` with more detailed enum entry
definition.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
boring-cyborg[bot] commented on PR #86:
URL:
https://github.com/apache/flink-connector-pulsar/pull/86#issuecomment-2044005954
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
shibd opened a new pull request, #86:
URL: https://github.com/apache/flink-connector-pulsar/pull/86
## Purpose of the change
https://issues.apache.org/jira/browse/FLINK-34962
## Brief change log
- Remove unnecessary call Pulsar API:
LookupService.getPrtitionedTopicMetadata
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835138#comment-17835138
]
Weijie Guo edited comment on FLINK-35023 at 4/9/24 4:13 AM:
Thanks
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835137#comment-17835137
]
Weijie Guo commented on FLINK-35023:
jdk17:
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835138#comment-17835138
]
Weijie Guo commented on FLINK-35023:
> Apparently this might be automatic in more recent Hadoop
jiexray commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1556755468
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835106#comment-17835106
]
yuanfenghu commented on FLINK-35035:
[~bgeng777]
Thank you for your comment. As you understand, I
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835129#comment-17835129
]
Weijie Guo commented on FLINK-35041:
[
https://issues.apache.org/jira/browse/FLINK-34997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34997:
---
Description:
{code}
Apr 03 03:12:37
masteryhx commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1556830946
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache Software
yuxiqian opened a new pull request, #3212:
URL: https://github.com/apache/flink-cdc/pull/3212
This resolves
[FLINK-35055](https://issues.apache.org/jira/browse/FLINK-35055).
Currently, Flink CDC connector releases both slim and fat jars. Apart from
CDC itself, all of its
[
https://issues.apache.org/jira/browse/FLINK-35055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35055:
---
Labels: pull-request-available (was: )
> Flink CDC connector release contains dependency
[
https://issues.apache.org/jira/browse/FLINK-34099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34099:
---
Affects Version/s: 1.20.0
> CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is
[
https://issues.apache.org/jira/browse/FLINK-34099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34099:
---
Component/s: Build System / CI
>
ljz2051 commented on code in PR #24631:
URL: https://github.com/apache/flink/pull/24631#discussion_r1556933308
##
flink-state-backends/flink-statebackend-forst/pom.xml:
##
@@ -0,0 +1,92 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1556939595
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835149#comment-17835149
]
Sergey Nuyanzin commented on FLINK-35008:
-
I think it would make sense to go with 1.26.1
I
liuyongvs commented on PR #24420:
URL: https://github.com/apache/flink/pull/24420#issuecomment-2044020112
> @liuyongvs the ci still fails could you please have a look here?
@snuyanzin The error occurs because the word "implicit" was mistakenly
written as "Implicit", which leads to a
[
https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35040:
Description:
The performance of serializerHeavyString regresses since April 3, and had not
yet recovered
GOODBOY008 commented on PR #24612:
URL: https://github.com/apache/flink/pull/24612#issuecomment-2044061547
@Jiabao-Sun @1996fanrui PTAL
--
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
GOODBOY008 commented on PR #24613:
URL: https://github.com/apache/flink/pull/24613#issuecomment-2044061806
@Jiabao-Sun @1996fanrui PTAL
--
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
Jacky Lau created FLINK-35054:
-
Summary: Migrate TemporalJoinRewriteWithUniqueKeyRule
Key: FLINK-35054
URL: https://issues.apache.org/jira/browse/FLINK-35054
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835131#comment-17835131
]
Weijie Guo commented on FLINK-34273:
[
https://issues.apache.org/jira/browse/FLINK-35008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835156#comment-17835156
]
Jiabao Sun commented on FLINK-35008:
I agree with Sergey's opinion.
In version 1.26.0, the
masteryhx commented on code in PR #24631:
URL: https://github.com/apache/flink/pull/24631#discussion_r1556741472
##
flink-state-backends/flink-statebackend-forst/pom.xml:
##
@@ -0,0 +1,92 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835106#comment-17835106
]
yuanfenghu edited comment on FLINK-35035 at 4/9/24 2:22 AM:
[~bgeng777]
[
https://issues.apache.org/jira/browse/FLINK-35037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835139#comment-17835139
]
yisha zhou commented on FLINK-35037:
Hi [~libenchao] , could you please assign this task to me? I've
[
https://issues.apache.org/jira/browse/FLINK-35051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835142#comment-17835142
]
Peter Vary commented on FLINK-35051:
FLINK-34704 is one of the ways this issue materializes
> Weird
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1556936793
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software
reswqa commented on code in PR #24634:
URL: https://github.com/apache/flink/pull/24634#discussion_r1556930144
##
docs/content/docs/dev/datastream/fault-tolerance/serialization/types_serialization.md:
##
@@ -37,15 +37,16 @@ Flink places some restrictions on the type of elements
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1556936013
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software
MOBIN created FLINK-35058:
-
Summary: Encountered change event for table db.table whose schema
isn't known to this connector
Key: FLINK-35058
URL: https://issues.apache.org/jira/browse/FLINK-35058
Project:
[
https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yandufeng updated FLINK-35056:
--
Affects Version/s: 2.0.0
Description:
when initial sqlserver table that's primary key is
Xiqian YU created FLINK-35055:
-
Summary: Flink CDC connector release contains jar with
incompatible licenses
Key: FLINK-35055
URL: https://issues.apache.org/jira/browse/FLINK-35055
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835130#comment-17835130
]
Weijie Guo commented on FLINK-34099:
masteryhx commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1556826447
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateExecutor.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-35055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35055:
-
Assignee: Xiqian YU
> Flink CDC connector release contains dependency with
[
https://issues.apache.org/jira/browse/FLINK-35055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiqian YU updated FLINK-35055:
--
Description:
Currently, Flink CDC connector releases both slim and fat jars. Apart from CDC
itself,
RocMarshal commented on PR #78:
URL:
https://github.com/apache/flink-connector-jdbc/pull/78#issuecomment-2042712930
Thanks everybody related for the pr. :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
snuyanzin opened a new pull request, #112:
URL: https://github.com/apache/flink-connector-jdbc/pull/112
The PR will allow to differentiate between jdbc connector statistics and
others with name ci
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-34944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34944:
---
Labels: pull-request-available (was: )
> Use Incremental Source Framework in Flink CDC
whhe opened a new pull request, #3211:
URL: https://github.com/apache/flink-cdc/pull/3211
(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,
RyanSkraba commented on code in PR #24545:
URL: https://github.com/apache/flink/pull/24545#discussion_r1555815225
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.java:
##
@@ -0,0 +1,256 @@
+/*
+ *
X-czh opened a new pull request, #24634:
URL: https://github.com/apache/flink/pull/24634
## What is the purpose of the change
Introduce built-in serialization support for map and lists, which falls back
to Kyro previously.
## Brief change log
Introduce built-in
snuyanzin opened a new pull request, #92:
URL: https://github.com/apache/flink-connector-kafka/pull/92
The PR will allow to differentiate between Kafka connector statistics and
others with name ci
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34123:
---
Labels: pull-request-available (was: )
> Introduce built-in serializers for common
flinkbot commented on PR #24634:
URL: https://github.com/apache/flink/pull/24634#issuecomment-2042769387
## CI report:
* c93a19e5bcb3657bd30bf47ceff989e19bc80a53 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Attachment: Timestamp.png
TimestampData.png
> TIMESTAMP with TIME ZONE not supported by
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
!createExternalConverter.png! The JDBC sink for Postgres does not support
{{{}TIMESTAMP WITH
[
https://issues.apache.org/jira/browse/FLINK-35051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-35051:
---
Description:
While looking through the code I noticed that `StreamTask` is processing
mas-chen commented on code in PR #70:
URL:
https://github.com/apache/flink-connector-kafka/pull/70#discussion_r1556262703
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -396,8 +408,27 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP WITH TIME ZONE{}}},
nor
[
https://issues.apache.org/jira/browse/FLINK-34450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835010#comment-17835010
]
Robert Metzger commented on FLINK-34450:
I was not able to reproduce the issue with a single
[
https://issues.apache.org/jira/browse/FLINK-35051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-35051:
---
Affects Version/s: 1.16.3
> Weird priorities when processing unaligned checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-35051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-35051:
---
Description:
While looking through the code I noticed that `StreamTask` is processing
mas-chen commented on code in PR #70:
URL:
https://github.com/apache/flink-connector-kafka/pull/70#discussion_r1556263478
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -396,8 +408,27 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP WITH TIME ZONE{}}},
nor
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Attachment: (was: image-2024-04-08-18-05-09-213.png)
> TIMESTAMP with TIME ZONE not supported by JDBC
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Attachment: (was: image-2024-04-08-18-05-00-820.png)
> TIMESTAMP with TIME ZONE not supported by JDBC
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP WITH TIME ZONE{}}},
nor
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP WITH TIME ZONE{}}},
nor
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Attachment: createExternalConverter.png
> TIMESTAMP with TIME ZONE not supported by JDBC connector for
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP WITH TIME ZONE{}}},
nor
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP WITH TIME ZONE{}}},
nor
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835002#comment-17835002
]
Ryan Skraba commented on FLINK-35023:
-
Ooops -- there's is already a {{surefire.module.config}} in
mas-chen commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1556248651
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
mas-chen commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1556250658
##
flink-core/src/main/java/org/apache/flink/configuration/MetricOptions.java:
##
@@ -277,11 +277,12 @@ public static Configuration forReporter(Configuration
mas-chen commented on code in PR #70:
URL:
https://github.com/apache/flink-connector-kafka/pull/70#discussion_r1556268256
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -86,6 +93,11 @@ public void flush() {
mas-chen commented on PR #70:
URL:
https://github.com/apache/flink-connector-kafka/pull/70#issuecomment-2043431836
@hhktseng were you able to test that this change mitigates your original
issue? Is there a way to repro in the tests?
--
This is an automated message from the Apache Git
Zakelly commented on PR #24614:
URL: https://github.com/apache/flink/pull/24614#issuecomment-2041936516
@masteryhx Thanks for your comments! Applied some suggestions, PTAL thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834798#comment-17834798
]
Zhu Zhu commented on FLINK-32513:
-
{{Transformation}} is not a public interface, it is an @Internal
Hangxiang Yu created FLINK-35043:
Summary: Release beta version of ForSt
Key: FLINK-35043
URL: https://issues.apache.org/jira/browse/FLINK-35043
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834798#comment-17834798
]
Zhu Zhu edited comment on FLINK-32513 at 4/8/24 6:27 AM:
-
{{Transformation}} is
joyCurry30 commented on code in PR #3187:
URL: https://github.com/apache/flink-cdc/pull/3187#discussion_r1555283731
##
flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml:
##
@@ -53,3 +53,8 @@ pipeline:
name: source-database-sync-pipe
parallelism: 4
joyCurry30 commented on code in PR #3187:
URL: https://github.com/apache/flink-cdc/pull/3187#discussion_r1555283731
##
flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml:
##
@@ -53,3 +53,8 @@ pipeline:
name: source-database-sync-pipe
parallelism: 4
Hangxiang Yu created FLINK-35047:
Summary: Introduce ForStStateBackend
Key: FLINK-35047
URL: https://issues.apache.org/jira/browse/FLINK-35047
Project: Flink
Issue Type: Sub-task
morazow commented on PR #89:
URL:
https://github.com/apache/flink-connector-kafka/pull/89#issuecomment-2041992850
Thanks @hugogu for the PR! I have added some comments, please have a look.
Do you know why the CI is failing?
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-35047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-35047:
-
Description:
A ForStStateBackend is introduced to leverage ForSt as state store for Flink.
PatrickRen commented on code in PR #24265:
URL: https://github.com/apache/flink/pull/24265#discussion_r1555343914
##
docs/content/docs/deployment/config.md:
##
@@ -479,6 +479,26 @@ Flink does not use Pekko for data transport.
{{< generated/akka_configuration >}}
+### Flink
masteryhx commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555343181
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/KeyAccountingUnit.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-34250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834818#comment-17834818
]
Qingsheng Ren commented on FLINK-34250:
---
[~ZhenqiuHuang] There are already pages for formats and
[
https://issues.apache.org/jira/browse/FLINK-35044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-35044:
-
Component/s: Runtime / State Backends
> Introduce statebackend-forst module
>
Hangxiang Yu created FLINK-35044:
Summary: Introduce statebackend-forst module
Key: FLINK-35044
URL: https://issues.apache.org/jira/browse/FLINK-35044
Project: Flink
Issue Type: Sub-task
morazow commented on code in PR #89:
URL:
https://github.com/apache/flink-connector-kafka/pull/89#discussion_r1555308164
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapperTest.java:
##
@@ -0,0 +1,63 @@
+package
[
https://issues.apache.org/jira/browse/FLINK-35044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-35044:
-
Description: A simple work to introduce a new module, then
> Introduce statebackend-forst
[
https://issues.apache.org/jira/browse/FLINK-35045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-35045:
-
Description: As described in FLIP-427, ForStFileSystem is introduced to
support reading and
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated FLINK-35023:
Attachment: jobmanager.log
> YARNApplicationITCase failed on Azure
>
[
https://issues.apache.org/jira/browse/FLINK-35047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-35047:
-
Summary: Introduce ForStStateBackend to manage ForSt (was: Introduce
ForStStateBackend)
>
Hangxiang Yu created FLINK-35049:
Summary: Implement Async State API for ForStStateBackend
Key: FLINK-35049
URL: https://issues.apache.org/jira/browse/FLINK-35049
Project: Flink
Issue Type:
masteryhx commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555340649
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequest.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834815#comment-17834815
]
Martijn Visser commented on FLINK-35009:
[~zhuzh] From a quick glance, it indeed looks like
Hangxiang Yu created FLINK-35045:
Summary: Introduce ForStFileSystem to support reading and writing
with ByteBuffer
Key: FLINK-35045
URL: https://issues.apache.org/jira/browse/FLINK-35045
Project:
1 - 100 of 201 matches
Mail list logo
