cc13ny commented on a change in pull request #17870:
URL: https://github.com/apache/flink/pull/17870#discussion_r756359816
##########
File path:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
##########
@@ -62,7 +62,7 @@ private CassandraSink(SingleOutputStreamOperator<IN> sink) {
}
private LegacySinkTransformation<IN> getSinkTransformation() {
- return sink1.getTransformation();
+ return sink1.getLegacyTransformation();
Review comment:
I couldn't find getLegacyTransformation in
[DataStreamSink.java](https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java).
I guess it may be related to `IN` or Cassandra? If so, could you refer me to
the doc or source code for that function?
--
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]
