reswqa commented on code in PR #19560:
URL: https://github.com/apache/flink/pull/19560#discussion_r858246149
##########
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesHighAvailabilityRecoverFromSavepointITCase.java:
##########
@@ -67,40 +68,47 @@
* Tests for recovering from savepoint when Kubernetes HA is enabled. The
savepoint will be
* persisted as a checkpoint and stored in the ConfigMap when recovered
successfully.
*/
-public class KubernetesHighAvailabilityRecoverFromSavepointITCase extends
TestLogger {
+public class KubernetesHighAvailabilityRecoverFromSavepointITCase {
private static final long TIMEOUT = 60 * 1000;
private static final String CLUSTER_ID = "flink-on-k8s-cluster-" +
System.currentTimeMillis();
private static final String FLAT_MAP_UID = "my-flat-map";
- @ClassRule public static KubernetesResource kubernetesResource = new
KubernetesResource();
+ private static Path temporaryPath;
Review Comment:
getConfiguration() will be called during initialization of
MiniClusterExtension. A path is required here, but the injection time of @
TempDir seems to be later than the initialization of static variables,
resulting in null path. I checked JUnit's doc and didn't find a way to modify
the injection timing. Do you have any suggestions about this.
--
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]
