I have 5 line datas,
i first need to transform current data with SQL
then mix current data and historical data which is batch get from hbase
for some special reason the program must run in batch mode
i think the correct result should be like this：
but the result is :
if i set different parallelism ,the result is different.