@@ -135,6 +135,7 @@ class SparkSubmitUtilsSuite extends SparkFunSuite with BeforeAndAfterAll {
135
135
val jarPath = SparkSubmitUtils .resolveMavenCoordinates(
136
136
main.toString,
137
137
SparkSubmitUtils .buildIvySettings(Option (repo), Some (tempIvyPath)),
138
+ transitive = true ,
138
139
isTest = true )
139
140
assert(jarPath.indexOf(tempIvyPath) >= 0 , " should use non-default ivy path" )
140
141
}
@@ -148,6 +149,7 @@ class SparkSubmitUtilsSuite extends SparkFunSuite with BeforeAndAfterAll {
148
149
val jarPath = SparkSubmitUtils .resolveMavenCoordinates(
149
150
main.toString,
150
151
SparkSubmitUtils .buildIvySettings(None , Some (tempIvyPath)),
152
+ transitive = true ,
151
153
isTest = true )
152
154
assert(jarPath.indexOf(" mylib" ) >= 0 , " should find artifact" )
153
155
assert(jarPath.indexOf(" mydep" ) >= 0 , " should find dependency" )
@@ -159,6 +161,7 @@ class SparkSubmitUtilsSuite extends SparkFunSuite with BeforeAndAfterAll {
159
161
val jarPath = SparkSubmitUtils .resolveMavenCoordinates(
160
162
main.toString,
161
163
SparkSubmitUtils .buildIvySettings(None , Some (tempIvyPath)),
164
+ transitive = true ,
162
165
isTest = true )
163
166
assert(jarPath.indexOf(" mylib" ) >= 0 , " should find artifact" )
164
167
assert(jarPath.indexOf(" mydep" ) >= 0 , " should find dependency" )
@@ -171,6 +174,7 @@ class SparkSubmitUtilsSuite extends SparkFunSuite with BeforeAndAfterAll {
171
174
val jarPath = SparkSubmitUtils .resolveMavenCoordinates(
172
175
main.toString,
173
176
SparkSubmitUtils .buildIvySettings(None , Some (tempIvyPath)),
177
+ transitive = true ,
174
178
isTest = true )
175
179
assert(jarPath.indexOf(" mylib" ) >= 0 , " should find artifact" )
176
180
assert(jarPath.indexOf(tempIvyPath) >= 0 , " should be in new ivy path" )
@@ -183,6 +187,7 @@ class SparkSubmitUtilsSuite extends SparkFunSuite with BeforeAndAfterAll {
183
187
SparkSubmitUtils .resolveMavenCoordinates(
184
188
" a:b:c" ,
185
189
SparkSubmitUtils .buildIvySettings(None , Some (tempIvyPath)),
190
+ transitive = true ,
186
191
isTest = true )
187
192
}
188
193
}
@@ -195,13 +200,15 @@ class SparkSubmitUtilsSuite extends SparkFunSuite with BeforeAndAfterAll {
195
200
val path = SparkSubmitUtils .resolveMavenCoordinates(
196
201
coordinates,
197
202
SparkSubmitUtils .buildIvySettings(None , Some (tempIvyPath)),
203
+ transitive = true ,
198
204
isTest = true )
199
205
assert(path === " " , " should return empty path" )
200
206
val main = MavenCoordinate (" org.apache.spark" , " spark-streaming-kafka-assembly_2.12" , " 1.2.0" )
201
207
IvyTestUtils .withRepository(main, None , None ) { repo =>
202
208
val files = SparkSubmitUtils .resolveMavenCoordinates(
203
209
coordinates + " ," + main.toString,
204
210
SparkSubmitUtils .buildIvySettings(Some (repo), Some (tempIvyPath)),
211
+ transitive = true ,
205
212
isTest = true )
206
213
assert(files.indexOf(main.artifactId) >= 0 , " Did not return artifact" )
207
214
}
@@ -215,6 +222,7 @@ class SparkSubmitUtilsSuite extends SparkFunSuite with BeforeAndAfterAll {
215
222
main.toString,
216
223
SparkSubmitUtils .buildIvySettings(Some (repo), Some (tempIvyPath)),
217
224
exclusions = Seq (" my.great.dep:mydep" ),
225
+ transitive = true ,
218
226
isTest = true )
219
227
assert(files.indexOf(main.artifactId) >= 0 , " Did not return artifact" )
220
228
assert(files.indexOf(" my.great.dep" ) < 0 , " Returned excluded artifact" )
@@ -250,7 +258,8 @@ class SparkSubmitUtilsSuite extends SparkFunSuite with BeforeAndAfterAll {
250
258
testUtilSettings.setDefaultIvyUserDir(new File (tempIvyPath))
251
259
IvyTestUtils .withRepository(main, Some (dep), Some (dummyIvyLocal), useIvyLayout = true ,
252
260
ivySettings = testUtilSettings) { repo =>
253
- val jarPath = SparkSubmitUtils .resolveMavenCoordinates(main.toString, settings, isTest = true )
261
+ val jarPath = SparkSubmitUtils .resolveMavenCoordinates(main.toString, settings,
262
+ transitive = true , isTest = true )
254
263
assert(jarPath.indexOf(" mylib" ) >= 0 , " should find artifact" )
255
264
assert(jarPath.indexOf(tempIvyPath) >= 0 , " should be in new ivy path" )
256
265
assert(jarPath.indexOf(" mydep" ) >= 0 , " should find dependency" )
@@ -265,6 +274,7 @@ class SparkSubmitUtilsSuite extends SparkFunSuite with BeforeAndAfterAll {
265
274
val jarPath = SparkSubmitUtils .resolveMavenCoordinates(
266
275
main.toString,
267
276
ivySettings,
277
+ transitive = true ,
268
278
isTest = true )
269
279
val r = """ .*org.apache.spark-spark-submit-parent-.*""" .r
270
280
assert(! ivySettings.getDefaultCache.listFiles.map(_.getName)
0 commit comments