question: public void testAddDataFromMap ( ) throws Exception { try { binaries = false ; startGrids ( 2 ) ; awaitPartitionMapExchange ( ) ; Ignite g0 = grid ( 0 ) ; IgniteDataStreamer < Integer , String > dataLdr = g0 . dataStreamer ( null ) ; Map < Integer , String > map = U . newHashMap ( KEYS_COUNT ) ; for ( int i = 0 ; i < KEYS_COUNT ; i ++ ) map . put ( i , String . valueOf ( i ) ) ; dataLdr . addData ( map ) ; dataLdr . close ( ) ; checkDistribution ( grid ( 0 ) ) ; checkDistribution ( grid ( 1 ) ) ; Random rnd = new Random ( ) ; IgniteCache < Integer , String > c0 = g0 . cache ( null ) ; for ( int i = 0 ; i < 100 ; i ++ ) { Integer k = rnd . nextInt ( KEYS_COUNT ) ; String v = c0 . get ( k ) ; assertEquals ( k . toString ( ) , v ) ; } } finally { G . stopAll ( true ) ; } }
target:  Data streamer should correctly load entries from HashMap in case of grids with more than one node and with GridOptimizedMarshaller that requires serializable.