fapaul commented on a change in pull request #18612:
URL: https://github.com/apache/flink/pull/18612#discussion_r798725902
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/InitContextInitializationContextAdapter.java
##########
@@ -15,9 +15,10 @@
* limitations under the License.
*/
-package org.apache.flink.api.connector.sink;
+package org.apache.flink.streaming.runtime.operators.sink;
import org.apache.flink.api.common.serialization.SerializationSchema;
+import org.apache.flink.api.connector.sink.Sink;
Review comment:
We accidentally introduced this class when developing the KafkaSink but
it was always meant to be public. The additional import iis required because
before the class was in the same package as the `Sink` so no import was
required. Now the class is close to the `SinkWriterOperator` that is now the
only place where it is used.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
