bmeriaux commented on issue #6715: [FLINK-8424] update cassandra and driver version to latest URL: https://github.com/apache/flink/pull/6715#issuecomment-454577593 yes, it seems caused by the async save, we close the sink before the end of all the request. The solutions seems to do like in the CassandraSinkBase by using a semaphore to know the number of pending async requests and flush them on close. So there is some rework on all the *OutputFormat classes I will not have to do this before some weeks
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
