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'm trying to deploy a simple Topology on Streamline, receiving a simple structured information through Kafka and use Indentity UDF on Projection processer for later, beign sent throgh Kafka using a diferent topic (topologia.png).

When application is deployed, i get this error on worker.log file on Porjection processer:

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$fn__9646.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$fn__555.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$fn__9633$fn__9646.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$fn__555.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$fn__10242.invoke(worker.clj:781) [storm-core-1.1.1.3.1.2.0-7.jar:1.1.1.3.1.2.0-7] at org.apache.storm.daemon.executor$mk_executor_data$fn__9448$fn__9449.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


Why this query cannot be validated? What can i do to solve this error? Than you a lot!! help!

87532-topologia.png