[
https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722656#comment-17722656
]
Yun Tang commented on FLINK-31810:
--
[~david.artiga] what distributed-file-system did you use to store
fsk119 commented on PR #17830:
URL: https://github.com/apache/flink/pull/17830#issuecomment-1547203381
I ask the chatgbt about the idea. The answer as follows:
> Q: Is it a good idea to put current catalog or database in the rest api
headers?
It can be a good idea to put the
[
https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722646#comment-17722646
]
Zhilong Hong commented on FLINK-32094:
--
The extra cost may be caused by
[
https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhilong Hong updated FLINK-32094:
-
Attachment: image-2023-05-15-12-33-56-319.png
> startScheduling.BATCH performance regression
[
https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722634#comment-17722634
]
lijie edited comment on FLINK-24696 at 5/15/23 4:28 AM:
hi Piotr Nowojski.
I
fsk119 commented on PR #17830:
URL: https://github.com/apache/flink/pull/17830#issuecomment-1547174183
The presto resposne headers contains the catalog/schema info[1], e.g
`X-Presto-Set-Catalog` and `X-Presto-Catalog`.
[1]
Weijie Guo created FLINK-32095:
--
Summary: HiveDialectITCase crashed with exit code 239
Key: FLINK-32095
URL: https://issues.apache.org/jira/browse/FLINK-32095
Project: Flink
Issue Type: Bug
[ https://issues.apache.org/jira/browse/FLINK-32065 ]
Wencong Liu deleted comment on FLINK-32065:
-
was (Author: JIRAUSER281639):
Hello [~SpongebobZ] , do you clean the tmp dir before the error happens ? It
seems that the file was deleted when
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722638#comment-17722638
]
Wencong Liu commented on FLINK-32065:
-
Hello [~SpongebobZ] , do you clean the tmp dir before the
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722639#comment-17722639
]
Weijie Guo commented on FLINK-30629:
[
https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-32094:
--
Assignee: Yuxin Tan
> startScheduling.BATCH performance regression since May 11th
>
[
https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722637#comment-17722637
]
Weijie Guo commented on FLINK-32094:
This may caused by FLINK-31635, [~tanyuxin] would you mind
fsk119 commented on code in PR #17830:
URL: https://github.com/apache/flink/pull/17830#discussion_r1193281401
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/PromptHandler.java:
##
@@ -0,0 +1,186 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722634#comment-17722634
]
lijie commented on FLINK-24696:
---
hi Piotr Nowojski.
I like flink and I learned how to contribute to our
[
https://issues.apache.org/jira/browse/FLINK-31033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722632#comment-17722632
]
Weijie Guo commented on FLINK-31033:
testCreateTemporarySystemFunctionUsingRemoteJar also report the
xintongsong commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193288010
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManager.java:
##
@@ -0,0 +1,96 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20794.
---
Fix Version/s: (was: 1.18.0)
Resolution: Not A Problem
> Support to select distinct columns in
[
https://issues.apache.org/jira/browse/FLINK-31638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-31638.
Fix Version/s: 1.18.0
Resolution: Done
master (1.18):
[
https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722623#comment-17722623
]
Dian Fu commented on FLINK-20794:
-
Thanks for the analysis. Since string based interfaces have been
xintongsong closed pull request #22316: [FLINK-31638][network] Downstream
supports reading buffers from tiered store
URL: https://github.com/apache/flink/pull/22316
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722618#comment-17722618
]
Liam commented on FLINK-31762:
--
Hi master [~martijnvisser] [~tzulitai] any comment?
> Subscribe to
flinkbot commented on PR #22577:
URL: https://github.com/apache/flink/pull/22577#issuecomment-1547107421
## CI report:
* 498d9e8c2a576f2a9dbfcb5367b2e2d8beed8f83 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fsk119 commented on code in PR #22533:
URL: https://github.com/apache/flink/pull/22533#discussion_r1193272280
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/Executor.java:
##
@@ -46,7 +46,7 @@ static Executor create(
*
* @return
luoyuxia opened a new pull request, #22577:
URL: https://github.com/apache/flink/pull/22577
… statement when delete is pushed down (#22488)
## What is the purpose of the change
Backport of #22488
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-31950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-31950:
--
Summary: Introduce StateMetadata (was: Introduce StateMetadata and
StateMetadataJson SerDe)
>
[
https://issues.apache.org/jira/browse/FLINK-31950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-31950:
--
Description:
According to the FLIP design, we're about to introduce
* StateMetadata, which describes
dianfu commented on code in PR #22571:
URL: https://github.com/apache/flink/pull/22571#discussion_r1191830067
##
flink-python/pyflink/datastream/connectors/pulsar.py:
##
@@ -693,8 +668,7 @@ class PulsarSinkBuilder(object):
... .set_service_url(PULSAR_BROKER_URL) \\
luoyuxia merged PR #22488:
URL: https://github.com/apache/flink/pull/22488
--
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-31950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He closed FLINK-31950.
--
Resolution: Fixed
Fixed in master: 62b11e2e117f874f073de93756c6b9889c464562
> Introduce
godfreyhe closed pull request #22492: [FLINK-31950][table-planner] Introduce
StateMetadata and StateMetadataJson SerDe
URL: https://github.com/apache/flink/pull/22492
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
godfreyhe commented on code in PR #22492:
URL: https://github.com/apache/flink/pull/22492#discussion_r1193258928
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/StateMetadata.java:
##
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32094:
---
Description:
[
https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32094:
---
Attachment: image-2023-05-14-22-58-00-886.png
Description:
Martijn Visser created FLINK-32094:
--
Summary: startScheduling.BATCH performance regression since May
11th
Key: FLINK-32094
URL: https://issues.apache.org/jira/browse/FLINK-32094
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722601#comment-17722601
]
Yaroslav Tkachenko commented on FLINK-28842:
Hi Valentina, unfortunately I didn’t have a
alainbrown commented on PR #42:
URL: https://github.com/apache/flink-playgrounds/pull/42#issuecomment-1546974310
Done!
--
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
flinkbot commented on PR #22576:
URL: https://github.com/apache/flink/pull/22576#issuecomment-1546972941
## CI report:
* 7daebec55b3c0aadaf4e499ac61fe078b25b1eb6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
alainbrown opened a new pull request, #22576:
URL: https://github.com/apache/flink/pull/22576
## What is the purpose of the change
With the addition of a docker volume, this step is no long needed.
https://github.com/apache/flink-playgrounds/pull/42
re:
mkdir -p
[
https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722593#comment-17722593
]
Gyula Fora commented on FLINK-32093:
Can you please share both the operator and the FlinkDeployment
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722592#comment-17722592
]
Gyula Fora commented on FLINK-32041:
Can you please share both the operator and FlinkDeployment
[
https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722589#comment-17722589
]
Tamir Sagi commented on FLINK-32093:
I'm talking about Operator HA not Job HA.
> Upon Delete
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722588#comment-17722588
]
Tamir Sagi edited comment on FLINK-32041 at 5/14/23 5:12 PM:
-
I'm talking
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722588#comment-17722588
]
Tamir Sagi commented on FLINK-32041:
I'm talking about Operator HA.
My point was when creating
[
https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32093:
---
Labels: (was: flink-kubernetes-operator)
> Upon Delete deployment idle pods throw -
[
https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32093:
---
Affects Version/s: kubernetes-operator-1.5.0
> Upon Delete deployment idle pods throw -
[
https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722586#comment-17722586
]
Gyula Fora commented on FLINK-32093:
By HA again here you mean Flink Job HA? or Operator HA (leader
[
https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722584#comment-17722584
]
Tamir Sagi edited comment on FLINK-32093 at 5/14/23 4:37 PM:
-
There are no
[
https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722584#comment-17722584
]
Tamir Sagi commented on FLINK-32093:
I will try tomorrow and get back to you.
> Upon Delete
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722585#comment-17722585
]
Gyula Fora commented on FLINK-32041:
This may be completely unrelated to the original issue
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722583#comment-17722583
]
Tamir Sagi edited comment on FLINK-32041 at 5/14/23 4:33 PM:
-
I need to try
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722583#comment-17722583
]
Tamir Sagi edited comment on FLINK-32041 at 5/14/23 4:33 PM:
-
I need to try
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722583#comment-17722583
]
Tamir Sagi commented on FLINK-32041:
I need to try and get back to youwith an answer (probably
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722583#comment-17722583
]
Tamir Sagi edited comment on FLINK-32041 at 5/14/23 4:32 PM:
-
I need to try
[
https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722581#comment-17722581
]
Gyula Fora edited comment on FLINK-32093 at 5/14/23 4:25 PM:
-
Can you share
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722582#comment-17722582
]
Gyula Fora commented on FLINK-32041:
[~tamirsagi] does the same error occur without HA enabled?
>
[
https://issues.apache.org/jira/browse/FLINK-32093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722581#comment-17722581
]
Gyula Fora commented on FLINK-32093:
Can you share the operator logs?
This this also happen without
Tamir Sagi created FLINK-32093:
--
Summary: Upon Delete deployment idle pods throw -
java.lang.IllegalStateException: Cannot receive event after a delete event
received
Key: FLINK-32093
URL:
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721192#comment-17721192
]
Tamir Sagi edited comment on FLINK-32041 at 5/14/23 4:18 PM:
-
Hey Gyula,
I
xuzhiwen1255 commented on code in PR #21971:
URL: https://github.com/apache/flink/pull/21971#discussion_r1193156542
##
flink-table/flink-table-api-java-bridge/src/test/java/org/apache/flink/table/factories/DataGenTableSourceFactoryTest.java:
##
@@ -264,57 +267,63 @@ void
xuzhiwen1255 commented on PR #21971:
URL: https://github.com/apache/flink/pull/21971#issuecomment-1546911786
@XComp 感谢您的review,我已经完成了修改. 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
xuzhiwen1255 commented on code in PR #21971:
URL: https://github.com/apache/flink/pull/21971#discussion_r1193156464
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java:
##
@@ -49,10 +50,18 @@
/**
*
[
https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32092:
-
Affects Version/s: 1.18.0
> Integrate snapshot file-merging with existing IT cases
>
[
https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32092:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Integrate snapshot
[
https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32091:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Add necessary metrics
[
https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32091:
-
Affects Version/s: 1.18.0
> Add necessary metrics for file-merging
>
[
https://issues.apache.org/jira/browse/FLINK-32090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32090:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Python API for
[
https://issues.apache.org/jira/browse/FLINK-32087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32087:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Space amplification
[
https://issues.apache.org/jira/browse/FLINK-32090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32090:
-
Affects Version/s: 1.18.0
> Python API for enabling and configuring file merging snapshot
>
[
https://issues.apache.org/jira/browse/FLINK-32089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32089:
-
Affects Version/s: 1.18.0
> Do fast copy in best-effort during first checkpoint after restoration
>
[
https://issues.apache.org/jira/browse/FLINK-32089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32089:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Do fast copy in
[
https://issues.apache.org/jira/browse/FLINK-32088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32088:
-
Affects Version/s: 1.18.0
> Re-uploading in state file-merging for space amplification control
>
[
https://issues.apache.org/jira/browse/FLINK-32087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32087:
-
Affects Version/s: 1.18.0
> Space amplification statistics of file merging
>
[
https://issues.apache.org/jira/browse/FLINK-32088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32088:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Re-uploading in state
[
https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32086:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Cleanup non-reported
[
https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32086:
-
Affects Version/s: 1.18.0
> Cleanup non-reported managed directory on exit of TM
>
[
https://issues.apache.org/jira/browse/FLINK-32085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32085:
-
Affects Version/s: 1.18.0
> Implement and migrate batch uploading in changelog files into the file
>
[
https://issues.apache.org/jira/browse/FLINK-32085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32085:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Implement and migrate
[
https://issues.apache.org/jira/browse/FLINK-32083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32083:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Chinese translation of
[
https://issues.apache.org/jira/browse/FLINK-32084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32084:
-
Affects Version/s: 1.18.0
> Migrate current file merging of channel state into the file merging
[
https://issues.apache.org/jira/browse/FLINK-32084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32084:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Migrate current file
[
https://issues.apache.org/jira/browse/FLINK-32083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32083:
-
Affects Version/s: 1.18.0
> Chinese translation of documentation of checkpoint file-merging
>
[
https://issues.apache.org/jira/browse/FLINK-32082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32082:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Documentation of
[
https://issues.apache.org/jira/browse/FLINK-32082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32082:
-
Affects Version/s: 1.18.0
> Documentation of checkpoint file-merging
>
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122906
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122840
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122816
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122680
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-32081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32081:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Compatibility between
[
https://issues.apache.org/jira/browse/FLINK-32081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32081:
-
Affects Version/s: 1.18.0
> Compatibility between file-merging on and off across job runs
>
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122499
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122339
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheBufferFlushTrigger.java:
##
@@ -0,0 +1,26 @@
+/*
+ *
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122290
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/common/TieredStorageUtils.java:
##
@@ -0,0 +1,32 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-32080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32080:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Restoration of
[
https://issues.apache.org/jira/browse/FLINK-32080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32080:
-
Affects Version/s: 1.18.0
> Restoration of FileMergingSnapshotManager
>
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122008
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemorySpec.java:
##
@@ -0,0 +1,51 @@
+/*
+ *
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193121929
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java:
##
@@ -0,0 +1,117 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-32079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32079:
-
Affects Version/s: 1.18.0
> Read/write checkpoint metadata of merged files
>
[
https://issues.apache.org/jira/browse/FLINK-32079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32079:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Read/write checkpoint
[
https://issues.apache.org/jira/browse/FLINK-32078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32078:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Implement private
[
https://issues.apache.org/jira/browse/FLINK-32077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-32077:
-
Component/s: Runtime / Checkpointing
Runtime / State Backends
> Implement shared state
1 - 100 of 122 matches
Mail list logo