Thanks Shixiong, I am not getting any error and telnet is also working fine.
$ telnet
Trying 192.168.186.97...
Connected to ttsv-
On Mon, Feb 22, 2016 at 1:10 PM, Shixiong(Ryan) Zhu wrote:
> What's the error info reported by Streaming? And could you use "telnet" to
> test if the network
What's the error info reported by Streaming? And could you use "telnet" to
test if the network is normal?
On Mon, Feb 22, 2016 at 6:59 AM, Vinti Maheshwari
wrote:
> For reference, my program:
>
> def main(args: Array[String]): Unit = {
> val conf = new SparkConf().setAppName("HBaseStream")
>
For reference, my program:
def main(args: Array[String]): Unit = {
val conf = new SparkConf().setAppName("HBaseStream")
val sc = new SparkContext(conf)
// create a StreamingContext, the main entry point for all
streaming functionality
val ssc = new StreamingContext(sc, Seconds(2))
