Skip to content

Commit 9bdc776

Browse files
committed
Fix review comments
1 parent 38eae1d commit 9bdc776

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

  • internal/pkg/object/command/spark

internal/pkg/object/command/spark/spark.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ func (s *sparkCommandContext) handler(r *plugin.Runtime, j *job.Job, c *cluster.
173173

174174
// let's set job driver
175175
jobDriver := &types.JobDriver{}
176-
setJobDriver(jobContext, jobDriver, s, queryURI, resultURI)
176+
s.setJobDriver(jobContext, jobDriver, queryURI, resultURI)
177177

178178
// let's prepare job payload
179179
jobPayload := &emrcontainers.StartJobRunInput{
@@ -254,7 +254,7 @@ timeoutLoop:
254254

255255
}
256256

257-
func setJobDriver(jobContext *sparkJobContext, jobDriver *types.JobDriver, s *sparkCommandContext, queryURI string, resultURI string) {
257+
func (s *sparkCommandContext) setJobDriver(jobContext *sparkJobContext, jobDriver *types.JobDriver, queryURI string, resultURI string) {
258258
jobParameters := getSparkSubmitParameters(jobContext)
259259
if jobContext.Arguments != nil {
260260
jobDriver.SparkSubmitJobDriver = &types.SparkSubmitJobDriver{

0 commit comments

Comments
 (0)