Skip to content

StreamingFormulaDemo2 execution

Jump to bottom
Juan Rodriguez Hortala edited this page Jan 12, 2016 · 1 revision 
16/01/11 21:37:14 WARN SharedSparkContext: creating test Spark context
16/01/11 21:37:14 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
16/01/11 21:37:16 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:37:16 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-f75bec74-97f0-44ca-9fb5-e80e65a7e860
16/01/11 21:37:16 WARN DStreamTLProperty: starting test case 0
-------------------------------------------
Time: 1452577037000 ms - InputDStream1 (20 records)
-------------------------------------------
(22,true)
(27,true)
(13,true)
(21,true)
...
-------------------------------------------
Time: 1452577037500 ms - InputDStream1 (20 records)
-------------------------------------------
(47,true)
(36,true)
(7,true)
(29,true)
...
-------------------------------------------
Time: 1452577038000 ms - InputDStream1 (20 records)
-------------------------------------------
(2,true)
(16,true)
(12,true)
(50,true)
...
-------------------------------------------
Time: 1452577038500 ms - InputDStream1 (20 records)
-------------------------------------------
(22,true)
(12,true)
(47,true)
(12,true)
...
-------------------------------------------
Time: 1452577039000 ms - InputDStream1 (21 records)
-------------------------------------------
(30,true)
(37,true)
(40,true)
(1,true)
...
-------------------------------------------
Time: 1452577039500 ms - InputDStream1 (20 records)
-------------------------------------------
(50,true)
(45,true)
(17,true)
(5,true)
...
-------------------------------------------
Time: 1452577040000 ms - InputDStream1 (21 records)
-------------------------------------------
(42,true)
(26,true)
(32,true)
(31,true)
...
16/01/11 21:37:20 WARN BlockManager: Block rdd_85_6 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577040500 ms - InputDStream1 (21 records)
-------------------------------------------
(12,true)
(16,true)
(47,true)
(50,true)
...
-------------------------------------------
Time: 1452577041000 ms - InputDStream1 (20 records)
-------------------------------------------
(12,true)
(26,true)
(8,true)
(34,true)
...
-------------------------------------------
Time: 1452577041500 ms - InputDStream1 (21 records)
-------------------------------------------
(46,true)
(38,true)
(44,true)
(27,true)
...
16/01/11 21:37:21 WARN BlockManager: Block rdd_112_3 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577042000 ms - InputDStream1 (21 records)
-------------------------------------------
(19,true)
(49,true)
(42,true)
(47,true)
...
-------------------------------------------
Time: 1452577042500 ms - InputDStream1 (21 records)
-------------------------------------------
(49,true)
(7,true)
(40,true)
(30,true)
...
-------------------------------------------
Time: 1452577043000 ms - InputDStream1 (21 records)
-------------------------------------------
(39,true)
(7,true)
(41,true)
(7,true)
...
-------------------------------------------
Time: 1452577043500 ms - InputDStream1 (20 records)
-------------------------------------------
(11,true)
(19,true)
(32,true)
(8,true)
...
-------------------------------------------
Time: 1452577044000 ms - InputDStream1 (21 records)
-------------------------------------------
(28,true)
(7,true)
(31,true)
(36,true)
...
16/01/11 21:37:24 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577044500 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:37:24 WARN DStreamTLProperty: finished test case 0 with result True
16/01/11 21:37:24 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:37:24 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-8f681399-e339-4e6c-964d-5fe63e8e502f
16/01/11 21:37:24 WARN DStreamTLProperty: starting test case 1
-------------------------------------------
Time: 1452577045000 ms - InputDStream1 (20 records)
-------------------------------------------
(41,true)
(8,true)
(41,true)
(20,true)
...
-------------------------------------------
Time: 1452577045500 ms - InputDStream1 (20 records)
-------------------------------------------
(35,true)
(8,true)
(46,true)
(50,true)
...
-------------------------------------------
Time: 1452577046000 ms - InputDStream1 (20 records)
-------------------------------------------
(2,true)
(50,true)
(43,true)
(26,true)
...
-------------------------------------------
Time: 1452577046500 ms - InputDStream1 (20 records)
-------------------------------------------
(31,true)
(12,true)
(18,true)
(23,true)
...
-------------------------------------------
Time: 1452577047000 ms - InputDStream1 (20 records)
-------------------------------------------
(49,true)
(20,true)
(47,true)
(15,true)
...
-------------------------------------------
Time: 1452577047500 ms - InputDStream1 (20 records)
-------------------------------------------
(20,true)
(35,true)
(46,true)
(1,true)
...
-------------------------------------------
Time: 1452577048000 ms - InputDStream1 (20 records)
-------------------------------------------
(13,true)
(34,true)
(20,true)
(5,true)
...
-------------------------------------------
Time: 1452577048500 ms - InputDStream1 (20 records)
-------------------------------------------
(38,true)
(42,true)
(18,true)
(46,true)
...
-------------------------------------------
Time: 1452577049000 ms - InputDStream1 (21 records)
-------------------------------------------
(48,true)
(28,true)
(27,true)
(27,true)
...
-------------------------------------------
Time: 1452577049500 ms - InputDStream1 (21 records)
-------------------------------------------
(35,true)
(8,true)
(14,true)
(10,true)
...
-------------------------------------------
Time: 1452577050000 ms - InputDStream1 (21 records)
-------------------------------------------
(35,true)
(49,true)
(45,true)
(17,true)
...
-------------------------------------------
Time: 1452577050500 ms - InputDStream1 (20 records)
-------------------------------------------
(9,true)
(8,true)
(27,true)
(26,true)
...
-------------------------------------------
Time: 1452577051000 ms - InputDStream1 (21 records)
-------------------------------------------
(41,true)
(4,true)
(30,true)
(16,true)
...
16/01/11 21:37:31 WARN BlockManager: Block rdd_296_4 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577051500 ms - InputDStream1 (20 records)
-------------------------------------------
(29,true)
(32,true)
(6,true)
(45,true)
...
-------------------------------------------
Time: 1452577052000 ms - InputDStream1 (21 records)
-------------------------------------------
(6,true)
(15,true)
(47,true)
(13,true)
...
-------------------------------------------
Time: 1452577052500 ms - InputDStream1 (21 records)
-------------------------------------------
(24,true)
(2,true)
(34,true)
(33,true)
...
-------------------------------------------
Time: 1452577053000 ms - InputDStream1 (20 records)
-------------------------------------------
(21,true)
(14,true)
(27,true)
(24,true)
...
-------------------------------------------
Time: 1452577053500 ms - InputDStream1 (20 records)
-------------------------------------------
(6,true)
(7,true)
(3,true)
(16,true)
...
-------------------------------------------
Time: 1452577054000 ms - InputDStream1 (20 records)
-------------------------------------------
(40,true)
(44,true)
(34,true)
(29,true)
...
16/01/11 21:37:34 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577054500 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:37:34 WARN DStreamTLProperty: finished test case 1 with result True
16/01/11 21:37:34 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:37:34 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-24990123-9567-4e20-81cd-7dd06fb56de7
16/01/11 21:37:34 WARN DStreamTLProperty: starting test case 2
-------------------------------------------
Time: 1452577055000 ms - InputDStream1 (20 records)
-------------------------------------------
(4,true)
(6,true)
(47,true)
(15,true)
...
16/01/11 21:37:35 WARN BlockManager: Block rdd_338_2 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577055500 ms - InputDStream1 (20 records)
-------------------------------------------
(40,true)
(17,true)
(38,true)
(32,true)
...
-------------------------------------------
Time: 1452577056000 ms - InputDStream1 (21 records)
-------------------------------------------
(9,true)
(38,true)
(40,true)
(7,true)
...
-------------------------------------------
Time: 1452577056500 ms - InputDStream1 (21 records)
-------------------------------------------
(8,true)
(23,true)
(4,true)
(5,true)
...
16/01/11 21:37:36 WARN BlockManager: Block rdd_386_1 already exists on this machine; not re-adding it
16/01/11 21:37:36 WARN BlockManager: Block rdd_386_2 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577057000 ms - InputDStream1 (21 records)
-------------------------------------------
(17,true)
(31,true)
(15,true)
(2,true)
...
-------------------------------------------
Time: 1452577057500 ms - InputDStream1 (21 records)
-------------------------------------------
(35,true)
(8,true)
(49,true)
(15,true)
...
-------------------------------------------
Time: 1452577058000 ms - InputDStream1 (21 records)
-------------------------------------------
(42,true)
(26,true)
(30,true)
(2,true)
...
-------------------------------------------
Time: 1452577058500 ms - InputDStream1 (21 records)
-------------------------------------------
(33,true)
(28,true)
(30,true)
(4,true)
...
-------------------------------------------
Time: 1452577059000 ms - InputDStream1 (21 records)
-------------------------------------------
(2,true)
(40,true)
(25,true)
(34,true)
...
-------------------------------------------
Time: 1452577059500 ms - InputDStream1 (21 records)
-------------------------------------------
(29,true)
(5,true)
(9,true)
(32,true)
...
-------------------------------------------
Time: 1452577060000 ms - InputDStream1 (20 records)
-------------------------------------------
(48,true)
(31,true)
(45,true)
(7,true)
...
-------------------------------------------
Time: 1452577060500 ms - InputDStream1 (20 records)
-------------------------------------------
(29,true)
(16,true)
(47,true)
(30,true)
...
16/01/11 21:37:40 WARN BlockManager: Block rdd_466_5 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577061000 ms - InputDStream1 (20 records)
-------------------------------------------
(9,true)
(45,true)
(47,true)
(19,true)
...
16/01/11 21:37:41 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577061500 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:37:41 WARN DStreamTLProperty: finished test case 2 with result Undecided
16/01/11 21:37:41 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:37:41 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-1ed2d400-ea8d-4000-9a26-0fa6797b5923
16/01/11 21:37:41 WARN DStreamTLProperty: starting test case 3
-------------------------------------------
Time: 1452577062000 ms - InputDStream1 (21 records)
-------------------------------------------
(41,true)
(32,true)
(12,true)
(36,true)
...
-------------------------------------------
Time: 1452577062500 ms - InputDStream1 (21 records)
-------------------------------------------
(5,true)
(6,true)
(42,true)
(48,true)
...
-------------------------------------------
Time: 1452577063000 ms - InputDStream1 (21 records)
-------------------------------------------
(41,true)
(22,true)
(42,true)
(12,true)
...
-------------------------------------------
Time: 1452577063500 ms - InputDStream1 (20 records)
-------------------------------------------
(20,true)
(29,true)
(20,true)
(27,true)
...
-------------------------------------------
Time: 1452577064000 ms - InputDStream1 (21 records)
-------------------------------------------
(4,true)
(33,true)
(34,true)
(8,true)
...
-------------------------------------------
Time: 1452577064500 ms - InputDStream1 (21 records)
-------------------------------------------
(42,true)
(21,true)
(7,true)
(31,true)
...
-------------------------------------------
Time: 1452577065000 ms - InputDStream1 (20 records)
-------------------------------------------
(29,true)
(15,true)
(31,true)
(5,true)
...
-------------------------------------------
Time: 1452577065500 ms - InputDStream1 (21 records)
-------------------------------------------
(5,true)
(44,true)
(31,true)
(50,true)
...
16/01/11 21:37:45 WARN BlockManager: Block rdd_559_2 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577066000 ms - InputDStream1 (20 records)
-------------------------------------------
(13,true)
(28,true)
(43,true)
(36,true)
...
16/01/11 21:37:46 WARN BlockManager: Block rdd_568_1 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577066500 ms - InputDStream1 (20 records)
-------------------------------------------
(16,true)
(40,true)
(21,true)
(7,true)
...
-------------------------------------------
Time: 1452577067000 ms - InputDStream1 (21 records)
-------------------------------------------
(45,true)
(15,true)
(48,true)
(28,true)
...
16/01/11 21:37:47 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577067500 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:37:47 WARN DStreamTLProperty: finished test case 3 with result Undecided
16/01/11 21:37:47 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:37:47 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-dea31983-e96f-440a-b7fc-d85504a7fe74
16/01/11 21:37:47 WARN DStreamTLProperty: starting test case 4
-------------------------------------------
Time: 1452577068000 ms - InputDStream1 (20 records)
-------------------------------------------
(9,true)
(49,true)
(36,true)
(42,true)
...
-------------------------------------------
Time: 1452577068500 ms - InputDStream1 (21 records)
-------------------------------------------
(20,true)
(8,true)
(16,true)
(26,true)
...
-------------------------------------------
Time: 1452577069000 ms - InputDStream1 (21 records)
-------------------------------------------
(29,true)
(41,true)
(32,true)
(32,true)
...
-------------------------------------------
Time: 1452577069500 ms - InputDStream1 (20 records)
-------------------------------------------
(39,true)
(27,true)
(24,true)
(44,true)
...
-------------------------------------------
Time: 1452577070000 ms - InputDStream1 (20 records)
-------------------------------------------
(5,true)
(35,true)
(3,true)
(49,true)
...
-------------------------------------------
Time: 1452577070500 ms - InputDStream1 (20 records)
-------------------------------------------
(41,true)
(13,true)
(33,true)
(17,true)
...
-------------------------------------------
Time: 1452577071000 ms - InputDStream1 (21 records)
-------------------------------------------
(23,true)
(48,true)
(7,true)
(33,true)
...
-------------------------------------------
Time: 1452577071500 ms - InputDStream1 (21 records)
-------------------------------------------
(3,true)
(32,true)
(40,true)
(33,true)
...
-------------------------------------------
Time: 1452577072000 ms - InputDStream1 (21 records)
-------------------------------------------
(18,true)
(8,true)
(27,true)
(34,true)
...
-------------------------------------------
Time: 1452577072500 ms - InputDStream1 (21 records)
-------------------------------------------
(23,true)
(46,true)
(42,true)
(30,true)
...
-------------------------------------------
Time: 1452577073000 ms - InputDStream1 (21 records)
-------------------------------------------
(1,true)
(29,true)
(38,true)
(45,true)
...
-------------------------------------------
Time: 1452577073500 ms - InputDStream1 (21 records)
-------------------------------------------
(38,true)
(45,true)
(33,true)
(31,true)
...
16/01/11 21:37:53 WARN BlockManager: Block rdd_709_2 already exists on this machine; not re-adding it
16/01/11 21:37:53 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577074000 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:37:54 WARN DStreamTLProperty: finished test case 4 with result Undecided
16/01/11 21:37:54 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:37:54 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-0f105115-4039-4281-9326-025987a4b2c4
16/01/11 21:37:54 WARN DStreamTLProperty: starting test case 5
-------------------------------------------
Time: 1452577074500 ms - InputDStream1 (21 records)
-------------------------------------------
(34,true)
(33,true)
(46,true)
(17,true)
...
-------------------------------------------
Time: 1452577075000 ms - InputDStream1 (20 records)
-------------------------------------------
(32,true)
(49,true)
(45,true)
(39,true)
...
-------------------------------------------
Time: 1452577075500 ms - InputDStream1 (20 records)
-------------------------------------------
(29,true)
(42,true)
(36,true)
(24,true)
...
-------------------------------------------
Time: 1452577076000 ms - InputDStream1 (21 records)
-------------------------------------------
(36,true)
(28,true)
(47,true)
(41,true)
...
-------------------------------------------
Time: 1452577076500 ms - InputDStream1 (20 records)
-------------------------------------------
(26,true)
(43,true)
(3,true)
(12,true)
...
-------------------------------------------
Time: 1452577077000 ms - InputDStream1 (21 records)
-------------------------------------------
(36,true)
(7,true)
(16,true)
(3,true)
...
-------------------------------------------
Time: 1452577077500 ms - InputDStream1 (21 records)
-------------------------------------------
(1,true)
(23,true)
(25,true)
(9,true)
...
-------------------------------------------
Time: 1452577078000 ms - InputDStream1 (21 records)
-------------------------------------------
(20,true)
(6,true)
(35,true)
(37,true)
...
-------------------------------------------
Time: 1452577078500 ms - InputDStream1 (20 records)
-------------------------------------------
(45,true)
(30,true)
(27,true)
(22,true)
...
-------------------------------------------
Time: 1452577079000 ms - InputDStream1 (20 records)
-------------------------------------------
(38,true)
(32,true)
(44,true)
(35,true)
...
-------------------------------------------
Time: 1452577079500 ms - InputDStream1 (20 records)
-------------------------------------------
(45,true)
(48,true)
(1,true)
(2,true)
...
16/01/11 21:37:59 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577080000 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:38:00 WARN DStreamTLProperty: finished test case 5 with result Undecided
16/01/11 21:38:00 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:38:00 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-996767cb-9b0f-46b2-989c-4181178329a7
16/01/11 21:38:00 WARN DStreamTLProperty: starting test case 6
-------------------------------------------
Time: 1452577080500 ms - InputDStream1 (20 records)
-------------------------------------------
(14,true)
(3,true)
(17,true)
(25,true)
...
-------------------------------------------
Time: 1452577081000 ms - InputDStream1 (20 records)
-------------------------------------------
(21,true)
(14,true)
(21,true)
(34,true)
...
-------------------------------------------
Time: 1452577081500 ms - InputDStream1 (20 records)
-------------------------------------------
(26,true)
(14,true)
(30,true)
(38,true)
...
-------------------------------------------
Time: 1452577082000 ms - InputDStream1 (21 records)
-------------------------------------------
(4,true)
(12,true)
(38,true)
(1,true)
...
-------------------------------------------
Time: 1452577082500 ms - InputDStream1 (21 records)
-------------------------------------------
(36,true)
(29,true)
(15,true)
(8,true)
...
16/01/11 21:38:02 WARN BlockManager: Block rdd_891_2 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577083000 ms - InputDStream1 (20 records)
-------------------------------------------
(11,true)
(15,true)
(32,true)
(46,true)
...
-------------------------------------------
Time: 1452577083500 ms - InputDStream1 (21 records)
-------------------------------------------
(23,true)
(30,true)
(7,true)
(31,true)
...
-------------------------------------------
Time: 1452577084000 ms - InputDStream1 (21 records)
-------------------------------------------
(39,true)
(48,true)
(10,true)
(3,true)
...
-------------------------------------------
Time: 1452577084500 ms - InputDStream1 (21 records)
-------------------------------------------
(49,true)
(46,true)
(27,true)
(36,true)
...
-------------------------------------------
Time: 1452577085000 ms - InputDStream1 (20 records)
-------------------------------------------
(21,true)
(18,true)
(5,true)
(29,true)
...
16/01/11 21:38:05 WARN BlockManager: Block rdd_937_6 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577085500 ms - InputDStream1 (21 records)
-------------------------------------------
(27,true)
(17,true)
(32,true)
(40,true)
...
-------------------------------------------
Time: 1452577086000 ms - InputDStream1 (20 records)
-------------------------------------------
(1,true)
(48,true)
(48,true)
(43,true)
...
-------------------------------------------
Time: 1452577086500 ms - InputDStream1 (21 records)
-------------------------------------------
(29,true)
(22,true)
(7,true)
(2,true)
...
-------------------------------------------
Time: 1452577087000 ms - InputDStream1 (21 records)
-------------------------------------------
(14,true)
(37,true)
(30,true)
(47,true)
...
16/01/11 21:38:07 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577087500 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:38:07 WARN DStreamTLProperty: finished test case 6 with result True
16/01/11 21:38:07 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:38:07 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-cebaacc9-9bda-4f81-9ac1-8f3188a36f37
16/01/11 21:38:07 WARN DStreamTLProperty: starting test case 7
-------------------------------------------
Time: 1452577088000 ms - InputDStream1 (20 records)
-------------------------------------------
(30,true)
(29,true)
(40,true)
(37,true)
...
-------------------------------------------
Time: 1452577088500 ms - InputDStream1 (20 records)
-------------------------------------------
(11,true)
(5,true)
(10,true)
(29,true)
...
-------------------------------------------
Time: 1452577089000 ms - InputDStream1 (20 records)
-------------------------------------------
(4,true)
(20,true)
(19,true)
(45,true)
...
-------------------------------------------
Time: 1452577089500 ms - InputDStream1 (21 records)
-------------------------------------------
(29,true)
(43,true)
(28,true)
(47,true)
...
-------------------------------------------
Time: 1452577090000 ms - InputDStream1 (21 records)
-------------------------------------------
(32,true)
(13,true)
(26,true)
(10,true)
...
16/01/11 21:38:10 WARN BlockManager: Block rdd_1039_2 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577090500 ms - InputDStream1 (20 records)
-------------------------------------------
(33,true)
(23,true)
(18,true)
(35,true)
...
-------------------------------------------
Time: 1452577091000 ms - InputDStream1 (21 records)
-------------------------------------------
(8,true)
(39,true)
(12,true)
(23,true)
...
-------------------------------------------
Time: 1452577091500 ms - InputDStream1 (20 records)
-------------------------------------------
(34,true)
(40,true)
(48,true)
(21,true)
...
-------------------------------------------
Time: 1452577092000 ms - InputDStream1 (21 records)
-------------------------------------------
(12,true)
(20,true)
(2,true)
(29,true)
...
16/01/11 21:38:12 WARN BlockManager: Block rdd_1075_6 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577092500 ms - InputDStream1 (21 records)
-------------------------------------------
(49,true)
(11,true)
(18,true)
(39,true)
...
-------------------------------------------
Time: 1452577093000 ms - InputDStream1 (21 records)
-------------------------------------------
(19,true)
(38,true)
(29,true)
(23,true)
...
-------------------------------------------
Time: 1452577093500 ms - InputDStream1 (20 records)
-------------------------------------------
(5,true)
(32,true)
(30,true)
(24,true)
...
-------------------------------------------
Time: 1452577094000 ms - InputDStream1 (20 records)
-------------------------------------------
(33,true)
(47,true)
(37,true)
(12,true)
...
16/01/11 21:38:14 WARN BlockManager: Block rdd_1108_1 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577094500 ms - InputDStream1 (20 records)
-------------------------------------------
(41,true)
(15,true)
(22,true)
(35,true)
...
16/01/11 21:38:14 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577095000 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:38:15 WARN DStreamTLProperty: finished test case 7 with result True
16/01/11 21:38:15 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:38:15 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-77ae07e3-c6b1-4a41-860a-8cf30a836a7a
16/01/11 21:38:15 WARN DStreamTLProperty: starting test case 8
-------------------------------------------
Time: 1452577095500 ms - InputDStream1 (20 records)
-------------------------------------------
(10,true)
(24,true)
(39,true)
(42,true)
...
-------------------------------------------
Time: 1452577096000 ms - InputDStream1 (20 records)
-------------------------------------------
(12,true)
(22,true)
(9,true)
(24,true)
...
-------------------------------------------
Time: 1452577096500 ms - InputDStream1 (20 records)
-------------------------------------------
(15,true)
(19,true)
(25,true)
(7,true)
...
-------------------------------------------
Time: 1452577097000 ms - InputDStream1 (20 records)
-------------------------------------------
(13,true)
(26,true)
(33,true)
(20,true)
...
-------------------------------------------
Time: 1452577097500 ms - InputDStream1 (20 records)
-------------------------------------------
(3,true)
(9,true)
(48,true)
(2,true)
...
-------------------------------------------
Time: 1452577098000 ms - InputDStream1 (20 records)
-------------------------------------------
(25,true)
(21,true)
(39,true)
(25,true)
...
16/01/11 21:38:18 WARN BlockManager: Block rdd_1200_7 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577098500 ms - InputDStream1 (20 records)
-------------------------------------------
(29,true)
(34,true)
(48,true)
(17,true)
...
-------------------------------------------
Time: 1452577099000 ms - InputDStream1 (20 records)
-------------------------------------------
(17,true)
(33,true)
(34,true)
(21,true)
...
-------------------------------------------
Time: 1452577099500 ms - InputDStream1 (21 records)
-------------------------------------------
(34,true)
(6,true)
(42,true)
(23,true)
...
-------------------------------------------
Time: 1452577100000 ms - InputDStream1 (20 records)
-------------------------------------------
(35,true)
(13,true)
(35,true)
(46,true)
...
-------------------------------------------
Time: 1452577100500 ms - InputDStream1 (20 records)
-------------------------------------------
(9,true)
(14,true)
(5,true)
(35,true)
...
-------------------------------------------
Time: 1452577101000 ms - InputDStream1 (21 records)
-------------------------------------------
(31,true)
(29,true)
(16,true)
(3,true)
...
-------------------------------------------
Time: 1452577101500 ms - InputDStream1 (21 records)
-------------------------------------------
(48,true)
(6,true)
(26,true)
(45,true)
...
-------------------------------------------
Time: 1452577102000 ms - InputDStream1 (21 records)
-------------------------------------------
(30,true)
(34,true)
(7,true)
(3,true)
...
-------------------------------------------
Time: 1452577102500 ms - InputDStream1 (21 records)
-------------------------------------------
(17,true)
(26,true)
(23,true)
(30,true)
...
-------------------------------------------
Time: 1452577103000 ms - InputDStream1 (20 records)
-------------------------------------------
(38,true)
(44,true)
(49,true)
(42,true)
...
-------------------------------------------
Time: 1452577103500 ms - InputDStream1 (20 records)
-------------------------------------------
(49,true)
(44,true)
(1,true)
(2,true)
...
-------------------------------------------
Time: 1452577104000 ms - InputDStream1 (21 records)
-------------------------------------------
(36,true)
(39,true)
(4,true)
(42,true)
...
-------------------------------------------
Time: 1452577104500 ms - InputDStream1 (21 records)
-------------------------------------------
(42,true)
(15,true)
(48,true)
(2,true)
...
16/01/11 21:38:24 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577105000 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:38:25 WARN DStreamTLProperty: finished test case 8 with result True
16/01/11 21:38:25 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:38:25 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-b1a34934-0ec2-4b6b-8c42-9892a77bb1a2
16/01/11 21:38:25 WARN DStreamTLProperty: starting test case 9
-------------------------------------------
Time: 1452577105500 ms - InputDStream1 (20 records)
-------------------------------------------
(31,true)
(38,true)
(43,true)
(1,true)
...
-------------------------------------------
Time: 1452577106000 ms - InputDStream1 (20 records)
-------------------------------------------
(12,true)
(6,true)
(5,true)
(50,true)
...
-------------------------------------------
Time: 1452577106500 ms - InputDStream1 (21 records)
-------------------------------------------
(6,true)
(23,true)
(50,true)
(20,true)
...
-------------------------------------------
Time: 1452577107000 ms - InputDStream1 (21 records)
-------------------------------------------
(43,true)
(7,true)
(48,true)
(1,true)
...
-------------------------------------------
Time: 1452577107500 ms - InputDStream1 (21 records)
-------------------------------------------
(5,true)
(19,true)
(41,true)
(24,true)
...
-------------------------------------------
Time: 1452577108000 ms - InputDStream1 (20 records)
-------------------------------------------
(5,true)
(4,true)
(49,true)
(28,true)
...
-------------------------------------------
Time: 1452577108500 ms - InputDStream1 (20 records)
-------------------------------------------
(34,true)
(38,true)
(17,true)
(44,true)
...
16/01/11 21:38:28 WARN BlockManager: Block rdd_1377_0 already exists on this machine; not re-adding it
-------------------------------------------
Time: 1452577109000 ms - InputDStream1 (21 records)
-------------------------------------------
(47,true)
(2,true)
(50,true)
(43,true)
...
-------------------------------------------
Time: 1452577109500 ms - InputDStream1 (20 records)
-------------------------------------------
(20,true)
(18,true)
(19,true)
(19,true)
...
-------------------------------------------
Time: 1452577110000 ms - InputDStream1 (20 records)
-------------------------------------------
(13,true)
(42,true)
(38,true)
(21,true)
...
-------------------------------------------
Time: 1452577110500 ms - InputDStream1 (21 records)
-------------------------------------------
(14,true)
(36,true)
(22,true)
(35,true)
...
-------------------------------------------
Time: 1452577111000 ms - InputDStream1 (20 records)
-------------------------------------------
(47,true)
(45,true)
(23,true)
(10,true)
...
-------------------------------------------
Time: 1452577111500 ms - InputDStream1 (21 records)
-------------------------------------------
(20,true)
(12,true)
(14,true)
(21,true)
...
16/01/11 21:38:31 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577112000 ms - InputDStream1 (0 records)
-------------------------------------------

...
16/01/11 21:38:32 WARN DStreamTLProperty: finished test case 9 with result True
16/01/11 21:38:32 WARN DStreamTLProperty: creating test Spark Streaming context
16/01/11 21:38:32 WARN DStreamTLProperty: configuring Spark Streaming checkpoint directory C:\Users\juanrh\AppData\Local\Temp\spark-9af1b26d-faf2-4b72-b9a5-964d7ea4ca66
16/01/11 21:38:32 WARN DStreamTLProperty: starting test case 0
-------------------------------------------
Time: 1452577112500 ms - InputDStream1 (20 records)
-------------------------------------------
(6,true)
(3,true)
(19,true)
(5,true)
...
16/01/11 21:38:32 WARN DStreamTLProperty: stopping test Spark Streaming context
-------------------------------------------
Time: 1452577113000 ms - InputDStream1 (20 records)
-------------------------------------------
(5,true)
(29,true)
(45,true)
(42,true)
...
16/01/11 21:38:33 WARN DStreamTLProperty: finished test case 0 with result False
16/01/11 21:38:33 WARN SharedSparkContext: stopping test Spark context

Clone this wiki locally