Skip to content

Commit

Permalink
pocket lint
Browse files Browse the repository at this point in the history
  • Loading branch information
ericcheatham committed Aug 3, 2023
1 parent 0b403a8 commit e99755d
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cmd/meroxa/flink/deploy.go
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,8 @@ func GetIRSpec(ctx context.Context, jarPath string, secrets map[string]string, l
irFilepath := filepath.Join(cwd, irFilename)

// The submitted jar is executed with some special env vars set to inform the `MeroxaExecutionEnvironment` to
// short circuit execution and emit an IR spec instead https://github.com/meroxa/flink-platform-prototype/blob/main/src/main/java/com/meroxa/flink/MeroxaExecutionEnvironment.java#L64-L69
// short circuit execution and emit an IR spec instead
// https://github.com/meroxa/flink-platform-prototype/blob/main/src/main/java/com/meroxa/flink/MeroxaExecutionEnvironment.java#L64-L69
cmd := exec.CommandContext(ctx, "java", "-jar", jarPath)
cmd.Env = append(
cmd.Environ(),
Expand Down Expand Up @@ -129,7 +130,6 @@ func GetIRSpec(ctx context.Context, jarPath string, secrets map[string]string, l
spec.Streams = append(spec.Streams, ss)
}
return &spec, nil

}

func verifyJavaVersion(ctx context.Context, l log.Logger) {
Expand Down

0 comments on commit e99755d

Please sign in to comment.