Jiabao-Sun commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2063581154
@ZmmBigdata yes, please go ahead.
--
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
liyubin117 commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570466913
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
ZmmBigdata commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2063554270
@GOODBOY008 Do I need to resynchronize the master repositories and resubmit
the PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838592#comment-17838592
]
Danny Cranmer commented on FLINK-35139:
---
[
https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35133:
-
Assignee: Danny Cranmer
> Release flink-connector-cassandra v3.x.x for Flink 1.19
>
[
https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838590#comment-17838590
]
Danny Cranmer commented on FLINK-35135:
---
[
https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838591#comment-17838591
]
Danny Cranmer commented on FLINK-35137:
---
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-35124.
---
Resolution: Fixed
> Connector Release Fails to run Checkstyle
>
[
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
dannycranmer opened a new pull request, #736:
URL: https://github.com/apache/flink-web/pull/736
(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
liyubin117 commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570448160
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
flinkbot commented on PR #24677:
URL: https://github.com/apache/flink/pull/24677#issuecomment-2063525108
## CI report:
* ef29926a603bc02167158b83b8c705208018adce UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-35156:
---
Assignee: Zakelly Lan
> Wire new operators for async state with DataStream V2
>
Zakelly Lan created FLINK-35156:
---
Summary: Wire new operators for async state with DataStream V2
Key: FLINK-35156
URL: https://issues.apache.org/jira/browse/FLINK-35156
Project: Flink
Issue
ZmmBigdata commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2063508038
> @ZmmBigdata @Jiabao-Sun Issue was fixed in pr #3217 and merged.
@GOODBOY008 In PR # 3217, only two files were modified, while I modified
three files
--
This is an
TobaccoProduct opened a new pull request, #24677:
URL: https://github.com/apache/flink/pull/24677
Document bug fixed:
missing character '>' in line 257, between 'String' and '()'
## What is the purpose of the change
*(For example: This pull request makes task
afedulov commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1568653505
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35127:
---
Labels: pull-request-available test-stability (was: test-stability)
> CDC
lvyanquan commented on PR #3237:
URL: https://github.com/apache/flink-cdc/pull/3237#issuecomment-2063493735
@PatrickRen @yuxiqian 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
lvyanquan opened a new pull request, #3237:
URL: https://github.com/apache/flink-cdc/pull/3237
At present, CI testing often causes OOM due to ValuesSource, which may be
caused by the use of HybridSource. Considering that this will block other prs,
remove it first to restore CI.
--
This
[
https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35092:
-
Assignee: Xiqian YU
> Add integrated test for Doris / Starrocks sink pipeline
[
https://issues.apache.org/jira/browse/FLINK-35072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35072:
-
Assignee: Xiqian YU
> Doris pipeline sink does not support applying
[
https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-35144.
-
Resolution: Duplicate
> Support various sources sync for FlinkCDC in one pipeline
>
[
https://issues.apache.org/jira/browse/FLINK-35077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35077:
-
Assignee: Xiqian YU
> Add package license check for Flink CDC modules.
>
[
https://issues.apache.org/jira/browse/FLINK-35102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35102:
-
Assignee: Xiqian YU
> Incorret Type mapping for Flink CDC Doris connector
>
Dawid Wysakowicz created FLINK-35155:
Summary: Introduce TableRuntimeException
Key: FLINK-35155
URL: https://issues.apache.org/jira/browse/FLINK-35155
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35120:
-
Assignee: Xiqian YU
> Add Doris Pipeline connector integration test cases
>
[
https://issues.apache.org/jira/browse/FLINK-35143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35143:
-
Assignee: Hongshun Wang
> Expose newly added tables capture in mysql pipeline
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35127:
-
Assignee: LvYanquan
> CDC ValuesDataSourceITCase crashed due to OutOfMemoryError
>
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35128:
-
Assignee: Hongshun Wang
> Re-calculate the starting change log offset after the new
[
https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35129:
-
Assignee: Muhammet Orazov
> Postgres source commits the offset after every multiple
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838576#comment-17838576
]
Qingsheng Ren commented on FLINK-35127:
---
I increased the priority to blocker as many PRs are
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838575#comment-17838575
]
Danny Cranmer commented on FLINK-35124:
---
Merged commit c411561 into apache:release_utils
>
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838575#comment-17838575
]
Danny Cranmer edited comment on FLINK-35124 at 4/18/24 9:54 AM:
Merged
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-35127:
--
Priority: Blocker (was: Major)
> CDC ValuesDataSourceITCase crashed due to OutOfMemoryError
dannycranmer merged PR #40:
URL: https://github.com/apache/flink-connector-shared-utils/pull/40
--
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:
dannycranmer commented on PR #40:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/40#issuecomment-2063479840
> But did you find the reason why the suppressions.xml path ends up being
/tools/maven/suppressions.xml and not tools/maven/suppressions.xml ?
No, but I
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838572#comment-17838572
]
Etienne Chauchot edited comment on FLINK-35124 at 4/18/24 9:45 AM:
---
Ok
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838572#comment-17838572
]
Etienne Chauchot commented on FLINK-35124:
--
Ok fair enough to put back {_}ci{_}, _maven_ and
LadyForest commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570355268
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
LadyForest commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570354008
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
LadyForest commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570354008
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
ferenc-csaky commented on PR #46:
URL:
https://github.com/apache/flink-connector-hbase/pull/46#issuecomment-2063424524
@dannycranmer if you have some time can you trigger a CI run? Thanks in
advance!
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838558#comment-17838558
]
Danny Cranmer commented on FLINK-35124:
---
> In the case of regular connectors it was containing ci
dannycranmer merged PR #25:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/25
--
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:
dannycranmer commented on code in PR #25:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/25#discussion_r1570324100
##
.github/workflows/push_pr.yml:
##
@@ -28,11 +28,9 @@ jobs:
compile_and_test:
strategy:
matrix:
- flink: [ 1.17-SNAPSHOT
boring-cyborg[bot] commented on PR #25:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/25#issuecomment-2063392255
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
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838553#comment-17838553
]
Ryan Skraba commented on FLINK-28440:
-
1.19 Java 8 / Test (module: tests)
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838548#comment-17838548
]
Ryan Skraba commented on FLINK-34227:
-
1.19 AdaptiveScheduler / Test (module: table)
hlteoh37 commented on code in PR #138:
URL:
https://github.com/apache/flink-connector-aws/pull/138#discussion_r1570320954
##
flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java:
##
@@ -149,6 +149,7
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838551#comment-17838551
]
Ryan Skraba commented on FLINK-35041:
-
* 1.20 Java 8 / Test (module: core)
[
https://issues.apache.org/jira/browse/FLINK-34224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838552#comment-17838552
]
Ryan Skraba commented on FLINK-34224:
-
1.20 Hadoop 3.1.3 / Test (module: core)
[
https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838550#comment-17838550
]
Ryan Skraba commented on FLINK-32523:
-
1.19 AdaptiveScheduler / Test (module: tests)
[
https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838543#comment-17838543
]
Martijn Visser commented on FLINK-35088:
[~fanrui] What are your thoughts on this?
> watermark
[
https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838541#comment-17838541
]
Ryan Skraba commented on FLINK-35002:
-
I changed the title; requests to the artifact service can
[
https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838541#comment-17838541
]
Ryan Skraba edited comment on FLINK-35002 at 4/18/24 8:55 AM:
--
I changed
[
https://issues.apache.org/jira/browse/FLINK-35154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitriy Linevich updated FLINK-35154:
-
Description:
Javadoc plugin fails with error. Using
{code:java}
javadoc:aggregate{code}
[
https://issues.apache.org/jira/browse/FLINK-35154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitriy Linevich updated FLINK-35154:
-
Description:
Javadoc plugin fails with error "cannot find symbol". Using
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-35154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitriy Linevich updated FLINK-35154:
-
Description:
Javadoc plugin fails with error. Using
{code:java}
javadoc:aggregate{code}
[
https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated FLINK-35002:
Summary: GitHub action request timeout to ArtifactService (was: GitHub
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35124:
---
Labels: pull-request-available (was: )
> Connector Release Fails to run Checkstyle
>
dannycranmer opened a new pull request, #40:
URL: https://github.com/apache/flink-connector-shared-utils/pull/40
Reverting
https://github.com/apache/flink-connector-shared-utils/commit/a75b89ee3f8c9a03e97ead2d0bd9d5b7bb02b51a
to ensure Maven build configuration is included in the source
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838537#comment-17838537
]
Danny Cranmer commented on FLINK-35124:
---
This resulted in bad source archives being generated for
[
https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838534#comment-17838534
]
elon_X commented on FLINK-35088:
[~martijnvisser] [~masc] I'm sorry for the late reply. I have
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35124:
-
Assignee: Danny Cranmer
> Connector Release Fails to run Checkstyle
>
dannycranmer commented on code in PR #138:
URL:
https://github.com/apache/flink-connector-aws/pull/138#discussion_r1570265098
##
flink-connector-aws/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerTest.java:
##
@@ -312,6
[
https://issues.apache.org/jira/browse/FLINK-35154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitriy Linevich updated FLINK-35154:
-
Description:
Javadoc plugin fails with error "cannot find symbol". Using
{code:java}
RocMarshal commented on PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#issuecomment-2063308586
hi, @snuyanzin @eskabetxe Could you help to have a review if you had the
free time ?
Thank you~
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-35154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitriy Linevich updated FLINK-35154:
-
Description:
Javadoc plugin fails with error "cannot find symbol". Using
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-35154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838529#comment-17838529
]
Dmitriy Linevich commented on FLINK-35154:
--
[~MartijnVisser] [~trohrmann]
Hi,
Please, assign
Dmitriy Linevich created FLINK-35154:
Summary: Javadoc aggregate fails
Key: FLINK-35154
URL: https://issues.apache.org/jira/browse/FLINK-35154
Project: Flink
Issue Type: Bug
vahmed-hamdy commented on code in PR #138:
URL:
https://github.com/apache/flink-connector-aws/pull/138#discussion_r1570201177
##
flink-connector-aws/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerTest.java:
##
@@ -312,6
gaborgsomogyi commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1570203474
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -129,8 +133,10 @@ public boolean scaleResource(
[
https://issues.apache.org/jira/browse/FLINK-35153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-35153:
Component/s: Runtime / State Backends
> Internal Async State Implementation and StateDescriptor
twalthr commented on code in PR #24661:
URL: https://github.com/apache/flink/pull/24661#discussion_r1570166387
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/formats/raw/RawFormatSerDeSchemaTest.java:
##
@@ -197,12 +247,12 @@ public static TestSpec
[
https://issues.apache.org/jira/browse/FLINK-35097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-35097:
Assignee: Kumar Mallikarjuna
> Table API Filesystem connector with 'raw' format repeats
fredia commented on PR #24672:
URL: https://github.com/apache/flink/pull/24672#issuecomment-2063204411
@Zakelly @yunfengzhou-hub Thanks for the detailed review, I updated the PR
and addressed some comments, would you please take a look again?
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838499#comment-17838499
]
Leonard Xu commented on FLINK-35151:
Thanks [~pacinogong]for the report, [~ruanhang1993] Would you
Zakelly Lan created FLINK-35153:
---
Summary: Internal Async State Implementation and StateDescriptor
for Map/List State
Key: FLINK-35153
URL: https://issues.apache.org/jira/browse/FLINK-35153
Project:
[
https://issues.apache.org/jira/browse/FLINK-35153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-35153:
Parent: FLINK-34974
Issue Type: Sub-task (was: Bug)
> Internal Async State
fredia commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1570140913
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceAsyncImpl.java:
##
@@ -0,0 +1,146 @@
+/*
+ * Licensed to the Apache
jeyhunkarimov commented on PR #24510:
URL: https://github.com/apache/flink/pull/24510#issuecomment-2063179382
Thanks a lot for the review @LadyForest
--
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-35152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tumengyao updated FLINK-35152:
--
Summary: Flink CDC Doris Sink Auto create table event should support
setting auto partition fields
[
https://issues.apache.org/jira/browse/FLINK-35152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tumengyao updated FLINK-35152:
--
Description:
In some scenarios, when creating a physical table in Doris, appropriate
partition
masteryhx commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1570109129
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java:
##
@@ -0,0 +1,195 @@
+/*
+ *
masteryhx commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1570106555
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java:
##
@@ -0,0 +1,210 @@
+/*
+ *
masteryhx commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1570103838
##
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java:
##
@@ -140,4 +144,43 @@ public void skipFully(long
tumengyao created FLINK-35152:
-
Summary: Flink CDC Doris/Starrocks Sink Auto create table event
should support setting auto partition fields for each table
Key: FLINK-35152
URL:
fredia commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1570100169
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/KeyAccountingUnit.java:
##
@@ -32,6 +32,8 @@
*/
public class KeyAccountingUnit {
+
lvyanquan commented on PR #3235:
URL: https://github.com/apache/flink-cdc/pull/3235#issuecomment-2063146409
Looks like there are other places that use ValueSource with paralism > 1,
and I'm trying to find out the reason of this failure.
--
This is an automated message from the Apache
fredia commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1570075307
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java:
##
@@ -117,6 +120,7 @@ public class
[
https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-31860.
--
Fix Version/s: kubernetes-operator-1.9.0
Assignee: Zhou JIANG (was: Jayme Howard)
gyfora merged PR #817:
URL: https://github.com/apache/flink-kubernetes-operator/pull/817
--
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:
mas-chen commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1570041925
##
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_r1570041925
##
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_r1570041925
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
101 - 197 of 197 matches
Mail list logo
