blob: ef73a261b0c489ecbcb97d6a6cccfd4dcc1d7a30 [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import common_job_properties
// This job runs the Beam performance tests on PerfKit Benchmarker.
job('beam_PerformanceTests_JDBC'){
// Set default Beam job properties.
common_job_properties.setTopLevelMainJobProperties(delegate)
// Run job in postcommit every 6 hours, don't trigger every push, and
// don't email individual committers.
common_job_properties.setPostCommit(
delegate,
'0 */6 * * *',
false,
'commits@beam.apache.org',
false)
def pipelineArgs = [
tempRoot: 'gs://temp-storage-for-end-to-end-tests',
project: 'apache-beam-testing',
postgresServerName: '10.36.0.11',
postgresUsername: 'postgres',
postgresDatabaseName: 'postgres',
postgresPassword: 'uuinkks',
postgresSsl: 'false'
]
def pipelineArgList = []
pipelineArgs.each({
key, value -> pipelineArgList.add("--$key=$value")
})
def pipelineArgsJoined = pipelineArgList.join(',')
def argMap = [
benchmarks: 'beam_integration_benchmark',
beam_it_module: 'sdks/java/io/jdbc',
beam_it_args: pipelineArgsJoined,
beam_it_class: 'org.apache.beam.sdk.io.jdbc.JdbcIOIT',
// Profile is located in $BEAM_ROOT/sdks/java/io/pom.xml.
beam_it_profile: 'io-it'
]
common_job_properties.buildPerformanceTest(delegate, argMap)
// [BEAM-2141] Perf tests do not pass.
disabled()
}