[INLONG-10644][Sort] Fix format

XiaoYou201 · Jul 19, 2024 · ee36e24 · ee36e24
1 parent 32c5002
commit ee36e24
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/.../src/main/java/org/apache/inlong/sort/elasticsearch/table/ElasticsearchConfiguration.java b/.../src/main/java/org/apache/inlong/sort/elasticsearch/table/ElasticsearchConfiguration.java
@@ -103,7 +103,8 @@ public Optional<String> getPassword() {
  }
 
  public boolean isBulkFlushBackoffEnabled() {
- return config.get(ElasticsearchConnectorOptions.BULK_FLUSH_BACKOFF_TYPE_OPTION) != ElasticsearchConnectorOptions.BackOffType.DISABLED;
+ return config.get(
+ ElasticsearchConnectorOptions.BULK_FLUSH_BACKOFF_TYPE_OPTION) != ElasticsearchConnectorOptions.BackOffType.DISABLED;
  }
 
  public Optional<ElasticsearchSinkBase.FlushBackoffType> getBulkFlushBackoffType() {
@@ -122,7 +123,8 @@ public Optional<Integer> getBulkFlushBackoffRetries() {
  }
 
  public Optional<Long> getBulkFlushBackoffDelay() {
- return config.getOptional(ElasticsearchConnectorOptions.BULK_FLUSH_BACKOFF_DELAY_OPTION).map(Duration::toMillis);
+ return config.getOptional(ElasticsearchConnectorOptions.BULK_FLUSH_BACKOFF_DELAY_OPTION)
+ .map(Duration::toMillis);
  }
 
  public boolean isDisableFlushOnCheckpoint() {