Hi, i have a problem,a dataStream read from rabbitMQ,and others data from a
hbase table,which is a dataSet.Those two data from follow:
val words=connectHelper.readFromRabbitMq(...) // words is
DataStream[String] val dataSet=HBaseWrite.fullScan(....) //dataSet is
DataSet[(int,String)]
words.map{ word => val res = dataSet.map{ y =>
val score = computerScore(x,y) (word,score) }
HBaseWrite.writeToTable(res,...,) }
the error is task not serializable,what is the solution? under a
DataStream, how to operate a DataSet?
