You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2022/04/21 06:23:50 UTC
[pulsar] branch master updated: [Functions] Check executor null when closing the FileSource (#15247)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 06ba587fb92 [Functions] Check executor null when closing the FileSource (#15247)
06ba587fb92 is described below
commit 06ba587fb92eff81785f8d463c85aaa1095292e9
Author: Neng Lu <nl...@streamnative.io>
AuthorDate: Wed Apr 20 23:23:44 2022 -0700
[Functions] Check executor null when closing the FileSource (#15247)
---
.../src/main/java/org/apache/pulsar/io/file/FileSource.java | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
diff --git a/pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSource.java b/pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSource.java
index 9ba85f3ed71..a67e3195ad7 100644
--- a/pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSource.java
+++ b/pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSource.java
@@ -57,13 +57,15 @@ public class FileSource extends PushSource<byte[]> {
@Override
public void close() throws Exception {
- executor.shutdown();
- try {
- if (!executor.awaitTermination(800, TimeUnit.MILLISECONDS)) {
+ if (executor != null) {
+ executor.shutdown();
+ try {
+ if (!executor.awaitTermination(800, TimeUnit.MILLISECONDS)) {
+ executor.shutdownNow();
+ }
+ } catch (InterruptedException e) {
executor.shutdownNow();
}
- } catch (InterruptedException e) {
- executor.shutdownNow();
}
}
}