Я пытаюсь развернуть простую топологию в Streamline.
Получение простой структурированной информации через Kafka и использование Identity UDF на процессоре Projection для последующей отправки через Kafka с использованием другой темы (topologia.png).
При развертывании приложения я получаю эту ошибку в файле worker.log на процессоре Projection:
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
Почему этот запрос не может быть проверен?
