Skip to content

Commit 4ba8bab

Browse files
author
ArtRand
committed
add dep to mesos project
2 parents e6a7357 + 113399b commit 4ba8bab

File tree

4 files changed

+20
-3
lines changed

4 files changed

+20
-3
lines changed

docs/structured-streaming-kafka-integration.md

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,8 @@ For Scala/Java applications using SBT/Maven project definitions, link your appli
1515
For Python applications, you need to add this above library and its dependencies when deploying your
1616
application. See the [Deploying](#deploying) subsection below.
1717

18+
For experimenting on `spark-shell`, you need to add this above library and its dependencies too when invoking `spark-shell`. Also see the [Deploying](#deploying) subsection below.
19+
1820
## Reading Data from Kafka
1921

2022
### Creating a Kafka Source for Streaming Queries
@@ -607,5 +609,9 @@ and its dependencies can be directly added to `spark-submit` using `--packages`,
607609

608610
./bin/spark-submit --packages org.apache.spark:spark-sql-kafka-0-10_{{site.SCALA_BINARY_VERSION}}:{{site.SPARK_VERSION_SHORT}} ...
609611

612+
For experimenting on `spark-shell`, you can also use `--packages` to add `spark-sql-kafka-0-10_{{site.SCALA_BINARY_VERSION}}` and its dependencies directly,
613+
614+
./bin/spark-shell --packages org.apache.spark:spark-sql-kafka-0-10_{{site.SCALA_BINARY_VERSION}}:{{site.SPARK_VERSION_SHORT}} ...
615+
610616
See [Application Submission Guide](submitting-applications.html) for more details about submitting
611617
applications with external dependencies.

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -510,7 +510,7 @@
510510
<groupId>org.slf4j</groupId>
511511
<artifactId>jcl-over-slf4j</artifactId>
512512
<version>${slf4j.version}</version>
513-
<scope>runtime</scope>
513+
<!-- runtime scope is appropriate, but causes SBT build problems -->
514514
</dependency>
515515
<dependency>
516516
<groupId>log4j</groupId>

resource-managers/mesos/pom.xml

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,17 @@
7474
<scope>test</scope>
7575
</dependency>
7676

77+
<dependency>
78+
<groupId>${hive.group}</groupId>
79+
<artifactId>hive-exec</artifactId>
80+
<scope>provided</scope>
81+
</dependency>
82+
<dependency>
83+
<groupId>${hive.group}</groupId>
84+
<artifactId>hive-metastore</artifactId>
85+
<scope>provided</scope>
86+
</dependency>
87+
7788
<!-- Explicitly depend on shaded dependencies from the parent, since shaded deps aren't transitive -->
7889
<dependency>
7990
<groupId>com.google.guava</groupId>

sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ArrowColumnVector.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -240,7 +240,7 @@ public int getArrayOffset(int rowId) {
240240
}
241241

242242
@Override
243-
public void loadBytes(Array array) {
243+
public void loadBytes(ColumnVector.Array array) {
244244
throw new UnsupportedOperationException();
245245
}
246246

@@ -304,7 +304,7 @@ public ArrowColumnVector(ValueVector vector) {
304304

305305
childColumns = new ColumnVector[1];
306306
childColumns[0] = new ArrowColumnVector(listVector.getDataVector());
307-
resultArray = new Array(childColumns[0]);
307+
resultArray = new ColumnVector.Array(childColumns[0]);
308308
} else if (vector instanceof MapVector) {
309309
MapVector mapVector = (MapVector) vector;
310310
accessor = new StructAccessor(mapVector);

0 commit comments

Comments
 (0)