Skip to content

Commit c54fe46

Browse files
leathekdedporras
authored andcommitted
fix ES IO write function
The :action was accidentally calling the wrong Java function
1 parent 3fe3b93 commit c54fe46

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/clj/datasplash/es.clj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ Examples:
9696
(merge
9797
es-connection-schema
9898
{:max-batch-size {:docstr "Specify the max number of documents in a bulk. Default to 1000"
99-
:action (fn [^ElasticsearchIO$Write transform ^Long b] (.withMaxBatchSizeBytes transform b))}
99+
:action (fn [^ElasticsearchIO$Write transform ^Long b] (.withMaxBatchSize transform b))}
100100
:max-batch-size-bytes {:docstr "Specify the max number of bytes in a bulk. Default to 5MB"
101101
:action (fn [^ElasticsearchIO$Write transform ^Long b] (.withMaxBatchSizeBytes transform b))}
102102
:retry-configuration {:docstr "Creates RetryConfiguration for ElasticsearchIO with provided max-attempts, max-durations and exponential backoff based retries"

0 commit comments

Comments
 (0)