Merge pull request #1004: [direct-io-pubsub] do not shutdown executor in PubSubWriter (might be shared)

Author: je-ik

direct/io-pubsub/module/src/main/java/cz/o2/proxima/direct/io/pubsub/AbstractPubSubWriter.java

@@ -30,7 +30,6 @@
 import java.io.IOException;
 import java.net.URI;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import javax.annotation.Nullable;
 import lombok.extern.slf4j.Slf4j;
@@ -140,9 +139,6 @@ public synchronized void close() {
             flightLock.wait(100);
           }
         }
-        executor.shutdown();
-        executor.awaitTermination(10, TimeUnit.SECONDS);
-        executor = null;
         publisher.shutdown();
       } catch (Exception ex) {
         log.warn("Failed to shutdown publisher {}", publisher, ex);