alpreu commented on a change in pull request #18038:
URL: https://github.com/apache/flink/pull/18038#discussion_r763930918
##########
File path:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java
##########
@@ -73,6 +73,16 @@
@Nullable
Throwable extractFailureCauseFromBulkItemResponse(BulkItemResponse
bulkItemResponse);
+ /**
+ * Sets the bulk flush interval, in milliseconds on the provided {@link
BulkProcessor.Builder}.
+ * The builder will be later on used to instantiate the actual {@link
BulkProcessor}.
+ *
+ * @param builder the {@link BulkProcessor.Builder} to configure.
+ * @param flushIntervalMillis the flush interval in milliseconds.
+ */
+ void configureBulkProcessorFlushInterval(
Review comment:
Bumping to 7.15.2 means that some imported classes changed their modules
which breaks the current connector code. To keep the old connector working I
had to move this to the version agnostic bridge interface
--
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]
