Skip to content

Commit

Permalink
disable streaming thread
Browse files Browse the repository at this point in the history
  • Loading branch information
sakthivelmanii committed Jan 6, 2025
1 parent 4d7c5fc commit e99c33b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -490,7 +490,7 @@ public ApiFuture<Void> setCallback(Executor exec, ReadyCallback cb) {
this.result = SettableApiFuture.create();
this.state = State.STREAMING_INITIALIZED;
initiateProduceRows();
// this.service.execute(new InitiateStreamingRunnable());
// this.service.execute(new InitiateStreamingRunnable());
this.executor = MoreExecutors.newSequentialExecutor(Preconditions.checkNotNull(exec));
this.callback = Preconditions.checkNotNull(cb);
pausedLatch.countDown();
Expand Down

0 comments on commit e99c33b

Please sign in to comment.