gliter commented on PR #26299:
URL: https://github.com/apache/flink/pull/26299#issuecomment-2741007537
@gaborgsomogyi I finished similar test like before
Setup:
Cluster running from official dist 1.20.1
Job build with official 1.20.1 that generates random numbers and output to
Kafka
State migration job build with 1.20-SNAPSHOT built from your branch
1. Start the job, let it run for a while
1. Stop with savepoint
1. Check if KafkaCommittable is present
OK: `KafkaCommittable{producerId=18, epoch=0,
transactionalId=kafka-sink-0-18}`
1. Change uid of stateful-function to stateful-function-tmp
1. Bootstrap stateful-function state using stateful-function-tmp as source
and change value by 1000
1. Validate checkpointId is preserved after migration
OK: checkpointId is preserved
1. Start job from savepoint
OK: job continues from last checkpointId
1. state was updated and loaded correctly, outputs are now higher by 1000
1. stop the job with savepoint and check if KafkaCommitable was properly
handled - that is, Commitable from checkpoint before migration was cleaned and
there is only latest Commitable
OK: `Kafka commitable: KafkaCommittable{producerId=55, epoch=0,
transactionalId=kafka-sink-0-54}`
Everything seems to work in order. Great thanks for quick resolution
:raised_hands: .
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
