@@ -1254,12 +1254,12 @@ public void testUpdateStateByKeyWithInitial() {
12541254 JavaPairRDD <String , Integer > initialRDD = JavaPairRDD .fromJavaRDD (tmpRDD );
12551255
12561256 List <List <Tuple2 <String , Integer >>> expected = Arrays .asList (
1257- Arrays .asList (new Tuple2 <String , Integer >("california" , 4 ),
1258- new Tuple2 <String , Integer >("new york" , 5 )),
1259- Arrays .asList (new Tuple2 <String , Integer >("california" , 14 ),
1260- new Tuple2 <String , Integer >("new york" , 9 )),
1261- Arrays .asList (new Tuple2 <String , Integer >("california" , 14 ),
1262- new Tuple2 <String , Integer >("new york" , 9 )));
1257+ Arrays .asList (new Tuple2 <String , Integer >("california" , 5 ),
1258+ new Tuple2 <String , Integer >("new york" , 7 )),
1259+ Arrays .asList (new Tuple2 <String , Integer >("california" , 15 ),
1260+ new Tuple2 <String , Integer >("new york" , 11 )),
1261+ Arrays .asList (new Tuple2 <String , Integer >("california" , 15 ),
1262+ new Tuple2 <String , Integer >("new york" , 11 )));
12631263
12641264 JavaDStream <Tuple2 <String , Integer >> stream = JavaTestUtils .attachTestInputStream (ssc , inputData , 1 );
12651265 JavaPairDStream <String , Integer > pairStream = JavaPairDStream .fromJavaDStream (stream );
0 commit comments