diff --git a/java/README.md b/java/README.md index 6816fa3d6c97..8b99e91c5893 100644 --- a/java/README.md +++ b/java/README.md @@ -14,7 +14,7 @@ This directory contains the java worker, with the following components. ```sh # build native components -sh ../build.sh -l java "$@" +sh ../build.sh -l java # build java worker mvn clean install -Dmaven.test.skip diff --git a/src/plasma/lib/java/org_ray_spi_impl_PlasmaClientJNI.cc b/src/plasma/lib/java/org_ray_spi_impl_PlasmaClientJNI.cc index 9b5aa00ec42b..f00107190863 100644 --- a/src/plasma/lib/java/org_ray_spi_impl_PlasmaClientJNI.cc +++ b/src/plasma/lib/java/org_ray_spi_impl_PlasmaClientJNI.cc @@ -180,10 +180,10 @@ JNIEXPORT jobjectArray JNICALL Java_org_ray_spi_impl_PlasmaClientJNI_get jobject dataBuf, metadataBuf; for (int i = 0; i < num_oids; ++i) { o = env->NewObjectArray(2, clsByteBuffer, NULL); - if (obufs[i].data_size != -1) { - dataBuf = env->NewDirectByteBuffer(const_cast(obufs[i].data->data()), obufs[i].data_size); - if (obufs[i].metadata_size > 0) { - metadataBuf = env->NewDirectByteBuffer(const_cast(obufs[i].metadata->data()), obufs[i].metadata_size); + if (obufs[i].data && obufs[i].data->size() != -1 ) { + dataBuf = env->NewDirectByteBuffer(const_cast(obufs[i].data->data()), obufs[i].data->size()); + if (obufs[i].metadata && obufs[i].metadata->size() > 0) { + metadataBuf = env->NewDirectByteBuffer(const_cast(obufs[i].metadata->data()), obufs[i].metadata->size()); } else { metadataBuf = NULL;