[BEAM-79] fix integration-test failure
[BEAM-79] fix integration-test failure

robertwb/incubator-beam,markflyhigh/incubator-beam,rangadi/beam,chamikaramj/beam,wangyum/beam,jbonofre/incubator-beam,jbonofre/beam,apache/beam,mxm/incubator-beam,robertwb/incubator-beam,markflyhigh/incubator-beam,lukecwik/incubator-beam,RyanSkraba/beam,RyanSkraba/beam,iemejia/incubator-beam,charlesccychen/beam,wangyum/beam,staslev/beam,staslev/beam,mxm/incubator-beam,eljefe6a/incubator-beam,iemejia/incubator-beam,robertwb/incubator-beam,rangadi/incubator-beam,wangyum/beam,robertwb/incubator-beam,RyanSkraba/beam,apache/beam,lukecwik/incubator-beam,RyanSkraba/beam,staslev/incubator-beam,tgroh/incubator-beam,rangadi/beam,charlesccychen/beam,tgroh/beam,apache/beam,chamikaramj/beam,charlesccychen/incubator-beam,lukecwik/incubator-beam,charlesccychen/incubator-beam,jbonofre/beam,wangyum/beam,charlesccychen/beam,rangadi/beam,lukecwik/incubator-beam,jbonofre/beam,rangadi/incubator-beam,RyanSkraba/beam,apache/beam,lukecwik/incubator-beam,jbonofre/beam,robertwb/incubator-beam,robertwb/incubator-beam,tgroh/incubator-beam,charlesccychen/beam,charlesccychen/beam,apache/beam,chamikaramj/beam,charlesccychen/beam,apache/beam,markflyhigh/incubator-beam,eljefe6a/incubator-beam,charlesccychen/incubator-beam,tgroh/beam,tgroh/beam,chamikaramj/beam,apache/beam,eljefe6a/incubator-beam,chamikaramj/beam,rangadi/beam,rangadi/beam,lukecwik/incubator-beam,chamikaramj/beam,lukecwik/incubator-beam,lukecwik/incubator-beam,chamikaramj/beam,apache/beam,rangadi/incubator-beam,chamikaramj/beam,lukecwik/incubator-beam,staslev/incubator-beam,robertwb/incubator-beam,robertwb/incubator-beam,markflyhigh/incubator-beam,markflyhigh/incubator-beam,markflyhigh/incubator-beam,rangadi/beam,chamikaramj/beam,jbonofre/incubator-beam,RyanSkraba/beam,rangadi/beam,apache/beam,tgroh/beam,charlesccychen/beam,chamikaramj/beam,lukecwik/incubator-beam,robertwb/incubator-beam,markflyhigh/incubator-beam,robertwb/incubator-beam,apache/beam,staslev/beam,apache/beam,RyanSkraba/beam