This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 674107ba16a310fef219fce59ea2013d778cffff
Author: Piotr Nowojski <[email protected]>
AuthorDate: Tue Dec 12 14:42:20 2023 +0100

    [hotfix] Removed incorrect VisibleForTesting
---
 .../flink/streaming/api/operators/StreamTaskStateInitializerImpl.java   | 2 --
 1 file changed, 2 deletions(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java
index 55d8ffa1f24..737a75f0627 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java
@@ -18,7 +18,6 @@
 
 package org.apache.flink.streaming.api.operators;
 
-import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.api.common.TaskInfo;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.api.java.tuple.Tuple2;
@@ -116,7 +115,6 @@ public class StreamTaskStateInitializerImpl implements 
StreamTaskStateInitialize
                 StreamTaskCancellationContext.alwaysRunning());
     }
 
-    @VisibleForTesting
     public StreamTaskStateInitializerImpl(
             Environment environment,
             StateBackend stateBackend,

Reply via email to