From 29da97734a8321bb880badbfe372cf0a0fc8c14d Mon Sep 17 00:00:00 2001 From: Patrick Clay Date: Mon, 26 Jan 2015 12:29:53 -0800 Subject: [PATCH] Release of version 1.1.0 --- CHANGES.txt | 6 +++++- bdutil | 2 +- bdutil_env.sh | 6 +++--- hadoop2_env.sh | 6 +++--- libexec/configure_hadoop.sh | 6 ++++++ samples/bigquery_wordcount.jar | Bin 419167 -> 419168 bytes samples/datastore_wordcount.jar | Bin 424086 -> 424086 bytes samples/datastore_wordcountsetup.jar | Bin 424101 -> 424101 bytes samples/datastoretobigquery_wordcount.jar | Bin 423765 -> 423766 bytes 9 files changed, 18 insertions(+), 8 deletions(-) diff --git a/CHANGES.txt b/CHANGES.txt index 1c0caf2..5897cd3 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,7 @@ -1.1.0 - 2015-xx-xx +1.1.1 - 2015-xx-xx + + +1.1.0 - 2015-01-22 1. Added plugin for deploying Ambari/HDP with: ./bdutil -e platforms/hdp/ambari_env.sh deploy @@ -16,6 +19,7 @@ with compiler/tools instead of just the minimal JRE; set to 'true' in single_node_env.sh and ambari_env.sh. 8. Added python script to allocate memory more intelligently in Hadoop 2. + 9. Upgraded default Hadoop 2 version to 2.5.2. 1.0.1 - 2014-12-16 diff --git a/bdutil b/bdutil index f676589..ef94c75 100755 --- a/bdutil +++ b/bdutil @@ -20,7 +20,7 @@ # # Usage: ./bdutil [deploy|delete] [optional: ]... -BDUTIL_VERSION='{{ version_string }}' +BDUTIL_VERSION='1.1.1-SNAPSHOT' # Prints the usage for this script and exits. function print_usage() { diff --git a/bdutil_env.sh b/bdutil_env.sh index bbd17e2..41aea7a 100644 --- a/bdutil_env.sh +++ b/bdutil_env.sh @@ -167,13 +167,13 @@ CORES_PER_REDUCE_TASK=1.0 JAVAOPTS='-Xms1024m -Xmx2048m' # Complete URL for downloading the GCS Connector JAR file. -GCS_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib-dev/gcs/gcs-connector-1.3.2-SNAPSHOT-hadoop1-20141222-135330.jar?GoogleAccessId=359641935755-j2hkfvkvflpvguhuj2dajativ5ft8856@developer.gserviceaccount.com&Expires=1450821786&Signature=Y8CR1WVu2lOMdS9mgXXhIAELvhrGvmO%2BBrooLjWWRJWJCPBQ3MT%2FdVVK%2BnSqdTeMdK8jycRV6KuTPMs%2Bmr6yxHvhucKEc14mZcIdVyEo9FiS46QQeD3cn1GkKrFt90rfQ%2FJC7KaJQcqyYlZLN0lb40n8dSPPL994xbx0Lqf7lF0=' +GCS_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib/gcs/gcs-connector-1.3.2-hadoop1.jar' # Complete URL for downloading the BigQuery Connector JAR file. -BIGQUERY_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib-dev/bigquery/bigquery-connector-0.5.1-SNAPSHOT-20141222-112706-hadoop1.jar?GoogleAccessId=359641935755-j2hkfvkvflpvguhuj2dajativ5ft8856@developer.gserviceaccount.com&Expires=1450812947&Signature=O514AO229YtAaQIwLgmyV5ILuebndeT4g%2FJw2TvPWrMO7vK42XscpIllMi%2B128E5Q50jzGHlUxZaRNc37yRXLylekSo88WOTg9YUxN%2FjLzYmIkOlFPUfWLogjUVvlh4zvGYqaZ%2FpbNW2DWtQM7Yhy1khFgD0%2B51ruCgjfMHzVz0=' +BIGQUERY_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib/bigquery/bigquery-connector-0.5.1-hadoop1.jar' # Complete URL for downloading the Cloud Datastore Connector JAR file. -DATASTORE_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib-dev/datastore/datastore-connector-0.14.10-SNAPSHOT-20141222-133725-hadoop1.jar?GoogleAccessId=359641935755-j2hkfvkvflpvguhuj2dajativ5ft8856@developer.gserviceaccount.com&Expires=1450820611&Signature=mPGE%2Fv%2FMfV5c1AY%2BjDiJ9troPcZMUzSaw82RdDXRj8Tzxh5JuGwDixGziaAXM0aW9pRb%2B8X97hAICM2vo%2B4lVHg6JJtyXhhGYJfn8o9KFp8x%2FoMp7AiGWlqIFvM27M%2FM4TZTpu%2BzWDtm9WTXWi4SEpOuCbZoqTu2fRjFuNTOpfk=' +DATASTORE_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib/datastore/datastore-connector-0.14.9-hadoop1.jar' # Complete URL for downloading the configuration script. BDCONFIG='https://storage.googleapis.com/hadoop-tools/bdconfig/bdconfig-0.28.1.tar.gz' diff --git a/hadoop2_env.sh b/hadoop2_env.sh index 346d0ca..13c003c 100644 --- a/hadoop2_env.sh +++ b/hadoop2_env.sh @@ -44,11 +44,11 @@ CORES_PER_REDUCE_TASK=2.0 CORES_PER_APP_MASTER=2.0 # Connector with Hadoop AbstractFileSystem implemenation for YARN -GCS_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib-dev/gcs/gcs-connector-1.3.2-SNAPSHOT-hadoop2-20141222-135330.jar?GoogleAccessId=359641935755-j2hkfvkvflpvguhuj2dajativ5ft8856@developer.gserviceaccount.com&Expires=1450821787&Signature=cQDn6fvv2Hyu58z9uzLQEIu42WyeSOY97lO8pXgZNq%2BEX5YGW8VjBWP1YzBX1Slkufc6USrb4009TZhSu%2BQATsZwYa7jOGh0sLSsHEmCPvUI3HrENag8rvvhefLnxGx6vrFcA2fOskivUOp5ZTyh1K0sCDBqjoSLTbGIFXeuNr0=' +GCS_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib/gcs/gcs-connector-1.3.2-hadoop2.jar' -DATASTORE_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib-dev/datastore/datastore-connector-0.14.10-SNAPSHOT-20141222-133725-hadoop2.jar?GoogleAccessId=359641935755-j2hkfvkvflpvguhuj2dajativ5ft8856@developer.gserviceaccount.com&Expires=1450820611&Signature=iZWtERtR1vRszg8D734aO%2BadLcOpSjgOF5%2BxsNYLN%2B26oVO8KnEAF%2FRFVEsVQMXxwMSY8olp7r7zegBhOsuAflm%2F7d8rSpXOqWuoUI7VfGaadC%2FNfkQTux%2Fl0rkvZj1bk85fsQO115p1voOyIH%2FweZ8U05cx6hIkvdG3s%2FPnVts=' +DATASTORE_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib/datastore/datastore-connector-0.14.9-hadoop2.jar' -BIGQUERY_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib-dev/bigquery/bigquery-connector-0.5.1-SNAPSHOT-20141222-112706-hadoop2.jar?GoogleAccessId=359641935755-j2hkfvkvflpvguhuj2dajativ5ft8856@developer.gserviceaccount.com&Expires=1450812947&Signature=M14Jcxt5HjiCGhDvOQGJdr9UcwrFp4ELJ617AW9O2cpZ453%2F5irwsnHPgGjeczpoD4sCxidheWTCEcSOa8y0E163zBNKXda1Nc0gHyMVQMQOPWzfQ1QgQCTuT%2BD39FjNyvOazlXJymzuRJruLRK2CY2HbbN%2FSpacVUCrckn6ABU=' +BIGQUERY_CONNECTOR_JAR='https://storage.googleapis.com/hadoop-lib/bigquery/bigquery-connector-0.5.1-hadoop2.jar' HDFS_DATA_DIRS_PERM='700' diff --git a/libexec/configure_hadoop.sh b/libexec/configure_hadoop.sh index fd7ff46..f4ae381 100644 --- a/libexec/configure_hadoop.sh +++ b/libexec/configure_hadoop.sh @@ -53,6 +53,12 @@ TOTAL_MEM=$(free -m | awk '/^Mem:/{print $2}') HADOOP_MR_MASTER_MEM_MB=$(python -c "print int(${TOTAL_MEM} * \ ${HADOOP_MASTER_MAPREDUCE_MEMORY_FRACTION})") +# Fix Python 2.6 on CentOS +# TODO(user): Extract this into a helper. +if ! python -c 'import argparse' && [[ -x $(which yum) ]]; then + yum install -y python-argparse +fi + # MapReduce v2 (and YARN) Configuration if [[ -x configure_mrv2_mem.py ]]; then TEMP_ENV_FILE=$(mktemp /tmp/mrv2_XXX_tmp_env.sh) diff --git a/samples/bigquery_wordcount.jar b/samples/bigquery_wordcount.jar index 46df9f783042aa45487e717254d2e9b52be25d51..c1f4271e2710e679a80527a446330789f58d2da4 100644 GIT binary patch delta 4854 zcmZ9P2~?9;7RUKsk_Ut(LG}b$WJkdSWD|sd$R@ixAiG$XBG#o^typxbSgF?3T#pV_ zr&X(r3Y8YE0$SIiWvNT+f}*v>s#wvwz|?W>mpA8YkaNPh|KGj$?eE>>R;y!ot7F}0 zu3}UEhEG*Cr*FNO@aO#0xn}0(6)D>4=Ki_=^77D*_wBf)8YI4%JP$uSrin4681_Tbxt& zTj%y{weJGYnRT)`#oz7fIaRGXa$<>2_v_*nR+ASGQFu;m06*XO_O`4!c~d6)aA}t& z<=QR!x?yRD>)8xRTm8zUvMnX2Jwj84SzO(F?!%-g<8NhVT_FiE?l#v$J_>*Ms;Dcc zp*k+qTkF$Sk!Yh0JMH^kZt3uF>7Nsw);-y>YfWfH;r0gekDhkVJX?P3RnAY^xzn!9 z7$;h~`f266Vg5Uhr{=A0OSShTVI}@^x30+QjwlZP&n>6W!pAq41b*P+uH?ue53c_7A0B_c$Y?MIs~ABC&K;uxL%Nh{F%T4{wX{BWVm4(E-j>2!}8Uoye)7T0+&_1Za`a zFtS{vJt4LRb4vY4EpICzi??s{_E6Zy+X^w-UeL?ixx5_!3C3ve=It10;O$waXoqQ! znVN%#3F;tA)SfN>wZi)$6ysdneS> zEtWXpv^9F$Mn)sK7mz8#r2CusxoUlMc2MhpIWJ_GW49ZjKWOAQ2*p0My|uafq)@|a zms;qvqAKW@Qx&p4hUs^MZ-EWPt)+d;d+n`u^l8FVpusx%l-!@X4f5sSY*x=}{pW`)z+M-W; zUhnHVZwxzZ(KopbbqFK`Q7f&YQ)bYad8a;Wx*cX+x~R8X(B`V3&yE(7jH`OI${yV& zH_#4%T@KU^2JCUIZuju(17jR$2r+-8U(Do3*8F1nksC&k=|z=VSDgtAIM8Ua)k+Vb z!-}(pS&kUeZOurXBTXaS_JWXts{=O_B=9mJKJA@~%pBO$;66vVoI;-oygMZP4fkCojVH>;H|TUHnn(hp2GJ4vR+ecv zxtXwgMrGhOlrAFIV+Vy=K$|13+s&caqh*2K1-8yKl9U%QQRYk|$n;`CNTI`-#*o7^ z83}Nq;UuVxiCJZwJv-;MF4*451q}Bu;4I(|7hKxTWsDdv=Z3Jrsje6pQOWQIS8NQb zn9#W4jlRzl`)Ywik@Ss%Fo!*Ec;b6D3B(LuyU`%xu*HC655qHZd8+}j+s4UZi6w5) z#bMZcevROh!uA@DvXS|@qp$Z{-sc4YM{#D4-7!VWV_lPgDReb)w!F`etUS)}$&*N? zc+jz=@}xkNEWg(S^W9n*9_dNrNZ5HnSi=EN8cGs71Tq9%yr_z6h72#dkn~&ywKv}M z=Uz0NGX<45ol8b{G1lgdk5JJqCNw_SaLgS+NZ_asF4d;rdEyIpz8G8C%X(Sii`RfW zW}?@RD&Vy*4J4j@24rO)=L6gPaE@O+7jQCJ{$D2Yhf@vrKI|AyXArFk>>N&&@VyC< zgHnx4w$PmzUY42eETG1n{Qp(lG6L5mXe7)Jp!%1*fcqHK{h_&7Ab*@9X7Ix(>{ZojfZc;JbzZvxsSKv0$oWeKM1Gl=!=qqKP5apZ$A!>f z@cVIysj=jpO3>Hn>y{!rzA-=Y)Xo5Z6i!EzW-kNs zmzT&+HyYz+`3lq#3V1SBEf6WxkH+W4C0ZaRARj};U>$)^hK1%$oURdBzt8;<^d1kST0{>^}Y$BPt@8i~oPliu`QNW!V3PY#`tn0z;Na6l?)%ot4U zz${ZFWhq~c!IaAr2M3tKz!<#m>6NfkgNJNHG&P5bQ8?M`)dI1CV^K7Vv{nfuhL~>R zg&S;)##)o26NC&*G?@K(t3b?Po(9kQ1K6R#J*b&sc0&eQF>hh8A!K zp*{xhb$~Nu#^BuukELVCFc&7KyNK=JKrF7%Y!5~TV(ECI^AUtCEFX)b$iYzr$AaL)$D;RZaMVc^rm=v*YEKH)Y?l7Av!`#qLoCz6)7ct*b%| zNWcXA2@(W_6X-j{I>Nw_8zHfU{7Kl1&qQpdF3P~yA0?47-zU89na02u6@ydM=lz%W z<;5HL5+`AWU6v*gGiaHF!=GKk6BQ^Ymy z__}iN^gLS66BR^l#O=w*#mPP0AP`5E`fDx@QLUSfub&PIr_)*F?OHy@4SJ_zLd_vw zxI#yRL<$q~u<&ed5QqYf=i&OO8U@~ delta 4727 zcmZ{n2Ut}{7RR}B-zZ(` zICcEWW_z=R4<|f&VzJl7C7{And#K*RHoH7My(NAwGp~G=7IbuL)%%_o!`44ITe zW6`|!uoIh(O^ufy99-er}%qDbKUkv=cth< zO``(8krmYLy7Aa^&(iX4t@@M^ij5iJWfoaG6gkC7y$eUR52&|t-TCfm=-HC#&ff>y zWCU5CTsP%W`@z-AZ^f7tUiw9*ZS!p9+x^w;wRx)^-`za5_DJcC?um~swX7a+zs3&p^I(Gg+MR1I%Zw-A@XN>WV*qZnL68Of`v!SOmvj4A!o&J?>s-Ah*y1qOyMRt5mzG{U$qPT1B#z%hEHm5cf zudA3FyLd}*LDqu#>2M_?e#_Ou9p$4Yjk>dJbG^ab@B>X2ry7r5)Z4tfXR4)ZO?lyP z%VUxKrwk5@fY|f}({FCk+3EizcByNM%lq(~dmq{7+m*hq*_}WAlzHzyk6pc7@=%%f z;bpp7&p0iu`Mj1^@=#u)tFSH2ArUYIj>klOeg2UydFeHp^j|wq!bDnh!a4xFV%(f3@lTFigOAX80t|sazO}K z8$h)oLyvlJ1RV5nobB$sHtb~}h5-lYX7)m6kK`_}Uwxn{nMz=zKJs1xwCYnIE)wJh zG={qmsRmRb;4bQ;hM@>4WJ6?!T;RNGNGEH|VIVz)#ccis?dPh6(9&5dXz z>8?cE3FaEn5b}Hjvn$-IEMUJCHvH2F8=CJ%=n4^X>PxKmGP`2@UR~HG$6{^wq4tG0 z%y;*I+8$?2{YZ6<+CGOiOUjt$5bNV=^j8yfH=b16ZOpE$Lpuaqjc~jiQyeextlD|d z6x*6Wt0}fEzMw|4%`o2Va)saJV0d7L!{57#+y_FdYzOMjtG`UV;4&>nGqWC2p5s1?~X{CE~OY5vP)%Fi{x7Kb16&C?W-tY(qy8zbFlN zaTI4ObT8|J{S>G)e03_$TJSAozIy{ip8+(gILdq;#2^bw9dN%|+R_M8m?MZUY-ukve{2US#gP=C_5^CN)S9yFC4?iNV`DS9u6tbRDu0{FTg zoy4!#CeZ0fm2h2~7=eu+PSG4EA~z7fH?7G|q~ei60o$A~Ks~jaJgI{B_aRU|jwoTc z7qx~Lo^&w3+W#Yp=ZhmhDm+oWXc~WA^%;_a${VLA24;HGX}r%6wYx7&_n|tV=R?DI zqr{IWp4UqKpzizNaF@oal^4h}hyhISr5^mOacUGQ9LkFG3JHv_BBrp`AH!E}{z&ip(+K{DqYOAg zVFQuDk{mo?p4Wadh4*ST0=5Ov5dPpP4Z;P|Kwf%IgA6-I^r0XS2m9ut2JW~>^q`Sp zp9T@j!7B*Kj2j}sB!aNVhFcosNe~U@6aS$>1_jd~e&+)M-##EApzy(!zZgsvToybG zrsIg~V`vS=o%Spl>zNmVD}M7|thEAaLTC)X_YL&IIji9(NwwNPu?Ed z*hNqkie1*g;ZT}Fstwgn;lgY-z0@I0z_(IEeJ!9ewa^A~qs^Crl1 z7o)6MPjZ+Ujvw#hjN z?sM!NNfXGD_|Gv$Q}`jCS3*)G=JaDE=JX`-e??WL@cIyzgafPZ=u63;ly^M&|Fp3X zIzHMTJH9pI^PukjSYOg&hTULf6qY|`DHC2$A4OBSYaoxNnM8X%V>Xbb!W65c@j@6{ zr9q@B+MoQkStKg%1$?cdqe)GVz@GQ;AD$%pWD?DftQt~cXcjrB3#GB_fY+5Mp*;qt z)yq~OnRXHissT8o4t653fI|Z?W@=wXoZ$TcI)rR+6NL#Z9EgQv^wS`(2I9pX<}DH# zlz3y$>X}@T@kvfaP!db05aUc1><%YlaYwri!r5D$Ei~UAhj(;Su0#TNvn2*lG6-`i z!#k1X@?W1Bykz+0Bn>YSrDoQEVk(~{uezIOM87y#7=OMk-Ogu#Qp~y_&_w~ z6Fv+(E&oZtCBtYGDZ3+x^NCajqZ06)W0;6B$M1_+2gWDja$B{EWH>%oR!_Zy$&?dz^TXTztNz;it04S!xKwQ;^iS3S?&rHaP0bgb(!kN@bwqh*J<7 zAk{pDf&zqq{8W6MJPZ^>BMPppDh(f`{-FX|6e_iX-$q~ur_*qLOd_83;hNKF{_Amif%k}wh%bbb;O-f(&(Zm+2mp)(yH88)NP zb8WI9){Me=Tux$&ms<^cLXc;mIh6?$LOb zr;(&t%o_^F(rGxi4m#55OfqRcV_{G|2A9of5%^_Lf5=>f&DDc>j>SrJN(DTBER7-j zQYJzneW_FqHe+#!p1(;oPm?zA&A@k);R+$HB?CKtwMxhxi^}SH zIu0|%l^c&o(S|*2avY$2JpN&~W;||`{Cy$`C)G!pu!k=upnF6nE@EY^Nc5n&R%!%g zO6>DyCZ_LmLiEX@&jgItJ|&VE^60cEYYvWb?VgCG;FXI5=(RGUgpynu%I$Xbrzr_>qx uOr&nSyh{q+UD5z3Vk%QmesG`*=b>dHzEOVWDGTs}$Vt?e?vPM?oc#xX`rzmQ diff --git a/samples/datastore_wordcount.jar b/samples/datastore_wordcount.jar index 8100a84894a4d7db6be696ae80180f3ca74f903d..bab87078f9bd24a03ff9e298c1eeba8261d14b9d 100644 GIT binary patch delta 575 zcmV-F0>J&2@fnu!8L&D5f09v;oFEj1-}hJWxJ?QSimuv_Y}&UzH))$pGPxouyC4Q| z+HKSSUUhUPyAMqtBmwWa_v0MuNt=d5@STdHHti8=X3zGLZK2+=u%&#b`x zOYL=oJ0I1Vg5t%fL`w6*eB zd1Vv?b*xxf9IK_vodrG2RS<%hImv~SteoV+NwgzZDzb5suQT1Jg>D;UpjJj~o5ddS zaWU^b+Ge7Qm&t);f8@Xj5kG~H+*w$5Aeze#Sw*?Sks2(cHGuA42(^k#a{ zZm=+l`9lTgS(5S;HL8WlMD!a`ivA#NN9QA2HEKB1haxXNf9!T?tHhUnLZ4wkNrKqn zSY`RKN>a4=h3*+oSeYedarMVI32`2KN%nDF@oeSvlRRrrr1Rr7OJ|SO{s4oQ+ap{h zbW7*Wofe?kbvqIWWR5`G0QP)(7&>Kih delta 575 zcmV-F0>J&2@fnu!8L&D5e^T3O+%OP*&sXR%g-Wtzuh$L;LJNK95445ABFnO^tgJDT zylGnc@0B*Tlf0CIG@!ZZ%sJC8+H@ocH>ki{BYr6iOQ3_4xFp}n4=f#c9{>!#1tYeyuw zc^3z!hr4Zmypyzz{3aS{U1m*lY}ngiuhSCkk?TBbyr5}%pVn~(8~OHhRm;;$c9M&8 zNrct66}_1-Dl^SQcoJpeuM=$=j=~NRm=9aZzL$IPzp7IDUr z+bJxF|4x#ot#%KHLoC^uH}m;Dm!q*2i{KlKsh%2oa&uN9-td6 zhTF;Ehx3(oV;=*?aX3^sSoh41;P00HOq-}#=wS%0i)y!Dk5A}LZJ@NMHkV3ku#f6! zx=t6lM~e`!$i+S@^0~`h2d1B@AOtnRvNJ4OVA&a#8ON?@Y=vcCC&Ujk;wOw>hIN{S z60KS{vr+2(Y~x$9e-0*RSCfs{vW;LuQc3P-0&99Ck6D`ScUzghc>#au%(R3EaSV!z z_204{OrhnZAhwG0 zWwWN5-kcA{^&Jdq`bZ|_Hc4elDy(6&k^Cl{lRw0CgY%Ire;Vvh{2|+A?=E(k4%O#& zBp;zCNkYV?$hW&9Pf{}bMec=6#D1IXv#USWX^7L7WxLQ3Gq^Lx%lfA|I*$>e*sWS2M7#P z;STQs004ml0ssJ$U;`SLP#6XTgIoiLTmu1zTmu4!Tmu7#TmuA$TmuESTmuHB6bTGd Q;STQs004ov3K#~PU|dHKGXMYp delta 578 zcmV-I0=@mE@foG@8L&VBe^S9}+%OQm=PPtfp^|LbyK4sop@klLEu}347Fm{UWo3<# zKaifw`rFXaOdwe}T3l#C~v!dNEE$ z`IpS`30x~-w!y0~PsdhG2A;{Ia5tCvMCu@kw_@@G1dj71eO69)S~N!SZ0$5!*}!Le zvhZYYMxkxY3GaENMy}Mzg&Mh1BO1s?ge=s^w@Bz?BJ@RtuhTNyh(;N{{3KcUha}p2 zutan4#Omz-X(`eN_}$UR3qFH&l?kH4 zAIi{gL@D~SDxgQjKRJy)3ybo7{2uOhhxiyu5}@0>WO=#Uf3pKyS2iF;h!c4`%y6Fq zj@ryW$w@mR!A+Y(Fh1O^m*kzKP1HBZNUJid>qE_67dxHKX{%iJS?UE%+xv8w6WFM? zr;A&jp0lHzol7PxxfS$k!|2R75#dR+iN9>LdN>H%M`Av#E!%N!;D4b~`(IE?2MBn} zO3Uv7004&r0ssJ$U;`SLP#6XTgIoiLTmu1zTmu4!Tmu7#TmuA$TmuESTmuHB6bX3C QO3Uv7004)#3K#~PU{P%pO#lD@ diff --git a/samples/datastoretobigquery_wordcount.jar b/samples/datastoretobigquery_wordcount.jar index 923f7d939968a5fa92d09b9799fb554bc16f060c..bfd790c9bc95638636c9f0ca73b2f28453953a5b 100644 GIT binary patch delta 4889 zcmZvg2Ut{B7RPz_&D^2LIG})2gaJelDT8#WiWO9f3L;8XK?E5D3t|l+norc|h{r_N zUe?$WR8&@7No=u##1zyxxb}!bud5otz3=}$LJw*6VREa>Wy_k)vf<@~e4x;8cUkm7jIpC@5* zMrFKyO!DU?iMBE8|7HJNleD-fbLXY~YkrUZdSV~nmgCF) z;`%sOU)=ijoC)0*&X28rbk|+m{c|&mfwpJ;dcU%;+$I@pUlq01LHD}l=>f}8CpMO~ z>0MoOj-J@px_#Ozzu}1k6m@<&%jHGqb1J74J^0qlNo>7Z5ilY|(PG({`u@NPrM8+0 zQ`XM@tnEdWeBRNYp7}|`Dl)@+Ez@NwT+DWlWp%B0?V2{c?_J}tuzqe;=Fi%uscXM* zn02i9!0FL}t70`@xjAJ_uw9asEb5c|-04+@s{BoB5Br9R4rSKwLtj2_{ZaAAo2F0Ni#3NX z&-U^Yi`z}&VkD;4Es{T;GbUn_3f9C#w~AGirL#-YSq6Uuf1EACpZG{ROMSbUb;wOB zV1q3k!wiL1Tk2yu729SN{pyU zjA%pP&H?(U>0XLbM`3416q_co=ooxwMj$;X)5YX_81%& zIIKe56VR(@3~}>-CKXlb(mc$7?MdB8wui3XT?yJ)Y6_crVv;*ObhRE%(98wzctBx; z$Q=gQW5CT5GA@bLu$*%yd7?@M8ogKyjR=@6Aac#jT6-{3n0UZP9SB+5ozEVhr&VaOfw1dg8?0Kraq+l zG}?h+-wRtWIA`E zGW(h#MtfuI?$3sp_jL(qdtL$eqgZe`k;O2F=y-AA4_0SAM8G_8GSEk?1MXJ@Ef#U!PlJz5bX!FoneJL z4I`1(;M12nLyJ3&VA?^`mnM@zEUkWs>XPh5{G4_uG$ zLwPJqU`*kS2MuJ7f{!PiMZSp^0#a!7qp`PzUI$p+V&5BF=Gv=^Ct3Eo|1%Y@#aRSTFGOK{YG{tA5lG7WvQ+ z;#$r*PH-C|j6cZw(Q#yxj_>Zve$=15`-XE=pxw)eK;I9yUg<`Gn8Wdnj2T4xVpR`r zF~S>svFmdfw@0s9e;_NwGuQ}87s)~ z$JF0m;mIj~8pqrPs{p!?xeu!XXdWrQA&4#D)=j1x1O?(a8*X;SYVJ75;8+u5yleM1 z8L66^m>!@E!jzmI8sYpPI+DcvX+&;6Wz6A85Y{KZ`BQwf8FT(B2#4D9w9`-q3u_XL2zFu)wvPA|h>66}b|&$$^gP5Bk#rEV2I?be4k=DG z3ZxIfb3HlBh|~?BLy3EyK-AF8E!Mq!V!V5P%NGRQVE;foK@N)yWNj4g*^%XZv?hvL zz>0FL0(Wh~@THyl2wf_uLWp=Z=cplaHIc$QZWH+rq6&Pj#SNmVq-75uts8{B_dCNm z+(SwNn!$MSN1Xi#v}cF}bR6w=@e}%TF!dw3b)V1!b)*ZQp7NJY=}CY2M0s=wPIJwT zPpEt-^(77ZPw1SXIF|SQPv~z$@&2uP^pUnaBG&xiV~62vO+h=1W|1?koI(jL!)PQ^ z0Y1ZN5*r|4VSqK;6AC13cQ`(ry0a2#2a1%kQvOu*ipE}CAR?MhVQp+!@UdZC;BqvI z88xfRc%$H-unu!%rir4|_hzh{(pV3RoA5EB<19r(_zuRRTd>c>0*fD!QqK?9rCZII-a0mb5 z@c&EMfSlNv!ImUk;21NJ6<^`LqY*Q54yz$lF0z4nqw#L(rsByc6{d_t25p>hwKtEw z$KW&k3yt7VIHwVHtl15Jk@11O;?Jp^A$=^h2KxX}7l=;8?j-#?son+)su*%Aly~aJ z;%n>12q7YYU%6Xmd?IF|&*QOuzDN$1N!a5L9G+DmU<#5XyuALJ!4Yo=EfQHmi9ZV8 z7K>ySAGcmJY)+!NByKjR>kEP7XfX303dhl@WI-v zc`8ojFb#^YmcqOSaw9Gs4K$#zIjr|FC@)TYxEvYCa&*;vZ(3|t7gn0FSK zip^l6SlkV6X)xh)8Cb0jF=XgPT7VXD;13r`R1$xjBo-H3DHiZk5 zaH!^?Jn1zVKSE$Q@92k%<*;cohG&o9$*B=y8;;1pehLoMJ&wl{?Ar)T)IDqY=a`04l=%jK7!N28b=_&yJNAGwZaC)Z;UH?I?0K|wzDRkU8f zc6?ud<>TZNHu5-pIvvPhA*Rz}Qn{UD-f(-nm_lp@&N{RJrEiaMb#esD6Jm3Stic-A zUpsRM4ZJ*8Qw3>YEi!inzZ;?mw$oRqXbJ^ zh_A&%E*X*EIHJB{L_%gDd3#kLUEv=y@K}~L@Z{MHyh@xKftiVUrZr-UsYN(<#VvuD zLE0_c$EP^_<~ENli!s}{{|Jr*4i({7#)@K`^!N99+pFsGbt^ki&RLagov>G94R3*wi+v z>y3raV{~;Jr`*})82n9&tj@Y+bovHK)6R2_?a|++|5V*!l-BHfpt<>m&!Z=Gve|Ae zU!C35ymh$$)a|YddSnMXt~@G#xoX>u>W4Rij~ZFr4oWUD&j|1dud;U9{>NUYpzR%R zj}&MwWasTKy|*NDZ-0sA$Kl^>yyO)2%I@>ZjGraa)vf0jjE$Q!!84*I=Zfcqd)3+V z4>#xNBDUtXb$MHSF7oSlH8R`dPaIS=OO_0JSF`kXtE^Aqd*6oS0PVJfC7QA@MM+d! zRb-sf@l;5X_xSR+B~j)2oHFH!SnbMVT^}WduXz?e=5&Y2+x%PC-`SmQ^qmsZm{E4( zS;6C`SKDUheUe6C{@8|jNf)kmoLCnNhgSEBi49bm56yFUpXv%{YkZ|1pKEh|%{cE=^kaC z5m{$C_@UEh4ntba3T~{9%DdU$VrAK!*Kx&8(=6I!J#Xx}{Ob4kBb8_3cAvlB7mCa0 z2H$K8*#A=M{d3b#+sb#pXmrkgvDSEn&UN14^u#IuUDn+1;<;3(30~^bCI_wUoprgP zl}}2>>}(5+kC7WYg!>h?az;kdH4-Bu{TYc0wy3D|vnF zcP3K?8OBtMl^Da8-Z=2iL6Gk#Q|s#nQFz09G%x_GZ%R!eqz}3{x$-V{u$mW{2BC&K zeW-@p0@RiUbAb?LOM}S30Df$JQ>YmnwWS`UBJ_jq1-}uc46BAa_s3461$sk>sRfzggSc+q_`5b6S()K zTC(7zp}o8>^(3F30&_>Ig=REx{$TGwGl|AkGbWDlqVWY2)&o!+ zd1Vm#_pd(8Ij>1P=Zq%a>;?}8V7kKEFF!928<1h2!*g!QQCXnexgGu{U5xML|!^zX@BI4_fi+FZRM2>r-Pw4{@ zse8y-fbS3tc;my)*p8LliH1(wxVJ&%^`?Qd2DJ}HYyXnrgTAyI=zQo168%~ry`ag5 z`jVU`5joz(nZrCUOhU0QCSlVX!8V4RZx%!^7&4TGksYlfvVSP`BES4D5L4*xhezJC zzZfy3$N4>0_;NptEQ^ChAuMbC;Ws~A=rSUZSg^Lk5c(MtajEt)791SmuVI+_$7TXC zfp7h(DQFeM7;^k^f_n4LwgB?0k`Xr*QNW%koWM5#*LcyB;k*D$MtKk~)R3m8GSGyP zo=_h^BS}kWXRIsy^730Ic=-|OS~wJjkCSy6_2Eh(A&jPQZ{c7Vok-lzgLxEn z0iST(fPn9qSQn13pB|T(_$?gYG1F?9I9N-%vH502V6wX3Vfc6i=0g8~2~{K=Om5UO zQ5=cA-JUaXFOqt5hd>cU(>OWgN6}1ju7$-JHyl^n!pr zM;r6n7K5v@_Yv6|VzBBj4;7JaeiC!$ojn4*cZG;-yGBqy@@c$4xHZ)L}YR- zX7`6N0#U*#TMY0{Ql|hfBnb{Zz$FgL>%{~S*%XIoOk}Evn2)5PM3o^TlQVGfUyQ`0 z`AlKBek7h}hxJSZ#N+#=YP}%3gC+qV6M4DB86L!AFV~HoZC)g2J0mOhVG1g?<6p~D zF!Un{n1=(qMYfIvJncvC6NnY$jKUG)Di~Q(fn9Ms@dh*syY}n?*AsEeMs$&ygL*VN z8Yy{V2mVTFFId2n9%@ELs--qOQ9#>h?7Bw7ur?7VT&xuYg&M8&!=_dw;tT2u)F#p# z((cQjVc1#z|O)Ed`8d$5CVOorMc4=I<6Ag;MeDsu8v((dlI59Kku5bj%fmF>D@( z>sm11K+4DC4#zDJta8we#~1S|*fO4`a%0LT&`BiY0JKcR*gv0uzCMSUC^;-u!#C+T zeZOQ}&DBbVrzfM2^9d$&C!{^#buwl;vzC!PwNh)gztbjSuQ4|nJ}{96arMwVk?Ocf zkT!|VCH{4gK8Xf_Dg_t*%a6=&*fVKQu;a_4<0bCIo)o;`H{uJ7kFGw21`rj#sXhof zOl`vbNK3`(|I;GERjGJ$Se@Lb9A`SQN zONofoOJv<4J{fJeOff;Ugxz(13E za6KU}6O(TRwV8O2{UQvmXW~USV=_MUp%F}!MablEX);F87|BTgEHsx7XJT0vMp86_ ziHLxK4gs?5WZ(AO{@#8&)u+J)p?6o>+f^089FFN?@Mp4eU$kzoZ$ z+OG-33^o^FnSOeck>&!t2=%?s3pFI)msvyVESyI9NFb(=_DI$ZN(ym>^7>8{^6oM7 z>Qabr!I4h|(G4nQ;c#VzxXgpk8UE=xF3NDqJV(sA0yi6P#<~{XY6H7lu$W6{