Shaofeng SHI created KYLIN-1322:
-----------------------------------
Summary: Wrong package name for TimedJsonStreamParser
Key: KYLIN-1322
URL: https://issues.apache.org/jira/browse/KYLIN-1322
Project: Kylin
Issue Type: Bug
Components: Web
Affects Versions: v2.0
Reporter: Shaofeng SHI
Assignee: Zhong,Jason
Get this error when trigger a streaming job with 2.x-staging:
2016-01-15 09:28:58,567 ERROR [main StreamingCLI:97]: error start streaming
java.lang.RuntimeException: failed to create instance of StreamingParser
at
org.apache.kylin.source.kafka.KafkaStreamingInput.getBatchWithTimeWindow(KafkaStreamingInput.java:101)
at
org.apache.kylin.engine.streaming.OneOffStreamingBuilder$1.run(OneOffStreamingBuilder.java:72)
at
org.apache.kylin.engine.streaming.cli.StreamingCLI.startOneOffCubeStreaming(StreamingCLI.java:104)
at
org.apache.kylin.engine.streaming.cli.StreamingCLI.main(StreamingCLI.java:91)
Caused by: java.lang.ClassNotFoundException:
org.apache.kylin.streaming.TimedJsonStreamParser
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:190)
at
org.apache.kylin.source.kafka.StreamingParser.getStreamingParser(StreamingParser.java:82)
at
org.apache.kylin.source.kafka.KafkaStreamingInput.getBatchWithTimeWindow(KafkaStreamingInput.java:74)
... 3 more
And then I found the class has been refactored to package
org.apache.kylin.source.kafka, while the generated JSON is still using the old
package.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
