You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by zj...@apache.org on 2020/07/22 09:31:45 UTC
[zeppelin] branch master updated: [hotfix] catch error in flink udf
detection
This is an automated email from the ASF dual-hosted git repository.
zjffdu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git
The following commit(s) were added to refs/heads/master by this push:
new 390149f [hotfix] catch error in flink udf detection
390149f is described below
commit 390149ff542e55822bea62a0f759f4ada2ab4ec7
Author: Jeff Zhang <zj...@apache.org>
AuthorDate: Wed Jul 22 17:31:10 2020 +0800
[hotfix] catch error in flink udf detection
---
.../main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink/interpreter/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala b/flink/interpreter/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala
index 2f397c1..30ec177 100644
--- a/flink/interpreter/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala
+++ b/flink/interpreter/src/main/scala/org/apache/zeppelin/flink/FlinkScalaInterpreter.scala
@@ -499,7 +499,7 @@ class FlinkScalaInterpreter(val properties: Properties) {
}
}
} catch {
- case e : Exception =>
+ case e : Throwable =>
LOGGER.info("Fail to inspect udf class: " + je.getName, e)
}
}