CDAP - Spark Program - Incompatible expression types "boolean" and "java.lang.Boolean"

125 views
Skip to first unread message

Omar Meza

unread,
Nov 5, 2018, 4:02:06 PM11/5/18
to CDAP User
Hi all!

CDAP application running a Spark Program.

Spark 2.0.0

CDAP 4.3.4

Getting error in logs for the following line, Any idea?

Code:

val column: Column = (ref1.col("codetype1") === ref2.col("codetype1") && ref1.col("othercodetype1") === ref2.col("othercodetype1"))

Error:

Incompatible expression types "boolean" and "java.lang.Boolean"

Logs:

2018-11-05 14:33:07,710 - ERROR [Driver:o.a.s.s.c.e.c.CodeGenerator@91] - failed to compile: org.codehaus.commons.compiler.CompileException: File 'generated.java', Line 950, Column 45: Incompatible expression types "boolean" and "java.lang.Boolean"

/* 001 */ public Object generate(Object[] references) {

/* 002 */ return new GeneratedIterator(references);

/* 003 */ }

/* 004 */

/* 005 */ final class GeneratedIterator extends org.apache.spark.sql.execution.BufferedRowIterator {

/* 006 */ private Object[] references;

/* 007 */ private scala.collection.Iterator inputadapter_input;

/* 008 */ private org.apache.spark.sql.execution.metric.SQLMetric filter_numOutputRows;

/* 009 */ private boolean[] filter_argIsNulls;

/* 010 */ private com.certilytics.nucleo.model.BuildingBlocks filter_argValue;

/* 011 */ private com.certilytics.nucleo.model.CoreReference filter_argValue1;

/* 012 */ private boolean[] filter_argIsNulls1;

/* 013 */ private java.lang.String filter_argValue2;

/* 014 */ private java.lang.String filter_argValue3;

/* 015 */ private java.lang.String filter_argValue4;

/* 016 */ private java.lang.String filter_argValue5;

/* 017 */ private java.lang.String filter_argValue6;

/* 018 */ private java.lang.String filter_argValue7;

/* 019 */ private java.lang.String filter_argValue8;

/* 020 */ private java.lang.String filter_argValue9;

/* 021 */ private java.lang.String filter_argValue10;

/* 022 */ private java.lang.String filter_argValue11;

/* 023 */ private java.lang.String filter_argValue12;

/* 024 */ private java.lang.String filter_argValue13;

/* 025 */ private java.lang.String filter_argValue14;

/* 026 */ private java.lang.String filter_argValue15;

/* 027 */ private int filter_argValue16;

/* 028 */ private java.lang.String filter_argValue17;

/* 029 */ private java.lang.String filter_argValue18;

/* 030 */ private java.lang.String filter_argValue19;

/* 031 */ private java.lang.String filter_argValue20;

/* 032 */ private java.lang.String filter_argValue21;

/* 033 */ private java.lang.String filter_argValue22;

/* 034 */ private java.lang.String filter_argValue23;

/* 035 */ private java.lang.String filter_argValue24;

/* 036 */ private java.lang.String filter_argValue25;

/* 037 */ private java.lang.String filter_argValue26;

/* 038 */ private java.lang.String filter_argValue27;

/* 039 */ private java.lang.String filter_argValue28;

/* 040 */ private java.lang.String filter_argValue29;

/* 041 */ private java.lang.String filter_argValue30;

/* 042 */ private java.lang.String filter_argValue31;

/* 043 */ private java.lang.String filter_argValue32;

/* 044 */ private java.lang.String filter_argValue33;

/* 045 */ private java.lang.String filter_argValue34;

/* 046 */ private java.lang.String filter_argValue35;

/* 047 */ private java.lang.String filter_argValue36;

/* 048 */ private java.lang.String filter_argValue37;

/* 049 */ private java.lang.String filter_argValue38;

/* 050 */ private java.lang.String filter_errMsg;

/* 051 */ private boolean[] filter_argIsNulls2;

/* 052 */ private java.lang.String filter_argValue39;

/* 053 */ private java.lang.String filter_argValue40;

/* 054 */ private java.lang.String filter_argValue41;

/* 055 */ private java.lang.String filter_argValue42;

/* 056 */ private java.lang.String filter_argValue43;

/* 057 */ private java.lang.String filter_argValue44;

/* 058 */ private java.lang.String filter_argValue45;

/* 059 */ private java.lang.String filter_argValue46;

/* 060 */ private java.lang.String filter_argValue47;

/* 061 */ private java.lang.String filter_argValue48;

/* 062 */ private java.lang.String filter_argValue49;

/* 063 */ private java.lang.String filter_argValue50;

/* 064 */ private java.lang.String filter_argValue51;

/* 065 */ private java.lang.String filter_argValue52;

/* 066 */ private java.lang.String filter_argValue53;

/* 067 */ private UnsafeRow filter_result;

/* 068 */ private org.apache.spark.sql.catalyst.expressions.codegen.BufferHolder filter_holder;

/* 069 */ private org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter filter_rowWriter;

/* 070 */ private org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter filter_rowWriter1;

/* 071 */ private org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter filter_rowWriter2;

/* 072 */

/* 073 */ public GeneratedIterator(Object[] references) {

/* 074 */ this.references = references;

/* 075 */ }

/* 076 */

/* 077 */ public void init(int index, scala.collection.Iterator inputs[]) {

/* 078 */ partitionIndex = index;

/* 079 */ inputadapter_input = inputs[0];

/* 080 */ this.filter_numOutputRows = (org.apache.spark.sql.execution.metric.SQLMetric) references[0];

/* 081 */ filter_argIsNulls = new boolean[2];

/* 082 */

/* 083 */ filter_argIsNulls1 = new boolean[37];

/* 084 */

/* 085 */ this.filter_errMsg = (java.lang.String) references[2];

/* 086 */ filter_argIsNulls2 = new boolean[15];

/* 087 */

/* 088 */ filter_result = new UnsafeRow(2);

/* 089 */ this.filter_holder = new org.apache.spark.sql.catalyst.expressions.codegen.BufferHolder(filter_result, 64);

/* 090 */ this.filter_rowWriter = new org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter(filter_holder, 2);

/* 091 */ this.filter_rowWriter1 = new org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter(filter_holder, 37);

/* 092 */ this.filter_rowWriter2 = new org.apache.spark.sql.catalyst.expressions.codegen.UnsafeRowWriter(filter_holder, 15);

/* 093 */ }

/* 094 */

/* 095 */ protected void processNext() throws java.io.IOException {

/* 096 */ while (inputadapter_input.hasNext()) {

/* 097 */ InternalRow inputadapter_row = (InternalRow) inputadapter_input.next();

/* 098 */ InternalRow inputadapter_value = inputadapter_row.getStruct(0, 37);

/* 099 */ boolean inputadapter_isNull1 = inputadapter_row.isNullAt(1);

/* 100 */ InternalRow inputadapter_value1 = inputadapter_isNull1 ? null : (inputadapter_row.getStruct(1, 15));

/* 101 */

/* 102 */ Object filter_obj = ((Expression) references[1]).eval(null);

/* 103 */ scala.Function1 filter_value1 = (scala.Function1) filter_obj;

/* 104 */

/* 105 */ boolean filter_isNull5 = false;

/* 106 */ UTF8String filter_value5 = null;

/* 107 */

/* 108 */ if (inputadapter_value.isNullAt(0)) {

/* 109 */ filter_isNull5 = true;

/* 110 */ } else {

/* 111 */ filter_value5 = inputadapter_value.getUTF8String(0);

/* 112 */ }

/* 113 */

/* 114 */ boolean filter_isNull4 = filter_isNull5;

/* 115 */ final java.lang.String filter_value4 = filter_isNull4 ? null : (java.lang.String) filter_value5.toString();

/* 116 */ filter_isNull4 = filter_value4 == null;

/* 117 */ filter_argIsNulls1[0] = filter_isNull4;

/* 118 */ filter_argValue2 = filter_value4;

/* 119 */

/* 120 */ boolean filter_isNull8 = false;

/* 121 */ UTF8String filter_value8 = null;

/* 122 */

/* 123 */ if (inputadapter_value.isNullAt(1)) {

/* 124 */ filter_isNull8 = true;

/* 125 */ } else {

/* 126 */ filter_value8 = inputadapter_value.getUTF8String(1);

/* 127 */ }

/* 128 */

/* 129 */ boolean filter_isNull7 = filter_isNull8;

/* 130 */ final java.lang.String filter_value7 = filter_isNull7 ? null : (java.lang.String) filter_value8.toString();

/* 131 */ filter_isNull7 = filter_value7 == null;

/* 132 */ filter_argIsNulls1[1] = filter_isNull7;

/* 133 */ filter_argValue3 = filter_value7;

/* 134 */

/* 135 */ boolean filter_isNull11 = false;

/* 136 */ UTF8String filter_value11 = null;

/* 137 */

/* 138 */ if (inputadapter_value.isNullAt(2)) {

/* 139 */ filter_isNull11 = true;

/* 140 */ } else {

/* 141 */ filter_value11 = inputadapter_value.getUTF8String(2);

/* 142 */ }

/* 143 */

/* 144 */ boolean filter_isNull10 = filter_isNull11;

/* 145 */ final java.lang.String filter_value10 = filter_isNull10 ? null : (java.lang.String) filter_value11.toString();

/* 146 */ filter_isNull10 = filter_value10 == null;

/* 147 */ filter_argIsNulls1[2] = filter_isNull10;

/* 148 */ filter_argValue4 = filter_value10;

/* 149 */

/* 150 */ boolean filter_isNull14 = false;

/* 151 */ UTF8String filter_value14 = null;

/* 152 */

/* 153 */ if (inputadapter_value.isNullAt(3)) {

/* 154 */ filter_isNull14 = true;

/* 155 */ } else {

/* 156 */ filter_value14 = inputadapter_value.getUTF8String(3);

/* 157 */ }

/* 158 */

/* 159 */ boolean filter_isNull13 = filter_isNull14;

/* 160 */ final java.lang.String filter_value13 = filter_isNull13 ? null : (java.lang.String) filter_value14.toString();

/* 161 */ filter_isNull13 = filter_value13 == null;

/* 162 */ filter_argIsNulls1[3] = filter_isNull13;

/* 163 */ filter_argValue5 = filter_value13;

/* 164 */

/* 165 */ boolean filter_isNull17 = false;

/* 166 */ UTF8String filter_value17 = null;

/* 167 */

/* 168 */ if (inputadapter_value.isNullAt(4)) {

/* 169 */ filter_isNull17 = true;

/* 170 */ } else {

/* 171 */ filter_value17 = inputadapter_value.getUTF8String(4);

/* 172 */ }

/* 173 */

/* 174 */ boolean filter_isNull16 = filter_isNull17;

/* 175 */ final java.lang.String filter_value16 = filter_isNull16 ? null : (java.lang.String) filter_value17.toString();

/* 176 */ filter_isNull16 = filter_value16 == null;

/* 177 */ filter_argIsNulls1[4] = filter_isNull16;

/* 178 */ filter_argValue6 = filter_value16;

/* 179 */

/* 180 */ boolean filter_isNull20 = false;

/* 181 */ UTF8String filter_value20 = null;

/* 182 */

/* 183 */ if (inputadapter_value.isNullAt(5)) {

/* 184 */ filter_isNull20 = true;

/* 185 */ } else {

/* 186 */ filter_value20 = inputadapter_value.getUTF8String(5);

/* 187 */ }

/* 188 */

/* 189 */ boolean filter_isNull19 = filter_isNull20;

/* 190 */ final java.lang.String filter_value19 = filter_isNull19 ? null : (java.lang.String) filter_value20.toString();

/* 191 */ filter_isNull19 = filter_value19 == null;

/* 192 */ filter_argIsNulls1[5] = filter_isNull19;

/* 193 */ filter_argValue7 = filter_value19;

/* 194 */

/* 195 */ boolean filter_isNull23 = false;

/* 196 */ UTF8String filter_value23 = null;

/* 197 */

/* 198 */ if (inputadapter_value.isNullAt(6)) {

/* 199 */ filter_isNull23 = true;

/* 200 */ } else {

/* 201 */ filter_value23 = inputadapter_value.getUTF8String(6);

/* 202 */ }

/* 203 */

/* 204 */ boolean filter_isNull22 = filter_isNull23;

/* 205 */ final java.lang.String filter_value22 = filter_isNull22 ? null : (java.lang.String) filter_value23.toString();

/* 206 */ filter_isNull22 = filter_value22 == null;

/* 207 */ filter_argIsNulls1[6] = filter_isNull22;

/* 208 */ filter_argValue8 = filter_value22;

/* 209 */

/* 210 */ boolean filter_isNull26 = false;

/* 211 */ UTF8String filter_value26 = null;

/* 212 */

/* 213 */ if (inputadapter_value.isNullAt(7)) {

/* 214 */ filter_isNull26 = true;

/* 215 */ } else {

/* 216 */ filter_value26 = inputadapter_value.getUTF8String(7);

/* 217 */ }

/* 218 */

/* 219 */ boolean filter_isNull25 = filter_isNull26;

/* 220 */ final java.lang.String filter_value25 = filter_isNull25 ? null : (java.lang.String) filter_value26.toString();

/* 221 */ filter_isNull25 = filter_value25 == null;

/* 222 */ filter_argIsNulls1[7] = filter_isNull25;

/* 223 */ filter_argValue9 = filter_value25;

/* 224 */

/* 225 */ boolean filter_isNull29 = false;

/* 226 */ UTF8String filter_value29 = null;

/* 227 */

/* 228 */ if (inputadapter_value.isNullAt(8)) {

/* 229 */ filter_isNull29 = true;

/* 230 */ } else {

/* 231 */ filter_value29 = inputadapter_value.getUTF8String(8);

/* 232 */ }

/* 233 */

/* 234 */ boolean filter_isNull28 = filter_isNull29;

/* 235 */ final java.lang.String filter_value28 = filter_isNull28 ? null : (java.lang.String) filter_value29.toString();

/* 236 */ filter_isNull28 = filter_value28 == null;

/* 237 */ filter_argIsNulls1[8] = filter_isNull28;

/* 238 */ filter_argValue10 = filter_value28;

/* 239 */

/* 240 */ boolean filter_isNull32 = false;

/* 241 */ UTF8String filter_value32 = null;

/* 242 */

/* 243 */ if (inputadapter_value.isNullAt(9)) {

/* 244 */ filter_isNull32 = true;

/* 245 */ } else {

/* 246 */ filter_value32 = inputadapter_value.getUTF8String(9);

/* 247 */ }

/* 248 */

/* 249 */ boolean filter_isNull31 = filter_isNull32;

/* 250 */ final java.lang.String filter_value31 = filter_isNull31 ? null : (java.lang.String) filter_value32.toString();

/* 251 */ filter_isNull31 = filter_value31 == null;

/* 252 */ filter_argIsNulls1[9] = filter_isNull31;

/* 253 */ filter_argValue11 = filter_value31;

/* 254 */

/* 255 */ boolean filter_isNull35 = false;

/* 256 */ UTF8String filter_value35 = null;

/* 257 */

/* 258 */ if (inputadapter_value.isNullAt(10)) {

/* 259 */ filter_isNull35 = true;

/* 260 */ } else {

/* 261 */ filter_value35 = inputadapter_value.getUTF8String(10);

/* 262 */ }

/* 263 */

/* 264 */ boolean filter_isNull34 = filter_isNull35;

/* 265 */ final java.lang.String filter_value34 = filter_isNull34 ? null : (java.lang.String) filter_value35.toString();

/* 266 */ filter_isNull34 = filter_value34 == null;

/* 267 */ filter_argIsNulls1[10] = filter_isNull34;

/* 268 */ filter_argValue12 = filter_value34;

/* 269 */

/* 270 */ boolean filter_isNull38 = false;

/* 271 */ UTF8String filter_value38 = null;

/* 272 */

/* 273 */ if (inputadapter_value.isNullAt(11)) {

/* 274 */ filter_isNull38 = true;

/* 275 */ } else {

/* 276 */ filter_value38 = inputadapter_value.getUTF8String(11);

/* 277 */ }

/* 278 */

/* 279 */ boolean filter_isNull37 = filter_isNull38;

/* 280 */ final java.lang.String filter_value37 = filter_isNull37 ? null : (java.lang.String) filter_value38.toString();

/* 281 */ filter_isNull37 = filter_value37 == null;

/* 282 */ filter_argIsNulls1[11] = filter_isNull37;

/* 283 */ filter_argValue13 = filter_value37;

/* 284 */

/* 285 */ boolean filter_isNull41 = false;

/* 286 */ UTF8String filter_value41 = null;

/* 287 */

/* 288 */ if (inputadapter_value.isNullAt(12)) {

/* 289 */ filter_isNull41 = true;

/* 290 */ } else {

/* 291 */ filter_value41 = inputadapter_value.getUTF8String(12);

/* 292 */ }

/* 293 */

/* 294 */ boolean filter_isNull40 = filter_isNull41;

/* 295 */ final java.lang.String filter_value40 = filter_isNull40 ? null : (java.lang.String) filter_value41.toString();

/* 296 */ filter_isNull40 = filter_value40 == null;

/* 297 */ filter_argIsNulls1[12] = filter_isNull40;

/* 298 */ filter_argValue14 = filter_value40;

/* 299 */

/* 300 */ boolean filter_isNull44 = false;

/* 301 */ UTF8String filter_value44 = null;

/* 302 */

/* 303 */ if (inputadapter_value.isNullAt(13)) {

/* 304 */ filter_isNull44 = true;

/* 305 */ } else {

/* 306 */ filter_value44 = inputadapter_value.getUTF8String(13);

/* 307 */ }

/* 308 */

/* 309 */ boolean filter_isNull43 = filter_isNull44;

/* 310 */ final java.lang.String filter_value43 = filter_isNull43 ? null : (java.lang.String) filter_value44.toString();

/* 311 */ filter_isNull43 = filter_value43 == null;

/* 312 */ filter_argIsNulls1[13] = filter_isNull43;

/* 313 */ filter_argValue15 = filter_value43;

/* 314 */

/* 315 */ boolean filter_isNull47 = false;

/* 316 */ int filter_value47 = -1;

/* 317 */

/* 318 */ if (inputadapter_value.isNullAt(14)) {

/* 319 */ filter_isNull47 = true;

/* 320 */ } else {

/* 321 */ filter_value47 = inputadapter_value.getInt(14);

/* 322 */ }

/* 323 */

/* 324 */ if (filter_isNull47) {

/* 325 */ throw new RuntimeException(filter_errMsg);

/* 326 */ }

/* 327 */ filter_argIsNulls1[14] = false;

/* 328 */ filter_argValue16 = filter_value47;

/* 329 */

/* 330 */ boolean filter_isNull50 = false;

/* 331 */ UTF8String filter_value50 = null;

/* 332 */

/* 333 */ if (inputadapter_value.isNullAt(15)) {

/* 334 */ filter_isNull50 = true;

/* 335 */ } else {

/* 336 */ filter_value50 = inputadapter_value.getUTF8String(15);

/* 337 */ }

/* 338 */

/* 339 */ boolean filter_isNull49 = filter_isNull50;

/* 340 */ final java.lang.String filter_value49 = filter_isNull49 ? null : (java.lang.String) filter_value50.toString();

/* 341 */ filter_isNull49 = filter_value49 == null;

/* 342 */ filter_argIsNulls1[15] = filter_isNull49;

/* 343 */ filter_argValue17 = filter_value49;

/* 344 */

/* 345 */ boolean filter_isNull53 = false;

/* 346 */ UTF8String filter_value53 = null;

/* 347 */

/* 348 */ if (inputadapter_value.isNullAt(16)) {

/* 349 */ filter_isNull53 = true;

/* 350 */ } else {

/* 351 */ filter_value53 = inputadapter_value.getUTF8String(16);

/* 352 */ }

/* 353 */

/* 354 */ boolean filter_isNull52 = filter_isNull53;

/* 355 */ final java.lang.String filter_value52 = filter_isNull52 ? null : (java.lang.String) filter_value53.toString();

/* 356 */ filter_isNull52 = filter_value52 == null;

/* 357 */ filter_argIsNulls1[16] = filter_isNull52;

/* 358 */ filter_argValue18 = filter_value52;

/* 359 */

/* 360 */ boolean filter_isNull56 = false;

/* 361 */ UTF8String filter_value56 = null;

/* 362 */

/* 363 */ if (inputadapter_value.isNullAt(17)) {

/* 364 */ filter_isNull56 = true;

/* 365 */ } else {

/* 366 */ filter_value56 = inputadapter_value.getUTF8String(17);

/* 367 */ }

/* 368 */

/* 369 */ boolean filter_isNull55 = filter_isNull56;

/* 370 */ final java.lang.String filter_value55 = filter_isNull55 ? null : (java.lang.String) filter_value56.toString();

/* 371 */ filter_isNull55 = filter_value55 == null;

/* 372 */ filter_argIsNulls1[17] = filter_isNull55;

/* 373 */ filter_argValue19 = filter_value55;

/* 374 */

/* 375 */ boolean filter_isNull59 = false;

/* 376 */ UTF8String filter_value59 = null;

/* 377 */

/* 378 */ if (inputadapter_value.isNullAt(18)) {

/* 379 */ filter_isNull59 = true;

/* 380 */ } else {

/* 381 */ filter_value59 = inputadapter_value.getUTF8String(18);

/* 382 */ }

/* 383 */

/* 384 */ boolean filter_isNull58 = filter_isNull59;

/* 385 */ final java.lang.String filter_value58 = filter_isNull58 ? null : (java.lang.String) filter_value59.toString();

/* 386 */ filter_isNull58 = filter_value58 == null;

/* 387 */ filter_argIsNulls1[18] = filter_isNull58;

/* 388 */ filter_argValue20 = filter_value58;

/* 389 */

/* 390 */ boolean filter_isNull62 = false;

/* 391 */ UTF8String filter_value62 = null;

/* 392 */

/* 393 */ if (inputadapter_value.isNullAt(19)) {

/* 394 */ filter_isNull62 = true;

/* 395 */ } else {

/* 396 */ filter_value62 = inputadapter_value.getUTF8String(19);

/* 397 */ }

/* 398 */

/* 399 */ boolean filter_isNull61 = filter_isNull62;

/* 400 */ final java.lang.String filter_value61 = filter_isNull61 ? null : (java.lang.String) filter_value62.toString();

/* 401 */ filter_isNull61 = filter_value61 == null;

/* 402 */ filter_argIsNulls1[19] = filter_isNull61;

/* 403 */ filter_argValue21 = filter_value61;

/* 404 */

/* 405 */ boolean filter_isNull65 = false;

/* 406 */ UTF8String filter_value65 = null;

/* 407 */

/* 408 */ if (inputadapter_value.isNullAt(20)) {

/* 409 */ filter_isNull65 = true;

/* 410 */ } else {

/* 411 */ filter_value65 = inputadapter_value.getUTF8String(20);

/* 412 */ }

/* 413 */

/* 414 */ boolean filter_isNull64 = filter_isNull65;

/* 415 */ final java.lang.String filter_value64 = filter_isNull64 ? null : (java.lang.String) filter_value65.toString();

/* 416 */ filter_isNull64 = filter_value64 == null;

/* 417 */ filter_argIsNulls1[20] = filter_isNull64;

/* 418 */ filter_argValue22 = filter_value64;

/* 419 */

/* 420 */ boolean filter_isNull68 = false;

/* 421 */ UTF8String filter_value68 = null;

/* 422 */

/* 423 */ if (inputadapter_value.isNullAt(21)) {

/* 424 */ filter_isNull68 = true;

/* 425 */ } else {

/* 426 */ filter_value68 = inputadapter_value.getUTF8String(21);

/* 427 */ }

/* 428 */

/* 429 */ boolean filter_isNull67 = filter_isNull68;

/* 430 */ final java.lang.String filter_value67 = filter_isNull67 ? null : (java.lang.String) filter_value68.toString();

/* 431 */ filter_isNull67 = filter_value67 == null;

/* 432 */ filter_argIsNulls1[21] = filter_isNull67;

/* 433 */ filter_argValue23 = filter_value67;

/* 434 */

/* 435 */ boolean filter_isNull71 = false;

/* 436 */ UTF8String filter_value71 = null;

/* 437 */

/* 438 */ if (inputadapter_value.isNullAt(22)) {

/* 439 */ filter_isNull71 = true;

/* 440 */ } else {

/* 441 */ filter_value71 = inputadapter_value.getUTF8String(22);

/* 442 */ }

/* 443 */

/* 444 */ boolean filter_isNull70 = filter_isNull71;<

Sreevatsan Raman

unread,
Nov 5, 2018, 6:17:24 PM11/5/18
to cdap...@googlegroups.com
Omar:

Does the program work directly on Spark? Is it a problem running just on CDAP? I did a quick search, looks like the issue you reported is seen with spark 2.0.x https://issues.apache.org/jira/browse/SPARK-20176

Sree

--
You received this message because you are subscribed to the Google Groups "CDAP User" group.
To unsubscribe from this group and stop receiving emails from it, send an email to cdap-user+...@googlegroups.com.
To post to this group, send email to cdap...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/cdap-user/6a916f05-f1eb-49ec-91bc-86f2050c5340%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
Reply all
Reply to author
Forward
0 new messages