[
https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705975#comment-17705975
]
Matthias Pohl commented on FLINK-31593:
---------------------------------------
I attached the debug logs of the snapshot creation test run
[^FLINK-31593.StatefulJobSavepointMigrationITCase.create_snapshot.log] .
The actual snapshot creation is triggered after the log print "Triggering
snapshot.". in the logs that follow you see that it's a checkpointtype snapshot
that is created:
{code}
[...]
8776 [main] INFO
org.apache.flink.test.checkpointing.utils.SnapshotMigrationTestBase [] -
Triggering snapshot.
8778 [flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Triggering a manual
checkpoint for job b0d7b4f94a20c2f353f65dfd8e8d3682.
[...]
9122 [Flat Map -> Sink: Unnamed (4/4)#0] DEBUG
org.apache.flink.streaming.runtime.tasks.StreamTask [] - Starting checkpoint 1
CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD} on
task Flat Map -> Sink: Unnamed (4/4)#0
[...]
{code}
> Update reference data for Migration Tests
> -----------------------------------------
>
> Key: FLINK-31593
> URL: https://issues.apache.org/jira/browse/FLINK-31593
> Project: Flink
> Issue Type: Sub-task
> Reporter: Matthias Pohl
> Assignee: Matthias Pohl
> Priority: Major
> Labels: pull-request-available
> Attachments:
> FLINK-31593.StatefulJobSavepointMigrationITCase.create_snapshot.log
>
>
> # Update {{CURRENT_VERSION in TypeSerializerUpgradeTestBase}} with the new
> version. This will likely fail some tests because snapshots are missing for
> that version. Generate them, for example in
> {{TypeSerializerUpgradeTestBase.}}
> # (major/minor only) Update migration tests in master to cover migration
> from new version: (search for usages of FlinkV{{{}ersion{}}})
> ** AbstractOperatorRestoreTestBase
> ** CEPMigrationTest
> ** BucketingSinkMigrationTest
> ** FlinkKafkaConsumerBaseMigrationTest
> ** ContinuousFileProcessingMigrationTest
> ** WindowOperatorMigrationTest
> ** StatefulJobSavepointMigrationITCase
> ** StatefulJobWBroadcastStateMigrationITCase
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
