[KYLIN-1322] Wrong package name for TimedJsonStreamParser

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: v1.4.0
• Component/s: Web
• Assignee: Jason Zhong
• Reporter: Shao Feng Shi
• Created: 15/Jan/16 09:34
• Updated: 09/Aug/17 07:45
• Resolved: 18/Jan/16 04:57

Description

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.