sbt "org.apache.spark#spark-streaming-kafka_2.11;2.0.0: not found"

2016-12-12 Thread Luke Adolph
Hi all, My project uses spark-streaming-kafka module.When I migrate spark from 1.6.0 to 2.0.0 and rebuild project, I run into below error: [warn] module not found: org.apache.spark#spark-streaming-kafka_2.11;2.0.0 [warn] local: tried [warn]

Re: Dependencies with runing Spark Streaming on Mesos cluster using Python

2016-07-13 Thread Luke Adolph
4:2181 wlu_spark2cassandra' --docker-image > adolphlwq/mesos-for-spark-exector-image:1.6.0.beta2 Where I get new stderr output on mesos: ​ I only problem is submit the dependency spark-streaming-kafka_2.10-1.6.0.jar to worker. Thanks. 2016-07-13 18:57 GMT+08:00 Luke Adolph <kenan3...@gmail.com>:

Dependencies with runing Spark Streaming on Mesos cluster using Python

2016-07-13 Thread Luke Adolph
Hi all: My spark runs on mesos.I write a spark streaming app using python, code on GitHub . The app has dependency "*org.apache.spark:spark-streaming-kafka_2.10:1.6.1* ". Spark on mesos has two important concepts: Spark Framework and Spark

Save RDD to HDFS using Spark Python API

2016-04-26 Thread Luke Adolph
Hi, all: Below is my code: from pyspark import *import re def getDateByLine(input_str): str_pattern = '^\d{4}-\d{2}-\d{2}' pattern = re.compile(str_pattern) match = pattern.match(input_str) if match: return match.group() else: return None file_url =