Conversation
|
the upgrading causes a core dump in iceberg-spark-3.5's tests |
|
the failure seems related to arrow minimal reproduce command |
|
update: the failure is related to SPARK-50235, and the test passed on Spark 3.5.4 RC1 with reverting that patch |
|
Please check for some discussion there apache/spark#49131 (comment) |
Yes, I tested it locally and found that after adding a no-op |
|
@viirya @LuciferYang thank you for the guidance, let me try |
| // If a column vector is writable or constant, it should override this method and do nothing. | ||
| // See more details at SPARK-50235, SPARK-50463 (Fixed in Spark 3.5.4) | ||
| @Override | ||
| public void closeIfNotWritable() {} |
There was a problem hiding this comment.
will rename to closeIfFreeable after RC2 available
There was a problem hiding this comment.
If a column vector is writable or constant, it should override this method and do nothing.
we have ConstantColumnVector as well, should we do it vector classes which absolutely requires it ?
There was a problem hiding this comment.
I checked the codebase, other vectors overwrite void close() {}, so they are not affected
singhpk234
left a comment
There was a problem hiding this comment.
Nice catch @pan3793 !
| // If a column vector is writable or constant, it should override this method and do nothing. | ||
| // See more details at SPARK-50235, SPARK-50463 (Fixed in Spark 3.5.4) | ||
| @Override | ||
| public void closeIfNotWritable() {} |
There was a problem hiding this comment.
If a column vector is writable or constant, it should override this method and do nothing.
we have ConstantColumnVector as well, should we do it vector classes which absolutely requires it ?
|
FYI @LuciferYang @viirya @dongjoon-hyun @wForget CI is green now, and I think the current Spark |
|
Thank you for checking Apache Iceberg side, @pan3793 . |
|
Thanks @pan3793 for catching this early. Could you create a separate PR for just the patch? We can include this in 1.7.2. |
...5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/IcebergArrowColumnVector.java
Outdated
Show resolved
Hide resolved
...5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/IcebergArrowColumnVector.java
Outdated
Show resolved
Hide resolved
...5/spark/src/main/java/org/apache/iceberg/spark/data/vectorized/IcebergArrowColumnVector.java
Outdated
Show resolved
Hide resolved
…ectorized/IcebergArrowColumnVector.java
singhpk234
left a comment
There was a problem hiding this comment.
LGTM as well, thanks @pan3793 !
|
Thanks @pan3793 for fixing this! And thanks @singhpk234, @huaxingao, @LuciferYang, and @viirya for reviewing! |
|
@pan3793 Can you confirm if this was ever patched to 1.6.x? I don't see a 1.6.2 release. We see IlegalAccessError and the process exits with code 139. |
|
@gunrk no 1.6.2 yet, I think you can request a release on the mailing list. |
Bump Spark 3.5.4, with minimal necessary changes related to SPARK-50235 and SPARK-50463.
Note: this PR targets to 1.7.2 and 1.6.2 (for Java8 users)