Я пытаюсь запустить простое искровое потоковое приложение в Java. Но это не удалось на ssc.receiverStream
, показывая Caused by: com.fasterxml.jackson.databind.JsonMappingException: Incompatible Jackson version: 2.9.4
. Я проверил свою версию Джексона, это 2.6.0. Как получается 2.9.4? Ниже скриншот - все внешние библиотеки, которые я использую. Большинство других ответов, связанных с этой проблемой, содержится в scala. Как я могу решить это в java?
SparkConf sparkConf = new SparkConf().setAppName("myCustomizedReceiver").setMaster("local[2]");
JavaStreamingContext ssc = new JavaStreamingContext(sparkConf, new Duration(1000));
JavaReceiverInputDStream<String> lines = ssc.receiverStream(new myCustomizedReceiver());