apilloud commented on code in PR #23609:
URL: https://github.com/apache/beam/pull/23609#discussion_r995175235
##########
.test-infra/jenkins/job_PostCommit_Java_Nexmark_Direct.groovy:
##########
@@ -30,133 +30,12 @@ import static NexmarkDatabaseProperties.nexmarkInfluxDBArgs
NoPhraseTriggeringPostCommitBuilder.postCommitJob('beam_PostCommit_Java_Nexmark_Direct',
'Direct Runner Nexmark Tests', this) {
+
description('Runs the Nexmark suite on the Direct runner.')
- // Set common parameters.
commonJobProperties.setTopLevelMainJobProperties(delegate, 'master',
240, true, 'beam-perf')
- InfluxDBCredentialsHelper.useCredentials(delegate)
- // Gradle goals for this job.
- steps {
- shell('echo "*** RUN NEXMARK IN BATCH MODE USING DIRECT RUNNER ***"')
- gradle {
- rootBuildScriptDir(commonJobProperties.checkoutDir)
- tasks(':sdks:java:testing:nexmark:run')
- commonJobProperties.setGradleSwitches(delegate)
- switches('-Pnexmark.runner=":runners:direct-java"' +
- ' -Pnexmark.args="' +
- [
- commonJobProperties.mapToArgString(nexmarkBigQueryArgs),
- commonJobProperties.mapToArgString(nexmarkInfluxDBArgs),
- '--runner=DirectRunner',
- '--streaming=false',
- '--suite=SMOKE',
- '--manageResources=false',
- '--monitorJobs=true',
- '--enforceEncodability=true',
- '--enforceImmutability=true"'
- ].join(' '))
- }
- shell('echo "*** RUN NEXMARK IN STREAMING MODE USING DIRECT RUNNER
***"')
- gradle {
- rootBuildScriptDir(commonJobProperties.checkoutDir)
- tasks(':sdks:java:testing:nexmark:run')
- commonJobProperties.setGradleSwitches(delegate)
- switches('-Pnexmark.runner=":runners:direct-java"' +
- ' -Pnexmark.args="' +
- [
- commonJobProperties.mapToArgString(nexmarkBigQueryArgs),
- commonJobProperties.mapToArgString(nexmarkInfluxDBArgs),
- '--runner=DirectRunner',
- '--streaming=true',
- '--suite=SMOKE',
- '--manageResources=false',
- '--monitorJobs=true',
- '--enforceEncodability=true',
- '--enforceImmutability=true"'
- ].join(' '))
- }
- shell('echo "*** RUN NEXMARK IN SQL BATCH MODE USING DIRECT RUNNER
***"')
- gradle {
- rootBuildScriptDir(commonJobProperties.checkoutDir)
- tasks(':sdks:java:testing:nexmark:run')
- commonJobProperties.setGradleSwitches(delegate)
- switches('-Pnexmark.runner=":runners:direct-java"' +
- ' -Pnexmark.args="' +
- [
- commonJobProperties.mapToArgString(nexmarkBigQueryArgs),
- commonJobProperties.mapToArgString(nexmarkInfluxDBArgs),
- '--runner=DirectRunner',
- '--queryLanguage=sql',
- '--streaming=false',
- '--suite=SMOKE',
- '--manageResources=false',
- '--monitorJobs=true',
- '--enforceEncodability=true',
- '--enforceImmutability=true"'
- ].join(' '))
- }
- shell('echo "*** RUN NEXMARK IN SQL STREAMING MODE USING DIRECT RUNNER
***"')
- gradle {
- rootBuildScriptDir(commonJobProperties.checkoutDir)
- tasks(':sdks:java:testing:nexmark:run')
- commonJobProperties.setGradleSwitches(delegate)
- switches('-Pnexmark.runner=":runners:direct-java"' +
- ' -Pnexmark.args="' +
- [
- commonJobProperties.mapToArgString(nexmarkBigQueryArgs),
- commonJobProperties.mapToArgString(nexmarkInfluxDBArgs),
- '--runner=DirectRunner',
- '--queryLanguage=sql',
- '--streaming=true',
- '--suite=SMOKE',
- '--manageResources=false',
- '--monitorJobs=true',
- '--enforceEncodability=true',
- '--enforceImmutability=true"'
- ].join(' '))
- }
- shell('echo "*** RUN NEXMARK IN ZETASQL BATCH MODE USING DIRECT RUNNER
***"')
- gradle {
- rootBuildScriptDir(commonJobProperties.checkoutDir)
- tasks(':sdks:java:testing:nexmark:run')
- commonJobProperties.setGradleSwitches(delegate)
- switches('-Pnexmark.runner=":runners:direct-java"' +
- ' -Pnexmark.args="' +
- [
- commonJobProperties.mapToArgString(nexmarkBigQueryArgs),
- commonJobProperties.mapToArgString(nexmarkInfluxDBArgs),
- '--runner=DirectRunner',
- '--queryLanguage=zetasql',
- '--streaming=false',
- '--suite=SMOKE',
- '--manageResources=false',
- '--monitorJobs=true',
- '--enforceEncodability=true',
- '--enforceImmutability=true"'
- ].join(' '))
- }
- shell('echo "*** RUN NEXMARK IN ZETASQL STREAMING MODE USING DIRECT
RUNNER ***"')
- gradle {
- rootBuildScriptDir(commonJobProperties.checkoutDir)
- tasks(':sdks:java:testing:nexmark:run')
- commonJobProperties.setGradleSwitches(delegate)
- switches('-Pnexmark.runner=":runners:direct-java"' +
- ' -Pnexmark.args="' +
- [
- commonJobProperties.mapToArgString(nexmarkBigQueryArgs),
- commonJobProperties.mapToArgString(nexmarkInfluxDBArgs),
- '--runner=DirectRunner',
- '--queryLanguage=zetasql',
- '--streaming=true',
- '--suite=SMOKE',
- '--manageResources=false',
- '--monitorJobs=true',
Review Comment:
Set here:
https://github.com/apache/beam/blob/c2d4e5162afdc5ad9d32da7eca681581322e515f/.test-infra/jenkins/NexmarkBuilder.groovy#L34
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
