Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

“ [ERROR] Async loop died! java.lang.RuntimeException: Error compiling query” when SAM topology is deployed

Highlighted

“ [ERROR] Async loop died! java.lang.RuntimeException: Error compiling query” when SAM topology is deployed

New Contributor

I am trying to deploy a simple Topology on Streamline.

Receiving a simple structured information through Kafka and use Identity UDF on Projection processor for later, being sent through Kafka using a different topic (topologia.png).

Why this query cannot be validated? (attached image)

88471-pp54h.png

When the application is deployed, I get this error on worker.log file on Projection processor:

2018-09-03 14:19:04.277 o.a.s.util Thread-8-40-PROJECTION-executor[3 3] [ERROR] Async loop died! java.lang.RuntimeException: Error compiling query. Statements [[CREATE EXTERNAL TABLE RULETABLE ("recordType" VARCHAR, "IMSI" VARCHAR, "IMSI_LENGTH" VARCHAR) LOCATION 'RULESCHEMA:///RULETABLE', SELECT STREAM RULETABLE."recordType", RULETABLE."IMSI", RULETABLE."IMSI_LENGTH" FROM RULETABLE ]] at 
com.hortonworks.streamline.streams.runtime.rule.sql.SqlEngine.compileQuery(SqlEngine.java:56) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.rule.sql.SqlScript.<init>(SqlScript.java:88) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.rule.sql.SqlScript.<init>(SqlScript.java:65) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.processor.RuleProcessorRuntime.createSqlScript(RuleProcessorRuntime.java:245) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.processor.RuleProcessorRuntime.initializeRuleRuntimes(RuleProcessorRuntime.java:156) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.processor.RuleProcessorRuntime.initialize(RuleProcessorRuntime.java:83) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.storm.bolt.rules.RulesBolt.prepare(RulesBolt.java:77) ~[stormjar.jar:?] at 
org.apache.storm.daemon.executor$fn_9633$fn9646.invoke(executor.clj:810) ~[storm-core-1.1.1.3.1.2.0-7.jar:1.1.1.3.1.2.0-7] at 
org.apache.storm.util$async_loop$fn555.invoke(util.clj:482) [storm-core-1.1.1.3.1.2.0-7.jar:1.1.1.3.1.2.0-7] at 
clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] at 
java.lang.Thread.run(Thread.java:745) [?:1.8.0_65] Caused by: java.lang.NullPointerException at 
com.hortonworks.streamline.streams.sql.compiler.javac.CompilingClassLoader.compileSourceCodeToByteCode(CompilingClassLoader.java:147) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.sql.compiler.javac.CompilingClassLoader.<init>(CompilingClassLoader.java:116) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.sql.compiler.PlanCompiler.compile(PlanCompiler.java:126) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.sql.StreamlineSqlImpl.execute(StreamlineSqlImpl.java:86) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.rule.sql.SqlEngine.compileQuery(SqlEngine.java:52) ~[stormjar.jar:?] ... 10 more 

2018-09-03 14:19:04.281 o.a.s.d.executor Thread-8-40-PROJECTION-executor[3 3] [ERROR] java.lang.RuntimeException: Error compiling query. Statements [[CREATE EXTERNAL TABLE RULETABLE ("recordType" VARCHAR, "IMSI" VARCHAR, "IMSI_LENGTH" VARCHAR) LOCATION 'RULESCHEMA:///RULETABLE', SELECT STREAM RULETABLE."recordType", RULETABLE."IMSI", RULETABLE."IMSI_LENGTH" FROM RULETABLE ]] at 
com.hortonworks.streamline.streams.runtime.rule.sql.SqlEngine.compileQuery(SqlEngine.java:56) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.rule.sql.SqlScript.<init>(SqlScript.java:88) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.rule.sql.SqlScript.<init>(SqlScript.java:65) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.processor.RuleProcessorRuntime.createSqlScript(RuleProcessorRuntime.java:245) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.processor.RuleProcessorRuntime.initializeRuleRuntimes(RuleProcessorRuntime.java:156) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.processor.RuleProcessorRuntime.initialize(RuleProcessorRuntime.java:83) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.storm.bolt.rules.RulesBolt.prepare(RulesBolt.java:77) ~[stormjar.jar:?] at 
org.apache.storm.daemon.executor$fn9633$fn9646.invoke(executor.clj:810) ~[storm-core-1.1.1.3.1.2.0-7.jar:1.1.1.3.1.2.0-7] at 
org.apache.storm.util$async_loop$fn555.invoke(util.clj:482) [storm-core-1.1.1.3.1.2.0-7.jar:1.1.1.3.1.2.0-7] at 
clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] at 
java.lang.Thread.run(Thread.java:745) [?:1.8.0_65] Caused by: java.lang.NullPointerException at 
com.hortonworks.streamline.streams.sql.compiler.javac.CompilingClassLoader.compileSourceCodeToByteCode(CompilingClassLoader.java:147) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.sql.compiler.javac.CompilingClassLoader.<init>(CompilingClassLoader.java:116) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.sql.compiler.PlanCompiler.compile(PlanCompiler.java:126) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.sql.StreamlineSqlImpl.execute(StreamlineSqlImpl.java:86) ~[stormjar.jar:?] at 
com.hortonworks.streamline.streams.runtime.rule.sql.SqlEngine.compileQuery(SqlEngine.java:52) ~[stormjar.jar:?] ... 10 more 

2018-09-03 14:19:04.298 o.a.s.util Thread-8-40-PROJECTION-executor[3 3] [ERROR] Halting process: ("Worker died") java.lang.RuntimeException: ("Worker died") at 
org.apache.storm.util$exit_process_BANG.doInvoke(util.clj:341) [storm-core-1.1.1.3.1.2.0-7.jar:1.1.1.3.1.2.0-7] at 
clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?] at 
org.apache.storm.daemon.worker$fn_10241$fn10242.invoke(worker.clj:781) [storm-core-1.1.1.3.1.2.0-7.jar:1.1.1.3.1.2.0-7] at 
rg.apache.storm.daemon.executor$mk_executor_data$fn9448$fn9449.invoke(executor.clj:281) [storm-core-1.1.1.3.1.2.0-7.jar:1.1.1.3.1.2.0-7] at 
org.apache.storm.util$async_loop$fn_555.invoke(util.clj:494) [storm-core-1.1.1.3.1.2.0-7.jar:1.1.1.3.1.2.0-7] at 
clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] at 
java.lang.Thread.run(Thread.java:745) [?:1.8.0_65] 2018-09-03 14:19:04.299 o.a.s.d.worker Thread-21 [INFO] Shutting down worker streamline-1-Application_Mediacion_V1-26-1535992492 8fec64de-2357-47e5-b774-35ea9120a2b7 6700 2018-09-03 14:19:04.300 o.a.s.d.worker Thread-21 [INFO] Terminating messaging context 2018-09-03 14:19:04.300 o.a.s.d.worker Thread-21 [INFO] Shutting down executors

Don't have an account?
Coming from Hortonworks? Activate your account here