[ https://issues.apache.org/jira/browse/FLINK-27884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545770#comment-17545770 ]
Etienne Chauchot commented on FLINK-27884: ------------------------------------------ First difficulty that I can see is with guava dep and shading: cassandra uses _com.google.guava:guava:jar:18.0_ but flink-core for common io uses {_}org.apache.flink:flink-shaded-guava:jar:30.1.1-jre-15.0{_}. The problem is that if we promote the flush mechanism to common io there will be in the core an abstract _send()_ method that returns a guava _ListenableFuture_ and that is implemented in the connector modules such as cassandra. As a consequence the two incompatible guava _ListenableFuture_ will conflict. > Introduce a flush mechanism for OutputFormats > --------------------------------------------- > > Key: FLINK-27884 > URL: https://issues.apache.org/jira/browse/FLINK-27884 > Project: Flink > Issue Type: New Feature > Components: Connectors / Common > Reporter: Etienne Chauchot > Priority: Major > > This ticket is a generalization of > [FLINK-27457|https://issues.apache.org/jira/browse/FLINK-27457] -- This message was sent by Atlassian Jira (v8.20.7#820007)