- SplitStream working in local machine for single variable broadcast - Removed delays before publishing and receiving. - Commented out some prints.
- SplitStream working in local machine for single variable broadcast
- Removed delays before publishing and receiving.
- Commented out some prints.

MLnick/spark,Aegeaner/spark,ioana-delaney/spark,mdespriee/spark,dongjoon-hyun/spark,rednaxelafx/apache-spark,jianran/spark,SHASHANKB/spark,nlalevee/spark,kissmetrics/spark,dongjoon-hyun/spark,zuotingbing/spark,minixalpha/spark,rezasafi/spark,spark-test/spark,MLnick/spark,cloud-fan/spark,taroplus/spark,liutang123/spark,narahari92/spark,markhamstra/spark,andrewor14/iolap,rjpower/spark,gengliangwang/spark,LantaoJin/spark,dbtsai/spark,lyogavin/spark,maropu/spark,WindCanDie/spark,ddna1021/spark,Panos-Bletsos/spark-cost-model-optimizer,xflin/spark,big-pegasus/spark,LantaoJin/spark,SnappyDataInc/spark,panfengfeng/spark,huang1900/spark,javelinjs/spark,liutang123/spark,rednaxelafx/apache-spark,zhouyejoe/spark,zero323/spark,lyogavin/spark,MLnick/spark,bOOm-X/spark,darionyaphet/spark,xuanyuanking/spark,loneknightpy/spark,cin/spark,esi-mineset/spark,koeninger/spark,jianran/spark,aray/spark,highfei2011/spark,shuangshuangwang/spark,aray/spark,ioana-delaney/spark,saturday-shi/spark,yanboliang/spark,vinodkc/spark,ddna1021/spark,shuangshuangwang/spark,vinodkc/spark,mzl9039/spark,jianran/spark,eyalfa/spark,actuaryzhang/spark,rikima/spark,stanzhai/spark,1haodian/spark,highfei2011/spark,sahilTakiar/spark,debugger87/spark,techaddict/spark,wzhfy/spark,rekhajoshm/spark,ahnqirage/spark,srowen/spark,nlalevee/spark,goldmedal/spark,kimoonkim/spark,ddna1021/spark,lyogavin/spark,akopich/spark,joseph-torres/spark,maropu/spark,kevinyu98/spark,cloud-fan/spark,brad-kaiser/spark,holdenk/spark,rekhajoshm/spark,nilsgrabbert/spark,ericvandenbergfb/spark,Aegeaner/spark,janewangfb/spark,ueshin/apache-spark,caneGuy/spark,jianran/spark,zzcclp/spark,pronix/spark,spark-test/spark,wzhfy/spark,darionyaphet/spark,michalsenkyr/spark,ueshin/apache-spark,actuaryzhang/spark,wangyum/spark,loneknightpy/spark,Aegeaner/spark,markhamstra/spark,HyukjinKwon/spark,mkolod/incubator-spark,tengpeng/spark,narahari92/spark,stanzhai/spark,patrick-nicholson/spark,zzcclp/spark,icexelloss/spark,mdespriee/spark,eyalfa/spark,setjet/spark,ConeyLiu/spark,matthewfranglen/spark,dhruve/spark,debugger87/spark,facaiy/spark,shubhamchopra/spark,lvdongr/spark,JoshRosen/spark,kimoonkim/spark,witgo/spark,publicRoman/spark,liutang123/spark,rednaxelafx/apache-spark,ddna1021/spark,HyukjinKwon/spark,actuaryzhang/spark,ajaysaini725/spark,andrewor14/iolap,lvdongr/spark,nilsgrabbert/spark,sachintyagi22/spark,apache-spark-on-k8s/spark,sahilTakiar/spark,Panos-Bletsos/spark-cost-model-optimizer,byakuinss/spark,jlopezmalla/spark,actuaryzhang/spark,bOOm-X/spark,someorz/spark,rezasafi/spark,sahilTakiar/spark,hvanhovell/spark,vax11780/spark,cloudera/spark,MLnick/spark,saltstar/spark,zzcclp/spark,dhruve/spark,eyalfa/spark,saturday-shi/spark,bravo-zhang/spark,janewangfb/spark,mahak/spark,cin/spark,ConeyLiu/spark,akopich/spark,sahilTakiar/spark,brad-kaiser/spark,BryanCutler/spark,xflin/spark,hhbyyh/spark,shuangshuangwang/spark,jlopezmalla/spark,lvdongr/spark,zero323/spark,aosagie/spark,JerryLead/spark,aosagie/spark,guoxiaolongzte/spark,dbtsai/spark,aray/spark,liutang123/spark,bdrillard/spark,setjet/spark,WeichenXu123/spark,highfei2011/spark,setjet/spark,loneknightpy/spark,alunarbeach/spark,wangyum/spark,spark-test/spark,joseph-torres/spark,stanzhai/spark,holdenk/spark,taroplus/spark,ericvandenbergfb/spark,facaiy/spark,gioenn/xSpark,michalsenkyr/spark,narahari92/spark,ron8hu/spark,gioenn/xSpark,zhouyejoe/spark,huang1900/spark,ericvandenbergfb/spark,mahak/spark,UndeadBaneGitHub/spark,janewangfb/spark,holdenk/spark,ioana-delaney/spark,gengliangwang/spark,srowen/spark,jrshust/spark,debugger87/spark,shaneknapp/spark,sachintyagi22/spark,WeichenXu123/spark,lxsmnv/spark,lxsmnv/spark,sureshthalamati/spark,spark-test/spark,kiszk/spark,jkbradley/spark,wzhfy/spark,brad-kaiser/spark,gioenn/xSpark,bOOm-X/spark,cloudera/spark,lxsmnv/spark,techaddict/spark,joseph-torres/spark,michalsenkyr/spark,dongjoon-hyun/spark,minixalpha/spark,sryza/spark,jiangxb1987/spark,HyukjinKwon/spark,zuotingbing/spark,gengliangwang/spark,mdespriee/spark,jrshust/spark,someorz/spark,panfengfeng/spark,WeichenXu123/spark,ddna1021/spark,apache-spark-on-k8s/spark,guoxiaolongzte/spark,wangmiao1981/spark,icexelloss/spark,ueshin/apache-spark,szhem/spark,witgo/spark,JerryLead/spark,WeichenXu123/spark,apache/spark,BryanCutler/spark,dotunolafunmiloye/spark,patrick-nicholson/spark,yanboliang/spark,gengliangwang/spark,wangmiao1981/spark,szhem/spark,big-pegasus/spark,huang1900/spark,wgpshashank/spark,Panos-Bletsos/spark-cost-model-optimizer,ptkool/spark,saltstar/spark,nlalevee/spark,gioenn/xSpark,sachintyagi22/spark,milliman/spark,kevinyu98/spark,1haodian/spark,highfei2011/spark,ajaysaini725/spark,kevinyu98/spark,ron8hu/spark,chuckchen/spark,chuckchen/spark,ibm-research-ireland/sparkoscope,aokolnychyi/spark,mzl9039/spark,vinodkc/spark,ConeyLiu/spark,setjet/spark,esi-mineset/spark,jkbradley/spark,janewangfb/spark,bOOm-X/spark,witgo/spark,jrshust/spark,bravo-zhang/spark,LantaoJin/spark,pronix/spark,ConeyLiu/spark,markhamstra/spark,nchammas/spark,nchammas/spark,bOOm-X/spark,nchammas/spark,goldmedal/spark,panfengfeng/spark,icexelloss/spark,big-pegasus/spark,chuckchen/spark,koeninger/spark,Panos-Bletsos/spark-cost-model-optimizer,cloudera/spark,zzcclp/spark,caneGuy/spark,tejasapatil/spark,bdrillard/spark,1haodian/spark,xflin/spark,SnappyDataInc/spark,maropu/spark,UndeadBaneGitHub/spark,xflin/spark,tengpeng/spark,JoshRosen/spark,aray/spark,poffuomo/spark,rednaxelafx/apache-spark,bdrillard/spark,ioana-delaney/spark,wangyum/spark,SnappyDataInc/spark,eyalfa/spark,LantaoJin/spark,shaneknapp/spark,skonto/spark,SnappyDataInc/spark,rekhajoshm/spark,highfei2011/spark,darionyaphet/spark,tengpeng/spark,BryanCutler/spark,wangmiao1981/spark,zzcclp/spark,taroplus/spark,sachintyagi22/spark,bdrillard/spark,debugger87/spark,mike0sv/spark,taroplus/spark,ibm-research-ireland/sparkoscope,dongjoon-hyun/spark,kissmetrics/spark,milliman/spark,wgpshashank/spark,maropu/spark,michalsenkyr/spark,sachintyagi22/spark,rjpower/spark,kimoonkim/spark,nchammas/spark,rezasafi/spark,JerryLead/spark,publicRoman/spark,shuangshuangwang/spark,rjpower/spark,darionyaphet/spark,lxsmnv/spark,mahak/spark,witgo/spark,someorz/spark,1haodian/spark,icexelloss/spark,esi-mineset/spark,goldmedal/spark,hhbyyh/spark,goldmedal/spark,loneknightpy/spark,ahnqirage/spark,ajaysaini725/spark,joseph-torres/spark,huang1900/spark,metamx/spark,andrewor14/iolap,Aegeaner/spark,aokolnychyi/spark,ConeyLiu/spark,WindCanDie/spark,kissmetrics/spark,wgpshashank/spark,skonto/spark,UndeadBaneGitHub/spark,holdenk/spark,JoshRosen/spark,wzhfy/spark,wzhfy/spark,nilsgrabbert/spark,joseph-torres/spark,nchammas/spark,mzl9039/spark,xuanyuanking/spark,ericvandenbergfb/spark,dongjoon-hyun/spark,pgandhi999/spark,1haodian/spark,mzl9039/spark,zuotingbing/spark,apache/spark,adrian-ionescu/apache-spark,alunarbeach/spark,shaneknapp/spark,ankurdave/arthur,adrian-ionescu/apache-spark,vinodkc/spark,wangyum/spark,mkolod/incubator-spark,dbtsai/spark,techaddict/spark,mzl9039/spark,andrewor14/spark,wangyum/spark,brad-kaiser/spark,BryanCutler/spark,milliman/spark,jlopezmalla/spark,lxsmnv/spark,aokolnychyi/spark,hvanhovell/spark,shuangshuangwang/spark,xuanyuanking/spark,ahnqirage/spark,JerryLead/spark,techaddict/spark,HyukjinKwon/spark,xflin/spark,kevinyu98/spark,akopich/spark,tengpeng/spark,panfengfeng/spark,mike0sv/spark,WindCanDie/spark,liyichao/spark,jperla/spark-advancers,ankurdave/arthur,skonto/spark,apache-spark-on-k8s/spark,tejasapatil/spark,nilsgrabbert/spark,bravo-zhang/spark,icexelloss/spark,srowen/spark,ioana-delaney/spark,srowen/spark,saturday-shi/spark,michalsenkyr/spark,zhouyejoe/spark,yanboliang/spark,ptkool/spark,patrick-nicholson/spark,jlopezmalla/spark,stanzhai/spark,mike0sv/spark,zhouyejoe/spark,esi-mineset/spark,milliman/spark,techaddict/spark,bravo-zhang/spark,ankurdave/arthur,gengliangwang/spark,liyichao/spark,byakuinss/spark,mkolod/incubator-spark,metamx/spark,map222/spark,zero323/spark,actuaryzhang/spark,xuanyuanking/spark,sureshthalamati/spark,pgandhi999/spark,jkbradley/spark,kevinyu98/spark,alunarbeach/spark,ron8hu/spark,kevinyu98/spark,yanboliang/spark,hhbyyh/spark,minixalpha/spark,liutang123/spark,rikima/spark,markhamstra/spark,szhem/spark,cin/spark,sachintyagi22/spark,apache-spark-on-k8s/spark,stanzhai/spark,markhamstra/spark,chuckchen/spark,szhem/spark,saltstar/spark,adrian-ionescu/apache-spark,poffuomo/spark,bdrillard/spark,jlopezmalla/spark,alunarbeach/spark,rikima/spark,wzhfy/spark,cin/spark,hvanhovell/spark,xuanyuanking/spark,bdrillard/spark,apache-spark-on-k8s/spark,liutang123/spark,mahak/spark,akopich/spark,loneknightpy/spark,wzhfy/spark,ptkool/spark,ericvandenbergfb/spark,SnappyDataInc/spark,wgpshashank/spark,byakuinss/spark,cloud-fan/spark,apache/spark,ajaysaini725/spark,liyichao/spark,ericvandenbergfb/spark,pgandhi999/spark,taroplus/spark,tengpeng/spark,LantaoJin/spark,ahnqirage/spark,sureshthalamati/spark,tengpeng/spark,rekhajoshm/spark,shubhamchopra/spark,rekhajoshm/spark,zzcclp/spark,skonto/spark,rezasafi/spark,metamx/spark,andrewor14/spark,wangyum/spark,sachintyagi22/spark,map222/spark,publicRoman/spark,huang1900/spark,liyichao/spark,witgo/spark,mahak/spark,shaneknapp/spark,andrewor14/spark,metamx/spark,maropu/spark,cloudera/spark,techaddict/spark,joseph-torres/spark,UndeadBaneGitHub/spark,haowu80s/spark,rikima/spark,pronix/spark,andrewor14/iolap,1haodian/spark,poffuomo/spark,mzl9039/spark,big-pegasus/spark,big-pegasus/spark,witgo/spark,Aegeaner/spark,hvanhovell/spark,aray/spark,ron8hu/spark,dongjoon-hyun/spark,jlopezmalla/spark,gioenn/xSpark,akopich/spark,kiszk/spark,pronix/spark,jkbradley/spark,nilsgrabbert/spark,JoshRosen/spark,sryza/spark,SnappyDataInc/spark,JerryLead/spark,byakuinss/spark,goldmedal/spark,sahilTakiar/spark,andrewor14/iolap,mdespriee/spark,ericvandenbergfb/spark,skonto/spark,pgandhi999/spark,sureshthalamati/spark,dotunolafunmiloye/spark,skonto/spark,zuotingbing/spark,koeninger/spark,pgandhi999/spark,joseph-torres/spark,poffuomo/spark,wangyum/spark,lvdongr/spark,mahak/spark,metamx/spark,kiszk/spark,taroplus/spark,ptkool/spark,ioana-delaney/spark,cin/spark,ptkool/spark,jiangxb1987/spark,panfengfeng/spark,patrick-nicholson/spark,saturday-shi/spark,brad-kaiser/spark,Aegeaner/spark,setjet/spark,WeichenXu123/spark,saltstar/spark,caneGuy/spark,JerryLead/spark,cloud-fan/spark,patrick-nicholson/spark,minixalpha/spark,debugger87/spark,maropu/spark,hhbyyh/spark,wangmiao1981/spark,markhamstra/spark,metamx/spark,spark-test/spark,adrian-ionescu/apache-spark,guoxiaolongzte/spark,sahilTakiar/spark,facaiy/spark,dbtsai/spark,andrewor14/iolap,apache-spark-on-k8s/spark,ibm-research-ireland/sparkoscope,saltstar/spark,SHASHANKB/spark,wangmiao1981/spark,aokolnychyi/spark,MLnick/spark,lyogavin/spark,lxsmnv/spark,poffuomo/spark,huang1900/spark,ajaysaini725/spark,mike0sv/spark,aosagie/spark,caneGuy/spark,jianran/spark,highfei2011/spark,HyukjinKwon/spark,WindCanDie/spark,koeninger/spark,tejasapatil/spark,map222/spark,aokolnychyi/spark,eyalfa/spark,byakuinss/spark,aray/spark,kissmetrics/spark,jiangxb1987/spark,zuotingbing/spark,stanzhai/spark,janewangfb/spark,BryanCutler/spark,andrewor14/spark,SHASHANKB/spark,rekhajoshm/spark,darionyaphet/spark,map222/spark,ptkool/spark,zuotingbing/spark,cloud-fan/spark,debugger87/spark,hhbyyh/spark,yanboliang/spark,haowu80s/spark,shubhamchopra/spark,tejasapatil/spark,MLnick/spark,lxsmnv/spark,ConeyLiu/spark,WeichenXu123/spark,icexelloss/spark,eyalfa/spark,zhouyejoe/spark,goldmedal/spark,huang1900/spark,rikima/spark,andrewor14/spark,michalsenkyr/spark,hhbyyh/spark,nchammas/spark,nlalevee/spark,JoshRosen/spark,aray/spark,mahak/spark,guoxiaolongzte/spark,alunarbeach/spark,someorz/spark,hvanhovell/spark,andrewor14/iolap,minixalpha/spark,milliman/spark,WindCanDie/spark,Panos-Bletsos/spark-cost-model-optimizer,wangmiao1981/spark,mdespriee/spark,sureshthalamati/spark,shaneknapp/spark,MLnick/spark,kimoonkim/spark,UndeadBaneGitHub/spark,kiszk/spark,eyalfa/spark,zhouyejoe/spark,poffuomo/spark,jrshust/spark,pronix/spark,ueshin/apache-spark,minixalpha/spark,shuangshuangwang/spark,jianran/spark,SnappyDataInc/spark,ddna1021/spark,ibm-research-ireland/sparkoscope,WindCanDie/spark,dongjoon-hyun/spark,ueshin/apache-spark,publicRoman/spark,darionyaphet/spark,nilsgrabbert/spark,jrshust/spark,zzcclp/spark,SHASHANKB/spark,jkbradley/spark,panfengfeng/spark,dotunolafunmiloye/spark,patrick-nicholson/spark,jiangxb1987/spark,big-pegasus/spark,brad-kaiser/spark,wangmiao1981/spark,rekhajoshm/spark,kimoonkim/spark,bravo-zhang/spark,bravo-zhang/spark,ueshin/apache-spark,andrewor14/spark,hvanhovell/spark,map222/spark,saturday-shi/spark,someorz/spark,narahari92/spark,rednaxelafx/apache-spark,ahnqirage/spark,caneGuy/spark,milliman/spark,chuckchen/spark,taroplus/spark,nlalevee/spark,aosagie/spark,facaiy/spark,mike0sv/spark,sureshthalamati/spark,mike0sv/spark,rikima/spark,bdrillard/spark,mdespriee/spark,bOOm-X/spark,dhruve/spark,adrian-ionescu/apache-spark,tejasapatil/spark,map222/spark,dhruve/spark,rednaxelafx/apache-spark,cloud-fan/spark,haowu80s/spark,metamx/spark,dhruve/spark,tengpeng/spark,saturday-shi/spark,apache/spark,HyukjinKwon/spark,vinodkc/spark,actuaryzhang/spark,darionyaphet/spark,akopich/spark,WindCanDie/spark,mkolod/incubator-spark,janewangfb/spark,ron8hu/spark,rikima/spark,pgandhi999/spark,shubhamchopra/spark,narahari92/spark,publicRoman/spark,tejasapatil/spark,dbtsai/spark,ibm-research-ireland/sparkoscope,shaneknapp/spark,witgo/spark,xuanyuanking/spark,someorz/spark,aosagie/spark,gengliangwang/spark,dbtsai/spark,jkbradley/spark,1haodian/spark,holdenk/spark,janewangfb/spark,rjpower/spark,vax11780/spark,setjet/spark,shubhamchopra/spark,jiangxb1987/spark,kissmetrics/spark,guoxiaolongzte/spark,facaiy/spark,zero323/spark,ajaysaini725/spark,dhruve/spark,markhamstra/spark,aokolnychyi/spark,Panos-Bletsos/spark-cost-model-optimizer,liyichao/spark,yanboliang/spark,loneknightpy/spark,kimoonkim/spark,saltstar/spark,ibm-research-ireland/sparkoscope,xuanyuanking/spark,jianran/spark,zuotingbing/spark,lyogavin/spark,lvdongr/spark,mdespriee/spark,liyichao/spark,zero323/spark,aosagie/spark,rednaxelafx/apache-spark,xflin/spark,minixalpha/spark,mzl9039/spark,dotunolafunmiloye/spark,bOOm-X/spark,nlalevee/spark,ptkool/spark,loneknightpy/spark,byakuinss/spark,szhem/spark,vax11780/spark,nlalevee/spark,narahari92/spark,cloud-fan/spark,jiangxb1987/spark,byakuinss/spark,srowen/spark,kimoonkim/spark,ueshin/apache-spark,zero323/spark,nilsgrabbert/spark,goldmedal/spark,rezasafi/spark,big-pegasus/spark,SHASHANKB/spark,sureshthalamati/spark,maropu/spark,gioenn/xSpark,lvdongr/spark,michalsenkyr/spark,rezasafi/spark,holdenk/spark,apache/spark,brad-kaiser/spark,facaiy/spark,guoxiaolongzte/spark,SHASHANKB/spark,poffuomo/spark,milliman/spark,jkbradley/spark,jiangxb1987/spark,stanzhai/spark,apache-spark-on-k8s/spark,szhem/spark,haowu80s/spark,adrian-ionescu/apache-spark,alunarbeach/spark,guoxiaolongzte/spark,sryza/spark,mkolod/incubator-spark,saturday-shi/spark,sryza/spark,ioana-delaney/spark,WeichenXu123/spark,publicRoman/spark,rezasafi/spark,kiszk/spark,JerryLead/spark,zhouyejoe/spark,chuckchen/spark,highfei2011/spark,yanboliang/spark,sahilTakiar/spark,apache/spark,aosagie/spark,srowen/spark,haowu80s/spark,holdenk/spark,spark-test/spark,skonto/spark,ron8hu/spark,jrshust/spark,chuckchen/spark,shubhamchopra/spark,publicRoman/spark,shaneknapp/spark,hhbyyh/spark,pgandhi999/spark,setjet/spark,caneGuy/spark,xflin/spark,vinodkc/spark,HyukjinKwon/spark,Panos-Bletsos/spark-cost-model-optimizer,akopich/spark,esi-mineset/spark,zero323/spark,adrian-ionescu/apache-spark,sryza/spark,apache/spark,gengliangwang/spark,JoshRosen/spark,ron8hu/spark,rjpower/spark,BryanCutler/spark,JoshRosen/spark,lvdongr/spark,map222/spark,pronix/spark,UndeadBaneGitHub/spark,narahari92/spark,patrick-nicholson/spark,kiszk/spark,shuangshuangwang/spark,koeninger/spark,liutang123/spark,someorz/spark,ibm-research-ireland/sparkoscope,aokolnychyi/spark,actuaryzhang/spark,ddna1021/spark,shubhamchopra/spark,jlopezmalla/spark,vax11780/spark,ankurdave/arthur,bravo-zhang/spark,szhem/spark,esi-mineset/spark,caneGuy/spark,esi-mineset/spark,alunarbeach/spark,ajaysaini725/spark,srowen/spark,UndeadBaneGitHub/spark,spark-test/spark,cin/spark,kiszk/spark,vax11780/spark,icexelloss/spark,jrshust/spark,saltstar/spark,debugger87/spark,facaiy/spark,haowu80s/spark,ConeyLiu/spark,BryanCutler/spark,ahnqirage/spark,techaddict/spark,ahnqirage/spark,kissmetrics/spark,dbtsai/spark,SHASHANKB/spark,vinodkc/spark,panfengfeng/spark,cloudera/spark,gioenn/xSpark,kissmetrics/spark,LantaoJin/spark,kevinyu98/spark,andrewor14/spark,mike0sv/spark,LantaoJin/spark,Aegeaner/spark,nchammas/spark,tejasapatil/spark,cin/spark,dhruve/spark,liyichao/spark,hvanhovell/spark