lihaosky opened a new pull request, #25036:
URL: https://github.com/apache/flink/pull/25036
## What is the purpose of the change
Catalog changes to support model resource
## Brief change log
* Add `CatalogModel` related resource
* Add model CRUD operations in `Cata
lihaosky commented on PR #25036:
URL: https://github.com/apache/flink/pull/25036#issuecomment-2212606448
cc @twalthr
--
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 uns
flinkbot commented on PR #25036:
URL: https://github.com/apache/flink/pull/25036#issuecomment-2212607683
## CI report:
* dd6632371c5404780ab79e7ed308db46c6152154 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
RocMarshal opened a new pull request, #25037:
URL: https://github.com/apache/flink/pull/25037
…en't updated after failover.
(cherry picked from commit 615d19735b0691b57262a110e6078c3488349f5a)
## What is the purpose of the change
BP for 1.17 of https://github.com/
RocMarshal opened a new pull request, #25038:
URL: https://github.com/apache/flink/pull/25038
(cherry picked from commit 615d19735b0691b57262a110e6078c3488349f5a)
## What is the purpose of the change
BP for 1.18 of https://github.com/apache/flink/pull/25021
--
This is
RocMarshal opened a new pull request, #25039:
URL: https://github.com/apache/flink/pull/25039
(cherry picked from commit 615d19735b0691b57262a110e6078c3488349f5a)
## What is the purpose of the change
BP for 1.19 of https://github.com/apache/flink/pull/25021
--
This is
RocMarshal opened a new pull request, #25040:
URL: https://github.com/apache/flink/pull/25040
(cherry picked from commit 615d19735b0691b57262a110e6078c3488349f5a)
## What is the purpose of the change
BP for 1.20 of https://github.com/apache/flink/pull/25021
--
flinkbot commented on PR #25037:
URL: https://github.com/apache/flink/pull/25037#issuecomment-221297
## CI report:
* 1300c054a1ffa88c18f4c6c28a154207ce12bf98 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25038:
URL: https://github.com/apache/flink/pull/25038#issuecomment-2212777977
## CI report:
* 8cb40a599c1e127b5f427be710f4a840c7fa4ca1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25039:
URL: https://github.com/apache/flink/pull/25039#issuecomment-2212781383
## CI report:
* f1c40d72af10e7ba07304c018cdd2588a07bf395 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25040:
URL: https://github.com/apache/flink/pull/25040#issuecomment-2212781614
## CI report:
* 7f1b9491efa0ce3bb7a4815732d9ff10a82056bb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1996fanrui commented on code in PR #25030:
URL: https://github.com/apache/flink/pull/25030#discussion_r1667861271
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -773,6 +773,13 @@ static boolean
shouldSyn
fredia merged PR #25032:
URL: https://github.com/apache/flink/pull/25032
--
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.apache
fredia commented on PR #25032:
URL: https://github.com/apache/flink/pull/25032#issuecomment-2212848554
@kartikeypant Thanks for the PR, 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 sp
yuxiqian commented on PR #3458:
URL: https://github.com/apache/flink-cdc/pull/3458#issuecomment-2212862904
@ruanhang1993 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 specific comment.
showuon opened a new pull request, #25041:
URL: https://github.com/apache/flink/pull/25041
## What is the purpose of the change
In [FLINK-28493](https://github.com/apache/flink/pull/20506/), we
implemented "ANALYZE TABLE" syntax feature and documented the reserved keyword:
**
flinkbot commented on PR #25041:
URL: https://github.com/apache/flink/pull/25041#issuecomment-2212873141
## CI report:
* aa4b31c68b9831a2e78bfff7d976e2b32dd229bb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fengjiajie commented on PR #25009:
URL: https://github.com/apache/flink/pull/25009#issuecomment-2212880693
Could you please take a look when you have time? @Samrat002 @1996fanrui
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
Zakelly commented on code in PR #25030:
URL: https://github.com/apache/flink/pull/25030#discussion_r1667911678
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -773,6 +773,13 @@ static boolean
shouldSyncAf
RocMarshal commented on PR #25038:
URL: https://github.com/apache/flink/pull/25038#issuecomment-2212931466
@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 opened a new pull request, #25042:
URL: https://github.com/apache/flink/pull/25042
(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, e-ma
Zakelly opened a new pull request, #25043:
URL: https://github.com/apache/flink/pull/25043
(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, e-ma
flinkbot commented on PR #25042:
URL: https://github.com/apache/flink/pull/25042#issuecomment-2212952936
## CI report:
* b334fec2d8479c8e9e30928fc3fd6e6fa3f8f296 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly opened a new pull request, #25044:
URL: https://github.com/apache/flink/pull/25044
(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, e-ma
flinkbot commented on PR #25043:
URL: https://github.com/apache/flink/pull/25043#issuecomment-2212960152
## CI report:
* 3639c3545b47b7a06562c3deb316a11dccf3c885 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly opened a new pull request, #25045:
URL: https://github.com/apache/flink/pull/25045
(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, e-ma
flinkbot commented on PR #25044:
URL: https://github.com/apache/flink/pull/25044#issuecomment-2212968492
## CI report:
* aa3002c4d9433402793d85bccbba3d0768c1761a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25045:
URL: https://github.com/apache/flink/pull/25045#issuecomment-2212968868
## CI report:
* 9dc582bf8e0ed6e19306431c9a71542bb238784b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
kartikeypant commented on PR #25032:
URL: https://github.com/apache/flink/pull/25032#issuecomment-2213000911
Thanks for the merge, @fredia. I have also created backport PRs for 1.19
(https://github.com/apache/flink/pull/25033) and 1.20 versions
(https://github.com/apache/flink/pull/25034),
RocMarshal commented on PR #25037:
URL: https://github.com/apache/flink/pull/25037#issuecomment-2213100328
@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
RocMarshal commented on PR #25038:
URL: https://github.com/apache/flink/pull/25038#issuecomment-2213100224
@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
zhuzhurk merged PR #25024:
URL: https://github.com/apache/flink/pull/25024
--
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
yuxiqian commented on code in PR #3438:
URL: https://github.com/apache/flink-cdc/pull/3438#discussion_r1668075424
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java:
##
Review Comment:
In the future, defining multiple sink in one sin
whhe commented on code in PR #109:
URL:
https://github.com/apache/flink-connector-jdbc/pull/109#discussion_r1668077202
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java:
##
@@ -82,6 +84,14 @@ public static AbstractJdbcCatalog cr
ruanhang1993 commented on code in PR #3458:
URL: https://github.com/apache/flink-cdc/pull/3458#discussion_r1668081572
##
docs/content.zh/docs/core-concept/data-pipeline.md:
##
@@ -98,5 +98,5 @@ The following config options of Data Pipeline level are
supported:
| parameter
ruanhang1993 commented on code in PR #3458:
URL: https://github.com/apache/flink-cdc/pull/3458#discussion_r1668081572
##
docs/content.zh/docs/core-concept/data-pipeline.md:
##
@@ -98,5 +98,5 @@ The following config options of Data Pipeline level are
supported:
| parameter
whhe commented on code in PR #109:
URL:
https://github.com/apache/flink-connector-jdbc/pull/109#discussion_r1668082863
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/databases/oceanbase/catalog/OceanBaseTypeMapper.java:
##
@@ -0,0 +1,167 @@
+/*
+ * Licens
proletarians commented on code in PR #3438:
URL: https://github.com/apache/flink-cdc/pull/3438#discussion_r1668085508
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java:
##
Review Comment:
Got it! I will follow up on this.
--
Thi
Zakelly commented on code in PR #25030:
URL: https://github.com/apache/flink/pull/25030#discussion_r1667911678
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -773,6 +773,13 @@ static boolean
shouldSyncAf
Karl-WangSK commented on PR #3451:
URL: https://github.com/apache/flink-cdc/pull/3451#issuecomment-2213195743
hello , pls can trigger the CI e2e check? this cancelled not related to
this pr. @leonardBang
--
This is an automated message from the Apache Git Service.
To respond to t
Karl-WangSK commented on PR #3451:
URL: https://github.com/apache/flink-cdc/pull/3451#issuecomment-2213200856
hello , pls can trigger the CI e2e check? this cancelled not related to this
pr. @ruanhang1993
--
This is an automated message from the Apache Git Service.
To respond to the mess
XComp commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1668120064
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -85,7 +85,16 @@ public Collection getJobManagerRunners() {
hlteoh37 merged PR #24964:
URL: https://github.com/apache/flink/pull/24964
--
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
hlteoh37 merged PR #25033:
URL: https://github.com/apache/flink/pull/25033
--
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
hlteoh37 merged PR #25034:
URL: https://github.com/apache/flink/pull/25034
--
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
shangeyao commented on PR #2315:
URL: https://github.com/apache/flink-cdc/pull/2315#issuecomment-2213317177
> 合并到哪个版本了呢
3.1
--
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
hlteoh37 commented on PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#issuecomment-2213359349
> New feature has been introduced
If yes, how is this documented? JavaDocs
We will also need to document this on Flink docs - let's link the
documentation update
z3d1k commented on PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#issuecomment-2213371351
> We will also need to document this on Flink docs - let's link the
documentation update JIRA
Linked documentation Jira.
--
This is an automated message from the Apache
whhe commented on PR #109:
URL:
https://github.com/apache/flink-connector-jdbc/pull/109#issuecomment-2213542334
@RocMarshal Updated. 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 spec
1996fanrui merged PR #25039:
URL: https://github.com/apache/flink/pull/25039
--
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
1996fanrui merged PR #25040:
URL: https://github.com/apache/flink/pull/25040
--
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
AHeise commented on PR #70:
URL:
https://github.com/apache/flink-connector-kafka/pull/70#issuecomment-2213583717
Please check my comment here.
https://issues.apache.org/jira/browse/FLINK-33545?focusedCommentId=17863737&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#
showuon opened a new pull request, #25046:
URL: https://github.com/apache/flink/pull/25046
## What is the purpose of the change
master branch PR: https://github.com/apache/flink/pull/24964.
Flink UI always shows float metric value as int/long. For example,
`outPoolUsage
showuon opened a new pull request, #25047:
URL: https://github.com/apache/flink/pull/25047
## What is the purpose of the change
master branch PR: https://github.com/apache/flink/pull/24964.
Flink UI always shows float metric value as int/long. For example,
`outPoolUsage
showuon commented on PR #25046:
URL: https://github.com/apache/flink/pull/25046#issuecomment-2213589908
@hlteoh37 , PR to backport to 1.19. 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
showuon commented on PR #25047:
URL: https://github.com/apache/flink/pull/25047#issuecomment-2213590142
@hlteoh37 , PR to backport to 1.20. 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
flinkbot commented on PR #25046:
URL: https://github.com/apache/flink/pull/25046#issuecomment-2213598638
## CI report:
* b875e4639e6b694de4b12a127484d3308b3f1501 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mateczagany commented on code in PR #821:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/821#discussion_r1668364184
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java:
##
@@ -266,19 +30
flinkbot commented on PR #25047:
URL: https://github.com/apache/flink/pull/25047#issuecomment-2213599102
## CI report:
* 83126341fe0ac6764c0ae74ae354fa97968f37f6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JimmyZZZ commented on code in PR #107:
URL:
https://github.com/apache/flink-connector-kafka/pull/107#discussion_r1668370765
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -449,12 +460,17 @@ public void onCompletion(RecordMet
JimmyZZZ commented on code in PR #107:
URL:
https://github.com/apache/flink-connector-kafka/pull/107#discussion_r1668387172
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -411,11 +411,22 @@ private void registerMetricSync()
JimmyZZZ commented on PR #107:
URL:
https://github.com/apache/flink-connector-kafka/pull/107#issuecomment-2213634985
> Please also add some more details to the PR description and commit message
in accordance with the
[guidlines](https://flink.apache.org/how-to-contribute/reviewing-prs/). I
JimmyZZZ closed pull request #107: [FLINK-35749] Kafka sink component will lose
data when kafka cluster is unavailable for a while
URL: https://github.com/apache/flink-connector-kafka/pull/107
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
JimmyZZZ commented on code in PR #107:
URL:
https://github.com/apache/flink-connector-kafka/pull/107#discussion_r1668396762
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -411,11 +411,22 @@ private void registerMetricSync()
fredia opened a new pull request, #25048:
URL: https://github.com/apache/flink/pull/25048
## What is the purpose of the change
https://issues.apache.org/jira/browse/FLINK-34482 renamed options for
checkpointing, but the file-merging documents are not updated. This PR updates
flinkbot commented on PR #25048:
URL: https://github.com/apache/flink/pull/25048#issuecomment-2213665532
## CI report:
* 051486f910ad10f192178a50b6bd42e34c9733c2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia opened a new pull request, #25049:
URL: https://github.com/apache/flink/pull/25049
## What is the purpose of the change
1.18 backport for parent PR https://github.com/apache/flink/pull/25048
No conflicts appeared during backport.
## Brief change log
- Up
flinkbot commented on PR #25049:
URL: https://github.com/apache/flink/pull/25049#issuecomment-2213681978
## CI report:
* cfda72da0150ea96a9b6a22935580c8757a517db UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Karl-WangSK opened a new pull request, #3460:
URL: https://github.com/apache/flink-cdc/pull/3460
(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
Karl-WangSK commented on PR #3460:
URL: https://github.com/apache/flink-cdc/pull/3460#issuecomment-2213697218
@yuxiqian @leonardBang 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 speci
yuxiqian commented on code in PR #3455:
URL: https://github.com/apache/flink-cdc/pull/3455#discussion_r1668456054
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformDataOperator.java:
##
Review Comment:
I'm a bit unsure if `transfor
hlteoh37 commented on code in PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#discussion_r1668396430
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisShardSplitWithAssignmentStatus.
morazow commented on PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2213814301
Thanks @dongwoo6kim, Looks good!
--
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
ferenc-csaky commented on code in PR #851:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/851#discussion_r1668491036
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -263,14 +268,24 @@ protec
kumar-mallikarjuna commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1668545338
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -85,7 +85,16 @@ public Collection getJobManage
Zakelly commented on PR #25030:
URL: https://github.com/apache/flink/pull/25030#issuecomment-2213958804
Thanks Rui!
--
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 unsub
Zakelly merged PR #25031:
URL: https://github.com/apache/flink/pull/25031
--
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
Zakelly merged PR #25030:
URL: https://github.com/apache/flink/pull/25030
--
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
rkhachatryan commented on code in PR #25028:
URL: https://github.com/apache/flink/pull/25028#discussion_r1668622658
##
flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/AbstractS3FileSystemFactory.java:
##
@@ -41,6 +42,41 @@
/** Base class for file
XComp commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1668650443
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -85,7 +85,16 @@ public Collection getJobManagerRunners() {
mateczagany commented on code in PR #821:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/821#discussion_r1668650953
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java:
##
@@ -266,19 +30
XComp commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1668650443
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -85,7 +85,16 @@ public Collection getJobManagerRunners() {
hlteoh37 commented on code in PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#discussion_r1668649676
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/event/SplitsFinishedEvent.java:
##
@@ -0,
rkhachatryan opened a new pull request, #25050:
URL: https://github.com/apache/flink/pull/25050
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring th
flinkbot commented on PR #25050:
URL: https://github.com/apache/flink/pull/25050#issuecomment-2214162634
## CI report:
* 2d524cf16224834ef4b8c3fd7f4c63caabdf43ba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668797608
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -354,10 +354,12 @@ public void close() throws IOException {
if (shutdownReque
XComp commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668797608
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -354,10 +354,12 @@ public void close() throws IOException {
if (shutdownReque
twalthr merged PR #24987:
URL: https://github.com/apache/flink/pull/24987
--
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
rkhachatryan commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668850192
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -354,10 +354,12 @@ public void close() throws IOException {
if (shutdo
XComp commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668880762
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -354,10 +354,12 @@ public void close() throws IOException {
if (shutdownReque
XComp commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668880762
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -354,10 +354,12 @@ public void close() throws IOException {
if (shutdownReque
XComp commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668882384
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -354,10 +354,12 @@ public void close() throws IOException {
if (shutdownReque
rkhachatryan commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668896504
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -354,10 +354,12 @@ public void close() throws IOException {
if (shutdo
rkhachatryan commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668897088
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -354,10 +354,12 @@ public void close() throws IOException {
if (shutdo
XComp commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668927920
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -396,7 +399,9 @@ public void close() throws IOException {
if (LOG.isInfoE
rkhachatryan commented on code in PR #25050:
URL: https://github.com/apache/flink/pull/25050#discussion_r1668975142
##
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java:
##
@@ -396,7 +399,9 @@ public void close() throws IOException {
if (LOG.
Zakelly opened a new pull request, #25051:
URL: https://github.com/apache/flink/pull/25051
## What is the purpose of the change
The `OperatorSubtaskState` only make keyed state register with
`SharedStateRegistry`. However, the file-merging directories's handle are
wrapped in `FileMer
Zakelly opened a new pull request, #25052:
URL: https://github.com/apache/flink/pull/25052
## What is the purpose of the change
The `OperatorSubtaskState` only make keyed state register with
`SharedStateRegistry`. However, the file-merging directories's handle are
wrapped in `FileMer
flinkbot commented on PR #25051:
URL: https://github.com/apache/flink/pull/25051#issuecomment-2214714463
## CI report:
* e555779cb606a2ecb5bcd7f5f6e7c12eddd85a65 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25052:
URL: https://github.com/apache/flink/pull/25052#issuecomment-2214715238
## CI report:
* cadb2364f238bf047e938b742079f7f56a2b10ea UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
901 - 1000 of 53003 matches
Mail list logo
