Skip to content

Commit ec460c8

Browse files
committed
fixed typo in isSharedOpExecuterorOwned
1 parent e09d7f8 commit ec460c8

File tree

1 file changed

+4
-4
lines changed
  • client-v2/src/main/java/com/clickhouse/client/api

1 file changed

+4
-4
lines changed

client-v2/src/main/java/com/clickhouse/client/api/Client.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ public class Client implements AutoCloseable {
130130
private static final Logger LOG = LoggerFactory.getLogger(Client.class);
131131
private final ExecutorService sharedOperationExecutor;
132132

133-
private final boolean isSharedOpExecuterorOwned;
133+
private final boolean isSharedOpExecutorOwned;
134134

135135
private final Map<String, ClientStatisticsHolder> globalClientStats = new ConcurrentHashMap<>();
136136

@@ -155,10 +155,10 @@ private Client(Set<String> endpoints, Map<String,String> configuration, boolean
155155

156156
boolean isAsyncEnabled = MapUtils.getFlag(this.configuration, ClientConfigProperties.ASYNC_OPERATIONS.getKey(), false);
157157
if (isAsyncEnabled && sharedOperationExecutor == null) {
158-
this.isSharedOpExecuterorOwned = true;
158+
this.isSharedOpExecutorOwned = true;
159159
this.sharedOperationExecutor = Executors.newCachedThreadPool(new DefaultThreadFactory("chc-operation"));
160160
} else {
161-
this.isSharedOpExecuterorOwned = false;
161+
this.isSharedOpExecutorOwned = false;
162162
this.sharedOperationExecutor = sharedOperationExecutor;
163163
}
164164
boolean initSslContext = getEndpoints().stream().anyMatch(s -> s.toLowerCase().contains("https://"));
@@ -202,7 +202,7 @@ public String getDefaultDatabase() {
202202
*/
203203
@Override
204204
public void close() {
205-
if (isSharedOpExecuterorOwned) {
205+
if (isSharedOpExecutorOwned) {
206206
try {
207207
if (sharedOperationExecutor != null && !sharedOperationExecutor.isShutdown()) {
208208
this.sharedOperationExecutor.shutdownNow();

0 commit comments

Comments
 (0)