Hello,

It doesn't seem like we can disable max actions and max size for
Elasticsearch connector.

Docs:
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/elasticsearch.html#sink-bulk-flush-max-actions
sink.bulk-flush.max-actions optional 1000 Integer Maximum number of
buffered actions per bulk request. Can be set to '0' to disable it.
sink.bulk-flush.max-size optional 2mb MemorySize Maximum size in memory of
buffered actions per bulk request. Must be in MB granularity. Can be set to
'0' to disable it.
Reality:

org.apache.flink.client.program.ProgramInvocationException: The main method
caused an error: Max number of buffered actions must be larger than 0.

ES code looks like -1 is actually the value for disabling, but when I use
-1:
Caused by: java.lang.IllegalArgumentException: Could not parse value '-1'
for key 'sink.bulk-flush.max-size'.

How can I disable these two settings?

Thanks!

-- 

Rex Fenley  |  Software Engineer - Mobile and Backend


Remind.com <https://www.remind.com/> |  BLOG <http://blog.remind.com/>
 |  FOLLOW
US <https://twitter.com/remindhq>  |  LIKE US
<https://www.facebook.com/remindhq>

Reply via email to