You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2019/01/30 14:54:06 UTC
[flink] 01/18: [hotfix][cep] Close nfa in CepOperator only if not
null
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3bfffbf1773ca2edebffd826fb2bb44b3d38e065
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Tue Jan 22 09:47:23 2019 +0100
[hotfix][cep] Close nfa in CepOperator only if not null
---
.../src/main/java/org/apache/flink/cep/operator/CepOperator.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CepOperator.java b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CepOperator.java
index 357fbc7..8cc84c9 100644
--- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CepOperator.java
+++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CepOperator.java
@@ -226,7 +226,9 @@ public class CepOperator<IN, KEY, OUT>
@Override
public void close() throws Exception {
super.close();
- nfa.close();
+ if (nfa != null) {
+ nfa.close();
+ }
}
@Override