+1 (binding)
Regards,
Roman
On Mon, May 6, 2024 at 11:56 AM gongzhongqiang
wrote:
> +1 (non-binding)
>
> Best,
> Zhongqiang Gong
>
> yue ma 于2024年5月6日周一 10:54写道：
>
> > Hi everyone,
> >
> > Thanks for all the feedback, I'd like to start a vote on the FLIP-447:
> > Upgrade FRocksDB from 6.20.3
Hi Piotr,
+1 for the proposal, the recovery time improvements are significant IMO
Thanks for pushing this
Regards,
Roman
On Tue, Apr 30, 2024 at 3:15 PM Piotr Nowojski wrote:
> Hi all!
>
> I would like to put under discussion:
>
> FLIP-444: Native file copy support
>
Thanks for the proposal, I definitely see the need for this improvement, +1.
Regards,
Roman
On Tue, Apr 30, 2024 at 3:11 PM Piotr Nowojski wrote:
> Hi Yanfei,
>
> Thanks for the feedback!
>
> > 1. Currently when AbstractStreamOperator or AbstractStreamOperatorV2
> > processes a watermark, the
Congrats, well deserved!
Regards,
Roman
On Thu, Apr 18, 2024 at 9:06 AM xiangyu feng wrote:
> Congratulations, Zakelly!
>
>
> Regards,
> Xiangyu Feng
>
> yh z 于2024年4月18日周四 14:27写道：
>
> > Congratulations Zakelly!
> >
> > Best regards,
> > Yunhong (swuferhong)
> >
> > gongzhongqiang
Hi,
Thanks for writing the proposal and preparing the upgrade.
FRocksDB definitely needs to be kept in sync with the upstream and the new
APIs are necessary for faster rescaling.
We're already using a similar version internally.
I reviewed the FLIP and it looks good to me (disclaimer: I took
Roman Khachatryan created FLINK-34994:
-
Summary: JobIDLoggingITCase fails because of "checkpoint
confirmation for unknown task"
Key: FLINK-34994
URL: https://issues.apache.org/jira/browse/F
+1 (binding)
Regards,
Roman
On Fri, Mar 29, 2024 at 8:08 AM yue ma wrote:
> +1 (non-binding)
>
> Yanfei Lei 于2024年3月27日周三 18:28写道：
>
> > Hi everyone,
> >
> > Thanks for all the feedback about the FLIP-425: Asynchronous Execution
> > Model [1]. The discussion thread is here [2].
> >
> > The
+1 (binding)
Regards,
Roman
On Fri, Mar 29, 2024 at 7:01 AM Xintong Song wrote:
> +1 (binding)
>
> Best,
>
> Xintong
>
>
>
> On Fri, Mar 29, 2024 at 12:51 PM Yuepeng Pan
> wrote:
>
> > +1(non-binding)
> >
> > Best,
> > Yuepeng Pan
> >
> >
> > On 2024/03/29 03:03:53 Yunfeng Zhou wrote:
> > >
Roman Khachatryan created FLINK-34559:
-
Summary: TVF Window Aggregations might stuck
Key: FLINK-34559
URL: https://issues.apache.org/jira/browse/FLINK-34559
Project: Flink
Issue Type
Roman Khachatryan created FLINK-34420:
-
Summary: Various YARN tests fail after failing to download
hadoop.tar.gz
Key: FLINK-34420
URL: https://issues.apache.org/jira/browse/FLINK-34420
Project
Roman Khachatryan created FLINK-34417:
-
Summary: Add JobID to logging MDC
Key: FLINK-34417
URL: https://issues.apache.org/jira/browse/FLINK-34417
Project: Flink
Issue Type: Improvement
Roman Khachatryan created FLINK-34344:
-
Summary: Wrong JobID in CheckpointStatsTracker
Key: FLINK-34344
URL: https://issues.apache.org/jira/browse/FLINK-34344
Project: Flink
Issue Type
+1 (binding)
Regards,
Roman
On Wed, Nov 22, 2023 at 12:55 PM Rui Fan <1996fan...@gmail.com> wrote:
> +1(binding)
>
> Thanks for driving this proposal!
>
> Best,
> Rui
>
> On Wed, Nov 22, 2023 at 7:44 PM Piotr Nowojski
> wrote:
>
> > Hi All,
> >
> > I'd like to start a vote on the FLIP-386:
+1 (binding)
Regards,
Roman
On Wed, Nov 22, 2023, 7:30 AM Hangxiang Yu wrote:
> +1(binding)
>
> On Wed, Nov 22, 2023 at 10:29 AM Rui Fan <1996fan...@gmail.com> wrote:
>
> > +1(binding)
> >
> > Best,
> > Rui
> >
> > On Wed, Nov 22, 2023 at 1:20 AM Piotr Nowojski
> > wrote:
> >
> > > Hi All,
>
+1 (binding)
Regards,
Roman
On Wed, Nov 22, 2023, 7:08 AM Zakelly Lan wrote:
> +1(non-binding)
>
> Best,
> Zakelly
>
> On Wed, Nov 22, 2023 at 3:04 PM Hangxiang Yu wrote:
>
> > +1 (binding)
> > Thanks for driving this again!
> >
> > On Wed, Nov 22, 2023 at 10:30 AM Rui Fan
+1 (binding)
Thanks for the proposal
Regards,
Roman
On Wed, Nov 22, 2023, 10:08 AM Piotr Nowojski
wrote:
> Thanks Rui!
>
> +1 (binding)
>
> Best,
> Piotrek
>
> śr., 22 lis 2023 o 08:05 Hangxiang Yu napisał(a):
>
> > +1 (binding)
> > Thanks for your efforts!
> >
> > On Mon, Nov 20, 2023 at
to evolve
> that. Alternative to percentiles is previously mentioned to report
> separately each subtask's initialisation/checkpointing span.
>
> Best,
> Piotrek
>
> [1]
>
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-386%3A+Support+adding+custom+metrics+in+R
Roman Khachatryan created FLINK-33590:
-
Summary: CheckpointStatsTracker.totalNumberOfSubTasks not updated
Key: FLINK-33590
URL: https://issues.apache.org/jira/browse/FLINK-33590
Project: Flink
Thanks for the proposal,
Can you please explain:
1. why the existing MetricGroup interface can't be used? It already had
methods to add metrics and spans ...
2. IIUC, based on these numbers, we're going to report span(s). Shouldn't
the backend report them as spans?
3. How is the implementation
Thanks Piotr, the proposal totally makes sense to me.
Does it depend on FLIP-384 for voting?
Otherwise, we could probably start the vote already as there're no counter
proposals or objections.
Regards,
Roman
On Tue, Nov 7, 2023, 1:19 PM Piotr Nowojski
wrote:
> Hey, sorry for the misclick.
Thanks for the proposal,
Starting with the minimal functionality and expanding if necessary as the
FLIP describes makes a lot of sense to me.
Regards,
Roman
On Wed, Nov 15, 2023, 9:31 PM Jing Ge wrote:
> Hi Piotr,
>
> Sorry for the late reply and thanks for the proposal, it looks awesome!
>
>
Roman Khachatryan created FLINK-33442:
-
Summary: UnsupportedOperationException thrown from
RocksDBIncrementalRestoreOperation
Key: FLINK-33442
URL: https://issues.apache.org/jira/browse/FLINK-33442
Congratulations, Yanfey!
Regards,
Roman
On Wed, Aug 9, 2023 at 12:49 PM Benchao Li wrote:
> Congrats, YanFei!
>
> Jing Ge 于2023年8月8日周二 17:41写道：
>
> > Congrats, YanFei!
> >
> > Best regards,
> > Jing
> >
> > On Tue, Aug 8, 2023 at 3:04 PM Yangze Guo wrote:
> >
> > > Congrats, Yanfei!
> > >
>
Congratulations, Hangxiang!
Regards,
Roman
On Wed, Aug 9, 2023 at 12:49 PM Benchao Li wrote:
> Congrats, Hangxiang!
>
> Jing Ge 于2023年8月8日周二 17:44写道：
>
> > Congrats, Hangxiang!
> >
> > Best regards,
> > Jing
> >
> > On Tue, Aug 8, 2023 at 3:04 PM Yangze Guo wrote:
> >
> > > Congrats,
+1 (binding)
The FLIP LGTM, thanks Panos!
Regards,
Roman
On Thu, Apr 20, 2023 at 1:33 PM Hong Teoh wrote:
> +1 (non-binding)
>
> Thank you for driving this effort, Panagiotis.
>
> Regards,
> Hong
>
>
> > On 20 Apr 2023, at 12:16, David Morávek wrote:
> >
> > Thanks for the update!
> >
> >
Roman Khachatryan created FLINK-31601:
-
Summary: While waiting for resources, resources check might be
scheduled unlimited number of times (Adaptive Scheduler)
Key: FLINK-31601
URL: https://issues.apache.org
+1 (binding)
Thanks David, and everyone involved :)
Regards,
Roman
On Wed, Mar 1, 2023 at 8:01 AM Gyula Fóra wrote:
> +1 (binding)
>
> Looking forward to this :)
>
> Gyula
>
> On Wed, 1 Mar 2023 at 04:02, feng xiangyu wrote:
>
> > +1 (non-binding)
> >
> > ConradJam 于2023年3月1日周三 10:37写道：
>
Roman Khachatryan created FLINK-31261:
-
Summary: Make AdaptiveScheduler aware of the (local) state size
Key: FLINK-31261
URL: https://issues.apache.org/jira/browse/FLINK-31261
Project: Flink
Hi,
Thanks for the update, I think distinguishing the rescaling behaviour and
the desired parallelism declaration is important.
Having the ability to specify min parallelism might be useful in
environments with multiple jobs: Scheduler will then have an option to stop
the less suitable job.
In
Congratulations Rui!
Regards,
Roman
On Mon, Feb 20, 2023 at 5:58 PM Anton Kalashnikov
wrote:
> Congrats Rui!
>
> --
> Best regards,
> Anton Kalashnikov
>
> On 20.02.23 17:53, Matthias Pohl wrote:
> > Congratulations, Rui :)
> >
> > On Mon, Feb 20, 2023 at 5:10 PM Jing Ge
> wrote:
> >
> >>
Congratulations Anton, well deserved!
Regards,
Roman
On Tue, Feb 21, 2023 at 9:34 AM Martijn Visser
wrote:
> Congratulations Anton!
>
> On Tue, Feb 21, 2023 at 8:08 AM Lincoln Lee
> wrote:
>
> > Congratulations, Anton!
> >
> > Best,
> > Lincoln Lee
> >
> >
> > Guowei Ma 于2023年2月21日周二
suggestion. I have a test about different exchange types,
> forward
> and rescale, and the results show no differences from the all-to-all type,
> which
> is also understandable, because the network memory usage is calculated
> with numChannels, independent of the edge type.
>
> Bes
Hi everyone,
Thanks for the proposal and the discussion.
I couldn't find much details on how exactly the values of
ExclusiveBuffersPerChannel and FloatingBuffersPerGate are calculated.
I guess that
- the threshold evaluation is done on JM
- floating buffers calculation is done on TM based on the
Roman Khachatryan created FLINK-30073:
-
Summary: Managed memory can be wasted if rocksdb memory is
fixed-per-slot
Key: FLINK-30073
URL: https://issues.apache.org/jira/browse/FLINK-30073
Project
t of
> > > RocksDBStateBackend, that shares memory across slots and does not use
> > > managed memory. This basically means the shared memory is not
> considered
> > as
> > > part of managed memory. For users of this new feature, they would need
> to
> > > confi
the memory size of
> unmanaged part calculated?
> 3. For fine-grained-resource-management, the control
> of cpuCores, taskHeapMemory can still work, right? And I am a little
> worried that too many memory-about configuration options are complicated
> for users to understand.
>
Roman Khachatryan created FLINK-29985:
-
Summary: SlotTable not close on TM termination
Key: FLINK-29985
URL: https://issues.apache.org/jira/browse/FLINK-29985
Project: Flink
Issue Type
ory size of
> unmanaged part calculated?
> 3. For fine-grained-resource-management, the control
> of cpuCores, taskHeapMemory can still work, right? And I am a little
> worried that too many memory-about configuration options are complicated
> for users to understand.
>
> R
Hi everyone,
I'd like to discuss sharing RocksDB memory across slots as proposed in
FLINK-29928 [1].
Since 1.10 / FLINK-7289 [2], it is possible to:
- share these objects among RocksDB instances of the same slot
- bound the total memory usage by all RocksDB instances of a TM
However, the memory
Roman Khachatryan created FLINK-29928:
-
Summary: Allow sharing (RocksDB) memory between slots
Key: FLINK-29928
URL: https://issues.apache.org/jira/browse/FLINK-29928
Project: Flink
Issue
Roman Khachatryan created FLINK-29158:
-
Summary: Fix logging in DefaultCompletedCheckpointStore
Key: FLINK-29158
URL: https://issues.apache.org/jira/browse/FLINK-29158
Project: Flink
Roman Khachatryan created FLINK-29157:
-
Summary: Clarify the contract between CompletedCheckpointStore and
SharedStateRegistry
Key: FLINK-29157
URL: https://issues.apache.org/jira/browse/FLINK-29157
Roman Khachatryan created FLINK-28976:
-
Summary: Changelog 1st materialization delayed unneccesarily
Key: FLINK-28976
URL: https://issues.apache.org/jira/browse/FLINK-28976
Project: Flink
Roman Khachatryan created FLINK-28931:
-
Summary: BlockingPartitionBenchmark doesn't compile
Key: FLINK-28931
URL: https://issues.apache.org/jira/browse/FLINK-28931
Project: Flink
Issue
Roman Khachatryan created FLINK-28647:
-
Summary: Remove separate error handling and adjust documentation
for CLAIM mode + RocksDB native savepoint
Key: FLINK-28647
URL: https://issues.apache.org/jira/browse
Roman Khachatryan created FLINK-28597:
-
Summary: Empty checkpoint folders not deleted on job cancellation
if their shared state is still in use
Key: FLINK-28597
URL: https://issues.apache.org/jira/browse
Hi,
Thanks for the proposal Yun, I think that's a good idea and it could
solve the issue you mentioned (FLINK-26590) in many cases (though not all,
depending on deletion speed; but in practice it may be enough).
Having a separate interface (BulkDeletingFileSystem) would probably help in
Roman Khachatryan created FLINK-27571:
-
Summary: Recognize "less is better" benchmarks in regression
detection script
Key: FLINK-27571
URL: https://issues.apache.org/jira/browse/F
Roman Khachatryan created FLINK-27556:
-
Summary: Performance regression in checkpointSingleInput.UNALIGNED
on 29.04.2022
Key: FLINK-27556
URL: https://issues.apache.org/jira/browse/FLINK-27556
Roman Khachatryan created FLINK-27555:
-
Summary: Performance regression in schedulingDownstreamTasks on
02.05.2022
Key: FLINK-27555
URL: https://issues.apache.org/jira/browse/FLINK-27555
Project
Hi everyone,
FLINK-26985 was just merged.
Sorry for the long delay.
Regards,
Roman
On Tue, Apr 5, 2022 at 11:52 AM Yuan Mei wrote:
>
> FLINK-26985 was discovered just before last weekend.
>
> We will get it resolved first thing after the holiday (tomorrow).
>
> Best
> Yuan
>
> On Tue, Apr 5,
Roman Khachatryan created FLINK-27150:
-
Summary: Improve error reporting in Flink UI
Key: FLINK-27150
URL: https://issues.apache.org/jira/browse/FLINK-27150
Project: Flink
Issue Type
Roman Khachatryan created FLINK-27149:
-
Summary: KafkaSourceE2ECase.testScaleUp failed on AZP
Key: FLINK-27149
URL: https://issues.apache.org/jira/browse/FLINK-27149
Project: Flink
Issue
Roman Khachatryan created FLINK-27148:
-
Summary: UnalignedCheckpointITCase fails on AZP
Key: FLINK-27148
URL: https://issues.apache.org/jira/browse/FLINK-27148
Project: Flink
Issue Type
Roman Khachatryan created FLINK-27144:
-
Summary: Provide timeout details when calling FutureUtils.orTimeout
Key: FLINK-27144
URL: https://issues.apache.org/jira/browse/FLINK-27144
Project: Flink
Roman Khachatryan created FLINK-27132:
-
Summary: CheckpointResourcesCleanupRunner might discard shared
state of the initial checkpoint
Key: FLINK-27132
URL: https://issues.apache.org/jira/browse/FLINK-27132
Roman Khachatryan created FLINK-27114:
-
Summary: On JM restart, the information about the initial
checkpoints can be lost
Key: FLINK-27114
URL: https://issues.apache.org/jira/browse/FLINK-27114
Roman Khachatryan created FLINK-26968:
-
Summary: Bump CopyOnWriteStateMap entry version before write
Key: FLINK-26968
URL: https://issues.apache.org/jira/browse/FLINK-26968
Project: Flink
Roman Khachatryan created FLINK-26967:
-
Summary: Fix race condition in CopyOnWriteStateMap
Key: FLINK-26967
URL: https://issues.apache.org/jira/browse/FLINK-26967
Project: Flink
Issue
Roman Khachatryan created FLINK-26966:
-
Summary: Implement incremental checkpoints
Key: FLINK-26966
URL: https://issues.apache.org/jira/browse/FLINK-26966
Project: Flink
Issue Type: Sub
Roman Khachatryan created FLINK-26965:
-
Summary: Allow reuse of PeriodicMaterializationManager
Key: FLINK-26965
URL: https://issues.apache.org/jira/browse/FLINK-26965
Project: Flink
Roman Khachatryan created FLINK-26964:
-
Summary: Notify CheckpointStrategy about checkpoint
completion/abortion
Key: FLINK-26964
URL: https://issues.apache.org/jira/browse/FLINK-26964
Project
Roman Khachatryan created FLINK-26963:
-
Summary: Allow heap state backend creation customization
Key: FLINK-26963
URL: https://issues.apache.org/jira/browse/FLINK-26963
Project: Flink
Roman Khachatryan created FLINK-26956:
-
Summary: AZP: don't log "[ERROR] Picked up JAVA_TOOL_OPTIONS:
-XX:+HeapDumpOnOutOfMemoryError"
Key: FLINK-26956
URL: https://issues.apache.org/jira/browse/F
Roman Khachatryan created FLINK-26912:
-
Summary: EventTimeWindowCheckpointingITCase.testTumblingTimeWindow
failed on azure
Key: FLINK-26912
URL: https://issues.apache.org/jira/browse/FLINK-26912
Roman Khachatryan created FLINK-26853:
-
Summary: HeapStateBackend ignores metadata updates in certain cases
Key: FLINK-26853
URL: https://issues.apache.org/jira/browse/FLINK-26853
Project: Flink
Roman Khachatryan created FLINK-26685:
-
Summary: Investigate/improve tests stability when using InMemory
Changelog implementation
Key: FLINK-26685
URL: https://issues.apache.org/jira/browse/FLINK-26685
Roman Khachatryan created FLINK-26636:
-
Summary: EmbeddedMultiThreadDependencyTests test_add_python_file
failed on azure
Key: FLINK-26636
URL: https://issues.apache.org/jira/browse/FLINK-26636
Roman Khachatryan created FLINK-26635:
-
Summary: KafkaSourceE2ECase.testMultipleSplits failed on azure
with Correlation id for response does not match request
Key: FLINK-26635
URL: https://issues.apache.org
Roman Khachatryan created FLINK-26632:
-
Summary: JobManagerHAProcessFailureRecoveryITCase failed due to
JVM exits with code 239
Key: FLINK-26632
URL: https://issues.apache.org/jira/browse/FLINK-26632
Roman Khachatryan created FLINK-26615:
-
Summary: BatchingStateChangeUploadSchedulerTest.testRetryOnTimeout
fails on azure
Key: FLINK-26615
URL: https://issues.apache.org/jira/browse/FLINK-26615
Roman Khachatryan created FLINK-26592:
-
Summary: [Changelog] Deadlock in FsStateChangelogWriter
Key: FLINK-26592
URL: https://issues.apache.org/jira/browse/FLINK-26592
Project: Flink
Roman Khachatryan created FLINK-26591:
-
Summary: Compilation fails due to RawToBinaryCastRule
Key: FLINK-26591
URL: https://issues.apache.org/jira/browse/FLINK-26591
Project: Flink
Issue
Roman Khachatryan created FLINK-26590:
-
Summary: Triggered checkpoints can be delayed by discarding shared
state
Key: FLINK-26590
URL: https://issues.apache.org/jira/browse/FLINK-26590
Project
Congratulations, David!
Regards,
Roman
On Fri, Mar 4, 2022 at 7:54 PM Austin Cawley-Edwards
wrote:
>
> Congrats David!
>
> On Fri, Mar 4, 2022 at 12:18 PM Zhilong Hong wrote:
>
> > Congratulations, David!
> >
> > Best,
> > Zhilong
> >
> > On Sat, Mar 5, 2022 at 1:09 AM Piotr Nowojski
> >
Roman Khachatryan created FLINK-26485:
-
Summary: [Changelog] State not discarded after multiple retries
Key: FLINK-26485
URL: https://issues.apache.org/jira/browse/FLINK-26485
Project: Flink
Congratulations Martijn!
Regards,
Roman
On Fri, Mar 4, 2022 at 8:09 AM Sergey Nuyanzin wrote:
>
> Congratulations Martijn!
>
> On Fri, Mar 4, 2022 at 8:07 AM David Morávek wrote:
>
> > Congratulations Martijn, well deserved!
> >
> > Best,
> > D.
> >
> > On Fri, Mar 4, 2022 at 7:25 AM Jiangang
Roman Khachatryan created FLINK-26455:
-
Summary: [Changelog] Materialization interleaved with task
cancellation can fail the job
Key: FLINK-26455
URL: https://issues.apache.org/jira/browse/FLINK-26455
Roman Khachatryan created FLINK-26396:
-
Summary: [Changelog] Upload is not failed even if all attempts
timeout
Key: FLINK-26396
URL: https://issues.apache.org/jira/browse/FLINK-26396
Project
Roman Khachatryan created FLINK-26372:
-
Summary: Allow Changelog Storage configuration per program
Key: FLINK-26372
URL: https://issues.apache.org/jira/browse/FLINK-26372
Project: Flink
Roman Khachatryan created FLINK-26306:
-
Summary: Triggered checkpoints can be delayed by discarding shared
state
Key: FLINK-26306
URL: https://issues.apache.org/jira/browse/FLINK-26306
Project
Roman Khachatryan created FLINK-26255:
-
Summary: SplitAggregateITCase.testAggWithJoin failed on azure
Key: FLINK-26255
URL: https://issues.apache.org/jira/browse/FLINK-26255
Project: Flink
Roman Khachatryan created FLINK-26231:
-
Summary: [Changelog] Incorrect MaterializationID passed to
ChangelogStateBackendHandleImpl
Key: FLINK-26231
URL: https://issues.apache.org/jira/browse/FLINK-26231
Roman Khachatryan created FLINK-26198:
-
Summary: ArchitectureTest fails on AZP (table.api.StatementSet)
Key: FLINK-26198
URL: https://issues.apache.org/jira/browse/FLINK-26198
Project: Flink
Congratulations!
Regards,
Roman
On Wed, Feb 16, 2022 at 5:22 PM Matthias Pohl wrote:
>
> Congratulations to all of you :)
>
> On Wed, Feb 16, 2022 at 4:04 PM Till Rohrmann wrote:
>
> > Congratulations! Well deserved!
> >
> > Cheers,
> > Till
> >
> > On Wed, Feb 16, 2022 at 2:51 PM Martijn
Roman Khachatryan created FLINK-26165:
-
Summary: SavepointFormatITCase fails on azure
Key: FLINK-26165
URL: https://issues.apache.org/jira/browse/FLINK-26165
Project: Flink
Issue Type
Roman Khachatryan created FLINK-26154:
-
Summary: SavepointFormatITCase fails on azure
Key: FLINK-26154
URL: https://issues.apache.org/jira/browse/FLINK-26154
Project: Flink
Issue Type
Roman Khachatryan created FLINK-26144:
-
Summary: SavepointFormatITCase did NOT fail with changelog.enabled
randomized
Key: FLINK-26144
URL: https://issues.apache.org/jira/browse/FLINK-26144
Hi,
+1 for the proposal.
Thanks for volunteering Konstantin!
Regards,
Roman
On Fri, Feb 11, 2022 at 3:00 PM Till Rohrmann wrote:
>
> +1 for a 1.14.4 release. The release-1.14 branch already includes 36 fixed
> issues, some of them quite severe.
>
> Cheers,
> Till
>
> On Fri, Feb 11, 2022 at
Roman Khachatryan created FLINK-26092:
-
Summary: JsonAggregationFunctionsITCase fails with NPE when using
RocksDB
Key: FLINK-26092
URL: https://issues.apache.org/jira/browse/FLINK-26092
Project
Roman Khachatryan created FLINK-26079:
-
Summary: Disallow combination of Changelog backend and CLAIM
restore mode
Key: FLINK-26079
URL: https://issues.apache.org/jira/browse/FLINK-26079
Project
Roman Khachatryan created FLINK-26063:
-
Summary: [Changelog] Incorrect key group logged for PQ.poll and
remove
Key: FLINK-26063
URL: https://issues.apache.org/jira/browse/FLINK-26063
Project
Roman Khachatryan created FLINK-26062:
-
Summary: [Changelog] Non-deterministic recovery of PriorityQueue
states
Key: FLINK-26062
URL: https://issues.apache.org/jira/browse/FLINK-26062
Project
Roman Khachatryan created FLINK-26019:
-
Summary: Changelogged PriorityQueue elements recovered out-of-order
Key: FLINK-26019
URL: https://issues.apache.org/jira/browse/FLINK-26019
Project: Flink
Roman Khachatryan created FLINK-25992:
-
Summary:
JobDispatcherITCase..testRecoverFromCheckpointAfterLosingAndRegainingLeadership
fails on azure
Key: FLINK-25992
URL: https://issues.apache.org/jira/browse
Roman Khachatryan created FLINK-25987:
-
Summary: IllegalArgumentException thrown from
FsStateChangelogWriter.truncate
Key: FLINK-25987
URL: https://issues.apache.org/jira/browse/FLINK-25987
Roman Khachatryan created FLINK-25871:
-
Summary: "License Check failed" on AZP
Key: FLINK-25871
URL: https://issues.apache.org/jira/browse/FLINK-25871
Project: Flink
Issue
Roman Khachatryan created FLINK-25867:
-
Summary: [ZH] Add ChangelogBackend documentation
Key: FLINK-25867
URL: https://issues.apache.org/jira/browse/FLINK-25867
Project: Flink
Issue Type
Roman Khachatryan created FLINK-25850:
-
Summary: Consider notifying nested state backend about checkpoint
abortion
Key: FLINK-25850
URL: https://issues.apache.org/jira/browse/FLINK-25850
Project
Roman Khachatryan created FLINK-25842:
-
Summary: [v2] FLIP-158: Generalized incremental checkpoints
Key: FLINK-25842
URL: https://issues.apache.org/jira/browse/FLINK-25842
Project: Flink
1 - 100 of 338 matches
Mail list logo
