From 7668660311f32186b674f6c4637ea92aef141779 Mon Sep 17 00:00:00 2001 From: Kristen O'Leary Date: Mon, 8 Mar 2021 11:51:45 -0500 Subject: [PATCH] =?UTF-8?q?revert:=20Revert=20"fix:=20BigtableSession=20is?= =?UTF-8?q?=20never=20closed=20by=20Reader=20causing=20"ManagedChanne?= =?UTF-8?q?=E2=80=A6=20(#2782)"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit 5340db59 --- .../java/com/google/cloud/bigtable/beam/CloudBigtableIO.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/bigtable-dataflow-parent/bigtable-hbase-beam/src/main/java/com/google/cloud/bigtable/beam/CloudBigtableIO.java b/bigtable-dataflow-parent/bigtable-hbase-beam/src/main/java/com/google/cloud/bigtable/beam/CloudBigtableIO.java index aa24e87fd7..098204e777 100755 --- a/bigtable-dataflow-parent/bigtable-hbase-beam/src/main/java/com/google/cloud/bigtable/beam/CloudBigtableIO.java +++ b/bigtable-dataflow-parent/bigtable-hbase-beam/src/main/java/com/google/cloud/bigtable/beam/CloudBigtableIO.java @@ -699,10 +699,6 @@ public void close() throws IOException { scanner.close(); scanner = null; } - if (session != null) { - session.close(); - session = null; - } long totalOps = getRowsReadCount(); long elapsedTimeMs = System.currentTimeMillis() - workStart; long operationsPerSecond = elapsedTimeMs == 0 ? 0 : (totalOps * 1000 / elapsedTimeMs);