Resolve compile errors due to java version

Signed-off-by: chase <yun.er.run@gmail.com>
tikv · May 31, 2021 · 9038e44 · 9038e44
1 parent d8e65a0
commit 9038e44
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/org/tikv/cdc/RegionCDCClient.java b/src/main/java/org/tikv/cdc/RegionCDCClient.java
@@ -1,6 +1,7 @@
 package org.tikv.cdc;
 
 import com.google.common.base.Preconditions;
+import com.google.common.collect.ImmutableSet;
 import io.grpc.ManagedChannel;
 import io.grpc.stub.StreamObserver;
 import java.util.Set;
@@ -24,7 +25,7 @@ class RegionCDCClient implements AutoCloseable, StreamObserver<ChangeDataEvent>
   private static final Logger LOGGER = LoggerFactory.getLogger(RegionCDCClient.class);
   private static final AtomicLong REQ_ID_COUNTER = new AtomicLong(0);
   private static final Set<LogType> ALLOWED_LOGTYPE =
-      Set.of(LogType.PREWRITE, LogType.COMMIT, LogType.COMMITTED, LogType.ROLLBACK);
+      ImmutableSet.of(LogType.PREWRITE, LogType.COMMIT, LogType.COMMITTED, LogType.ROLLBACK);
 
   private final TiRegion region;
   private final KeyRange keyRange;