diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/TableView.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/TableView.java index 1a6dac9129bd7b..fd20d601cca43f 100644 --- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/TableView.java +++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/TableView.java @@ -111,9 +111,7 @@ public interface TableView extends Closeable { */ CompletableFuture closeAsync(); - /** - * * Refresh the table view with the latest data in the topic, ensuring that all subsequent reads are based on the refreshed data. * * Example usage: diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TableViewImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TableViewImpl.java index a8f21a765c5cdf..8a1cfe977aa038 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TableViewImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TableViewImpl.java @@ -270,7 +270,7 @@ private void readAllExistingMessages(Reader reader, CompletableFuture f future.completeExceptionally(ex); return null; }); - } else if (readTailMessages){ + } else if (readTailMessages) { // Reached the end long endTime = System.nanoTime(); long durationMillis = TimeUnit.NANOSECONDS.toMillis(endTime - startTime);