GoogleCloudPlatform / flink-on-k8s-operator

[DEPRECATED] Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
Apache License 2.0
658 stars 266 forks source link

Fix truncate history bug #364

Closed DeliangFan closed 3 years ago

DeliangFan commented 3 years ago

/gcbrun

DeliangFan commented 3 years ago

Could you add a unit test for this method? You might consider refactoring it to make it easier to test. Thanks!

A unit test has been added, please take a review again, thanks!

functicons commented 3 years ago

/gcbrun