This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 26f5792c8cc Distribute trigger time for daily load tests (#26556)
26f5792c8cc is described below
commit 26f5792c8cc7f0e2a04a3b94c57a96feabf92156
Author: Yi Hu <ya...@google.com>
AuthorDate: Thu May 4 13:27:57 2023 -0400
Distribute trigger time for daily load tests (#26556)
* Also, set all Java IO Performance test freq to half a day
Python Performance test freq to daily as most tests
---
.test-infra/jenkins/job_CloudMLBenchmarkTests_Python.groovy | 2 +-
.test-infra/jenkins/job_InferenceBenchmarkTests_Python.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java11.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_CoGBK_Java.groovy | 4 ++--
.../job_LoadTests_CoGBK_Java_spark_structured_streaming.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_Combine_Flink_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_Combine_Flink_Python.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_Combine_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_Combine_Java.groovy | 4 ++--
.../job_LoadTests_Combine_Java_spark_structured_streaming.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_Combine_Python.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java11.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java17.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_GBK_Flink_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_GBK_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_GBK_Java.groovy | 4 ++--
.../jenkins/job_LoadTests_GBK_Java_spark_structured_streaming.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_GBK_Python.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_GBK_Python_reiterate.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java11.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java17.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_ParDo_Flink_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_ParDo_Flink_Python.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_ParDo_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_ParDo_Java.groovy | 4 ++--
.../job_LoadTests_ParDo_Java_spark_structured_streaming.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_ParDo_Python.groovy | 4 ++--
.test-infra/jenkins/job_LoadTests_SideInput_Flink_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_SideInput_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_SideInput_Python.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_coGBK_Flink_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_coGBK_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_coGBK_Python.groovy | 4 ++--
.test-infra/jenkins/job_PerformanceTests_BigQueryIO_Java.groovy | 2 +-
.test-infra/jenkins/job_PerformanceTests_Python.groovy | 2 +-
.../job_PostCommit_Python_Chicago_Taxi_Example_Dataflow.groovy | 2 +-
.../jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy | 2 +-
38 files changed, 55 insertions(+), 55 deletions(-)
diff --git a/.test-infra/jenkins/job_CloudMLBenchmarkTests_Python.groovy
b/.test-infra/jenkins/job_CloudMLBenchmarkTests_Python.groovy
index 95dab94cb24..1867cccf775 100644
--- a/.test-infra/jenkins/job_CloudMLBenchmarkTests_Python.groovy
+++ b/.test-infra/jenkins/job_CloudMLBenchmarkTests_Python.groovy
@@ -60,7 +60,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
CronJobBuilder.cronJob(
'beam_CloudML_Benchmarks_Dataflow',
- 'H 14 * * *',
+ 'H H * * *',
this
) {
cloudMLJob(delegate)
diff --git a/.test-infra/jenkins/job_InferenceBenchmarkTests_Python.groovy
b/.test-infra/jenkins/job_InferenceBenchmarkTests_Python.groovy
index 975c9c6a7f2..a98b8d17043 100644
--- a/.test-infra/jenkins/job_InferenceBenchmarkTests_Python.groovy
+++ b/.test-infra/jenkins/job_InferenceBenchmarkTests_Python.groovy
@@ -199,7 +199,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
}
CronJobBuilder.cronJob(
- 'beam_Inference_Python_Benchmarks_Dataflow', 'H 15 * * *',
+ 'beam_Inference_Python_Benchmarks_Dataflow', 'H H * * *',
this
) {
loadTestJob(delegate)
diff --git a/.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java11.groovy
b/.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java11.groovy
index bd4b97c07e5..fc7f39d28a0 100644
--- a/.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java11.groovy
+++ b/.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java11.groovy
@@ -203,7 +203,7 @@ def streamingLoadTestJob = { scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java11',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java11',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -227,7 +227,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
"CoGBK", "batch", JOB_SPECIFIC_SWITCHES)
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_V2_Batch_Java11',
'H 14 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_V2_Batch_Java11',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy
b/.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy
index 0978753f40e..ca8c6689ad0 100644
--- a/.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy
+++ b/.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy
@@ -203,7 +203,7 @@ def streamingLoadTestJob = { scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java17',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_V2_Streaming_Java17',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -227,7 +227,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
"CoGBK", "batch", JOB_SPECIFIC_SWITCHES)
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_V2_Batch_Java17',
'H 14 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_V2_Batch_Java17',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_CoGBK_Java.groovy
b/.test-infra/jenkins/job_LoadTests_CoGBK_Java.groovy
index e9189490a7f..373e11e5a7a 100644
--- a/.test-infra/jenkins/job_LoadTests_CoGBK_Java.groovy
+++ b/.test-infra/jenkins/job_LoadTests_CoGBK_Java.groovy
@@ -172,7 +172,7 @@ def streamingLoadTestJob = { scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_Streaming', 'H 12 *
* *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_Streaming', 'H H *
* *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -196,7 +196,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
loadTestsBuilder.loadTests(scope, CommonTestProperties.SDK.JAVA,
loadTestConfigurations('batch', false), "CoGBK", "batch")
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_Batch', 'H 14 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_Dataflow_Batch', 'H H * *
*', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git
a/.test-infra/jenkins/job_LoadTests_CoGBK_Java_spark_structured_streaming.groovy
b/.test-infra/jenkins/job_LoadTests_CoGBK_Java_spark_structured_streaming.groovy
index 1c984bd1025..1d02dd7c6d8 100644
---
a/.test-infra/jenkins/job_LoadTests_CoGBK_Java_spark_structured_streaming.groovy
+++
b/.test-infra/jenkins/job_LoadTests_CoGBK_Java_spark_structured_streaming.groovy
@@ -153,7 +153,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
loadTestsBuilder.loadTests(scope, CommonTestProperties.SDK.JAVA,
loadTestConfigurations('batch', false), "CoGBK", "batch")
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_SparkStructuredStreaming_Batch',
'H 14 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_CoGBK_SparkStructuredStreaming_Batch',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_Combine_Flink_Go.groovy
b/.test-infra/jenkins/job_LoadTests_Combine_Flink_Go.groovy
index db573808c64..e161ba0c0de 100644
--- a/.test-infra/jenkins/job_LoadTests_Combine_Flink_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_Combine_Flink_Go.groovy
@@ -129,7 +129,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_Combine_Flink_Batch', 'H 8 * * *',
this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_Combine_Flink_Batch', 'H H * * *',
this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_Combine_Flink_Python.groovy
b/.test-infra/jenkins/job_LoadTests_Combine_Flink_Python.groovy
index 8f6ff06410f..996f05a05af 100644
--- a/.test-infra/jenkins/job_LoadTests_Combine_Flink_Python.groovy
+++ b/.test-infra/jenkins/job_LoadTests_Combine_Flink_Python.groovy
@@ -154,7 +154,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_Combine_Flink_Batch', 'H 15 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_Combine_Flink_Batch', 'H H * *
*', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -172,7 +172,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR,
'streaming')
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_Combine_Flink_Streaming', 'H 18
* * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_Combine_Flink_Streaming', 'H H *
* *', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_Combine_Go.groovy
b/.test-infra/jenkins/job_LoadTests_Combine_Go.groovy
index b88ee3476d6..0d6b7b8bb5b 100644
--- a/.test-infra/jenkins/job_LoadTests_Combine_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_Combine_Go.groovy
@@ -118,7 +118,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_Combine_Dataflow_Batch', 'H 8 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_Combine_Dataflow_Batch', 'H H * *
*', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_Combine_Java.groovy
b/.test-infra/jenkins/job_LoadTests_Combine_Java.groovy
index dc0c9c47431..a4254ca2194 100644
--- a/.test-infra/jenkins/job_LoadTests_Combine_Java.groovy
+++ b/.test-infra/jenkins/job_LoadTests_Combine_Java.groovy
@@ -125,7 +125,7 @@ def streamingLoadTestJob = {scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_Combine_Dataflow_Batch', 'H 12 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_Combine_Dataflow_Batch', 'H H * *
*', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -133,7 +133,7 @@
CronJobBuilder.cronJob('beam_LoadTests_Java_Combine_Dataflow_Batch', 'H 12 * * *
batchLoadTestJob(delegate,
CommonTestProperties.TriggeringContext.POST_COMMIT)
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_Combine_Dataflow_Streaming', 'H 12
* * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_Combine_Dataflow_Streaming', 'H H
* * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git
a/.test-infra/jenkins/job_LoadTests_Combine_Java_spark_structured_streaming.groovy
b/.test-infra/jenkins/job_LoadTests_Combine_Java_spark_structured_streaming.groovy
index 0be85984d6e..ff1dc2bf190 100644
---
a/.test-infra/jenkins/job_LoadTests_Combine_Java_spark_structured_streaming.groovy
+++
b/.test-infra/jenkins/job_LoadTests_Combine_Java_spark_structured_streaming.groovy
@@ -104,7 +104,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
loadTestsBuilder.loadTests(scope, CommonTestProperties.SDK.JAVA,
commonLoadTestConfig('batch', false), "Combine", "batch")
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_Combine_SparkStructuredStreaming_Batch',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_Combine_SparkStructuredStreaming_Batch',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_Combine_Python.groovy
b/.test-infra/jenkins/job_LoadTests_Combine_Python.groovy
index 99fd10e3bdd..4b6fe509ced 100644
--- a/.test-infra/jenkins/job_LoadTests_Combine_Python.groovy
+++ b/.test-infra/jenkins/job_LoadTests_Combine_Python.groovy
@@ -124,7 +124,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, "batch")
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_Combine_Dataflow_Batch', 'H 15 *
* *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_Combine_Dataflow_Batch', 'H H *
* *', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -142,7 +142,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR,
"streaming")
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_Combine_Dataflow_Streaming', 'H
15 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_Combine_Dataflow_Streaming', 'H
H * * *', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java11.groovy
b/.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java11.groovy
index 30c9dda3763..cc2d5d2e555 100644
--- a/.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java11.groovy
+++ b/.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java11.groovy
@@ -268,7 +268,7 @@ def streamingLoadTestJob = { scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_V2_Streaming_Java11',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_V2_Streaming_Java11',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -292,7 +292,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
"GBK", "batch", JOB_SPECIFIC_SWITCHES)
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_V2_Batch_Java11', 'H
14 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_V2_Batch_Java11', 'H
H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java17.groovy
b/.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java17.groovy
index ca897e7eec1..7405f9154b8 100644
--- a/.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java17.groovy
+++ b/.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java17.groovy
@@ -268,7 +268,7 @@ def streamingLoadTestJob = { scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_V2_Streaming_Java17',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_V2_Streaming_Java17',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -292,7 +292,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
"GBK", "batch", JOB_SPECIFIC_SWITCHES)
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_V2_Batch_Java17', 'H
14 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_V2_Batch_Java17', 'H
H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_GBK_Flink_Go.groovy
b/.test-infra/jenkins/job_LoadTests_GBK_Flink_Go.groovy
index 3a5e63b283a..59fbeb75bc2 100644
--- a/.test-infra/jenkins/job_LoadTests_GBK_Flink_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_GBK_Flink_Go.groovy
@@ -221,7 +221,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_GBK_Flink_Batch', 'H 10 * * *',
this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_GBK_Flink_Batch', 'H H * * *', this)
{
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_GBK_Go.groovy
b/.test-infra/jenkins/job_LoadTests_GBK_Go.groovy
index c158a3cb544..da31a692f61 100644
--- a/.test-infra/jenkins/job_LoadTests_GBK_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_GBK_Go.groovy
@@ -218,7 +218,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_GBK_Dataflow_Batch', 'H 10 * * *',
this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_GBK_Dataflow_Batch', 'H H * * *',
this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_GBK_Java.groovy
b/.test-infra/jenkins/job_LoadTests_GBK_Java.groovy
index d5d221026f5..6427b5b1235 100644
--- a/.test-infra/jenkins/job_LoadTests_GBK_Java.groovy
+++ b/.test-infra/jenkins/job_LoadTests_GBK_Java.groovy
@@ -219,7 +219,7 @@ def streamingLoadTestJob = { scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_Streaming', 'H 12 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_Streaming', 'H H * *
*', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -242,7 +242,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
loadTestsBuilder.loadTests(scope, CommonTestProperties.SDK.JAVA,
loadTestConfigurations('batch', false), "GBK", "batch")
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_Batch', 'H 14 * * *',
this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_Dataflow_Batch', 'H H * * *',
this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git
a/.test-infra/jenkins/job_LoadTests_GBK_Java_spark_structured_streaming.groovy
b/.test-infra/jenkins/job_LoadTests_GBK_Java_spark_structured_streaming.groovy
index b4524801741..8e5ec703f3b 100644
---
a/.test-infra/jenkins/job_LoadTests_GBK_Java_spark_structured_streaming.groovy
+++
b/.test-infra/jenkins/job_LoadTests_GBK_Java_spark_structured_streaming.groovy
@@ -191,7 +191,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
loadTestsBuilder.loadTests(scope, CommonTestProperties.SDK.JAVA,
loadTestConfigurations('batch', false), "GBK", "batch")
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_SparkStructuredStreaming_Batch',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_GBK_SparkStructuredStreaming_Batch',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_GBK_Python.groovy
b/.test-infra/jenkins/job_LoadTests_GBK_Python.groovy
index 1a772704ed7..5171256721e 100644
--- a/.test-infra/jenkins/job_LoadTests_GBK_Python.groovy
+++ b/.test-infra/jenkins/job_LoadTests_GBK_Python.groovy
@@ -176,7 +176,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_GBK_Dataflow_Batch', 'H 12 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_GBK_Dataflow_Batch', 'H H * *
*', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -194,7 +194,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR,
'streaming')
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_GBK_Dataflow_Streaming', 'H 12 *
* *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_GBK_Dataflow_Streaming', 'H H *
* *', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_GBK_Python_reiterate.groovy
b/.test-infra/jenkins/job_LoadTests_GBK_Python_reiterate.groovy
index d1960abce17..b762e1dad0b 100644
--- a/.test-infra/jenkins/job_LoadTests_GBK_Python_reiterate.groovy
+++ b/.test-infra/jenkins/job_LoadTests_GBK_Python_reiterate.groovy
@@ -97,7 +97,7 @@ def loadTestJob = { scope, triggeringContext, mode ->
}
CronJobBuilder.cronJob('beam_LoadTests_Python_GBK_reiterate_Dataflow_Batch',
- 'H 14 * * *', this) {
+ 'H H * * *', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -116,7 +116,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
}
CronJobBuilder.cronJob('beam_LoadTests_Python_GBK_reiterate_Dataflow_Streaming',
- 'H 14 * * *', this) {
+ 'H H * * *', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java11.groovy
b/.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java11.groovy
index 0a1cf8cfde5..a4535d52e6c 100644
--- a/.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java11.groovy
+++ b/.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java11.groovy
@@ -180,7 +180,7 @@ def streamingLoadTestJob = {scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Batch_Java11',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Batch_Java11',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -188,7 +188,7 @@
CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Batch_Java11', 'H
batchLoadTestJob(delegate,
CommonTestProperties.TriggeringContext.POST_COMMIT)
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Streaming_Java11',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Streaming_Java11',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java17.groovy
b/.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java17.groovy
index f09787225b9..f0f2179ebb3 100644
--- a/.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java17.groovy
+++ b/.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java17.groovy
@@ -180,7 +180,7 @@ def streamingLoadTestJob = {scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Batch_Java17',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Batch_Java17',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -188,7 +188,7 @@
CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Batch_Java17', 'H
batchLoadTestJob(delegate,
CommonTestProperties.TriggeringContext.POST_COMMIT)
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Streaming_Java17',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_V2_Streaming_Java17',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_ParDo_Flink_Go.groovy
b/.test-infra/jenkins/job_LoadTests_ParDo_Flink_Go.groovy
index 0eb7e2b2ce2..c5af6cc42d1 100644
--- a/.test-infra/jenkins/job_LoadTests_ParDo_Flink_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_ParDo_Flink_Go.groovy
@@ -142,7 +142,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_ParDo_Flink_Batch', 'H 10 * * *',
this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_ParDo_Flink_Batch', 'H H * * *',
this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_ParDo_Flink_Python.groovy
b/.test-infra/jenkins/job_LoadTests_ParDo_Flink_Python.groovy
index 96172d94b9b..aeeaae2c0ed 100644
--- a/.test-infra/jenkins/job_LoadTests_ParDo_Flink_Python.groovy
+++ b/.test-infra/jenkins/job_LoadTests_ParDo_Flink_Python.groovy
@@ -345,7 +345,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR,
'streaming')
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_ParDo_Flink_Batch', 'H 13 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_ParDo_Flink_Batch', 'H H * * *',
this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -354,7 +354,7 @@
CronJobBuilder.cronJob('beam_LoadTests_Python_ParDo_Flink_Batch', 'H 13 * * *',
loadTestJob(delegate, CommonTestProperties.TriggeringContext.POST_COMMIT,
'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_ParDo_Flink_Streaming', 'H 12 *
* *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_ParDo_Flink_Streaming', 'H H * *
*', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_ParDo_Go.groovy
b/.test-infra/jenkins/job_LoadTests_ParDo_Go.groovy
index 61d68125572..a45a146ca93 100644
--- a/.test-infra/jenkins/job_LoadTests_ParDo_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_ParDo_Go.groovy
@@ -146,7 +146,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_ParDo_Dataflow_Batch', 'H 10 * * *',
this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_ParDo_Dataflow_Batch', 'H H * * *',
this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_ParDo_Java.groovy
b/.test-infra/jenkins/job_LoadTests_ParDo_Java.groovy
index 21c15199f0e..974ae6b4d4f 100644
--- a/.test-infra/jenkins/job_LoadTests_ParDo_Java.groovy
+++ b/.test-infra/jenkins/job_LoadTests_ParDo_Java.groovy
@@ -149,7 +149,7 @@ def streamingLoadTestJob = {scope, triggeringContext ->
}
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_Batch', 'H 12 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_Batch', 'H H * *
*', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -157,7 +157,7 @@
CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_Batch', 'H 12 * * *',
batchLoadTestJob(delegate,
CommonTestProperties.TriggeringContext.POST_COMMIT)
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_Streaming', 'H 12 *
* *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_Dataflow_Streaming', 'H H *
* *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git
a/.test-infra/jenkins/job_LoadTests_ParDo_Java_spark_structured_streaming.groovy
b/.test-infra/jenkins/job_LoadTests_ParDo_Java_spark_structured_streaming.groovy
index 6e3987f6dd2..99639636bf6 100644
---
a/.test-infra/jenkins/job_LoadTests_ParDo_Java_spark_structured_streaming.groovy
+++
b/.test-infra/jenkins/job_LoadTests_ParDo_Java_spark_structured_streaming.groovy
@@ -127,7 +127,7 @@ def batchLoadTestJob = { scope, triggeringContext ->
}
-CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_SparkStructuredStreaming_Batch',
'H 12 * * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Java_ParDo_SparkStructuredStreaming_Batch',
'H H * * *', this) {
additionalPipelineArgs = [
influxDatabase: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influxHost: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_ParDo_Python.groovy
b/.test-infra/jenkins/job_LoadTests_ParDo_Python.groovy
index 82e7381ecf9..45ffb92a949 100644
--- a/.test-infra/jenkins/job_LoadTests_ParDo_Python.groovy
+++ b/.test-infra/jenkins/job_LoadTests_ParDo_Python.groovy
@@ -155,7 +155,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, "batch")
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_ParDo_Dataflow_Batch', 'H 13 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_ParDo_Dataflow_Batch', 'H H * *
*', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -173,7 +173,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR,
"streaming")
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_ParDo_Dataflow_Streaming', 'H 13
* * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_ParDo_Dataflow_Streaming', 'H H
* * *', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_SideInput_Flink_Go.groovy
b/.test-infra/jenkins/job_LoadTests_SideInput_Flink_Go.groovy
index b619d2eb6bd..f2c008b4f25 100644
--- a/.test-infra/jenkins/job_LoadTests_SideInput_Flink_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_SideInput_Flink_Go.groovy
@@ -95,7 +95,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_SideInput_Flink_Batch', 'H 11 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_SideInput_Flink_Batch', 'H H * * *',
this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_SideInput_Go.groovy
b/.test-infra/jenkins/job_LoadTests_SideInput_Go.groovy
index 5645c7dbc6b..35484d4cc3e 100644
--- a/.test-infra/jenkins/job_LoadTests_SideInput_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_SideInput_Go.groovy
@@ -91,7 +91,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_SideInput_Dataflow_Batch', 'H 11 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_SideInput_Dataflow_Batch', 'H H * *
*', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_SideInput_Python.groovy
b/.test-infra/jenkins/job_LoadTests_SideInput_Python.groovy
index 5ed7cc6381d..dcc687f4590 100644
--- a/.test-infra/jenkins/job_LoadTests_SideInput_Python.groovy
+++ b/.test-infra/jenkins/job_LoadTests_SideInput_Python.groovy
@@ -179,7 +179,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_SideInput_Dataflow_Batch', 'H 11
* * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_SideInput_Dataflow_Batch', 'H H
* * *', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_coGBK_Flink_Go.groovy
b/.test-infra/jenkins/job_LoadTests_coGBK_Flink_Go.groovy
index 4cb77e43368..95468a9d2f2 100644
--- a/.test-infra/jenkins/job_LoadTests_coGBK_Flink_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_coGBK_Flink_Go.groovy
@@ -174,7 +174,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_CoGBK_Flink_batch', 'H 8 * * *',
this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_CoGBK_Flink_batch', 'H H * * *',
this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_coGBK_Go.groovy
b/.test-infra/jenkins/job_LoadTests_coGBK_Go.groovy
index 009e374b154..cab73e55968 100644
--- a/.test-infra/jenkins/job_LoadTests_coGBK_Go.groovy
+++ b/.test-infra/jenkins/job_LoadTests_coGBK_Go.groovy
@@ -170,7 +170,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Go_CoGBK_Dataflow_batch', 'H 8 * * *',
this) {
+CronJobBuilder.cronJob('beam_LoadTests_Go_CoGBK_Dataflow_batch', 'H H * * *',
this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_LoadTests_coGBK_Python.groovy
b/.test-infra/jenkins/job_LoadTests_coGBK_Python.groovy
index b238f9d834a..42a97bf380c 100644
--- a/.test-infra/jenkins/job_LoadTests_coGBK_Python.groovy
+++ b/.test-infra/jenkins/job_LoadTests_coGBK_Python.groovy
@@ -165,7 +165,7 @@ def loadTestJob = { scope, triggeringContext, mode ->
loadTestConfigurations(mode, datasetName), 'CoGBK', mode)
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_CoGBK_Dataflow_Batch', 'H 16 * *
*', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_CoGBK_Dataflow_Batch', 'H H * *
*', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
@@ -183,7 +183,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
loadTestJob(delegate, CommonTestProperties.TriggeringContext.PR, 'batch')
}
-CronJobBuilder.cronJob('beam_LoadTests_Python_CoGBK_Dataflow_Streaming', 'H 16
* * *', this) {
+CronJobBuilder.cronJob('beam_LoadTests_Python_CoGBK_Dataflow_Streaming', 'H H
* * *', this) {
additionalPipelineArgs = [
influx_db_name: InfluxDBCredentialsHelper.InfluxDBDatabaseName,
influx_hostname: InfluxDBCredentialsHelper.InfluxDBHostUrl,
diff --git a/.test-infra/jenkins/job_PerformanceTests_BigQueryIO_Java.groovy
b/.test-infra/jenkins/job_PerformanceTests_BigQueryIO_Java.groovy
index c3d0ae1f78c..270aea0b733 100644
--- a/.test-infra/jenkins/job_PerformanceTests_BigQueryIO_Java.groovy
+++ b/.test-infra/jenkins/job_PerformanceTests_BigQueryIO_Java.groovy
@@ -120,7 +120,7 @@ private void createPostCommitJob(jobConfig) {
description(jobConfig.description)
common.setTopLevelMainJobProperties(delegate)
common.enablePhraseTriggeringFromPullRequest(delegate, jobConfig.title,
jobConfig.triggerPhrase)
- common.setAutoJob(delegate, 'H H/6 * * *')
+ common.setAutoJob(delegate, 'H H/12 * * *')
publishers {
archiveJunit('**/build/test-results/**/*.xml')
}
diff --git a/.test-infra/jenkins/job_PerformanceTests_Python.groovy
b/.test-infra/jenkins/job_PerformanceTests_Python.groovy
index 282f2db4c28..a2544a098cd 100644
--- a/.test-infra/jenkins/job_PerformanceTests_Python.groovy
+++ b/.test-infra/jenkins/job_PerformanceTests_Python.groovy
@@ -70,7 +70,7 @@ private void createPythonPerformanceTestJob(Map testConfig) {
InfluxDBCredentialsHelper.useCredentials(delegate)
// Run job in postcommit, don't trigger every push.
- commonJobProperties.setAutoJob(delegate, 'H H/6 * * *')
+ commonJobProperties.setAutoJob(delegate, 'H H * * *')
// Allows triggering this build against pull requests.
commonJobProperties.enablePhraseTriggeringFromPullRequest(
diff --git
a/.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Dataflow.groovy
b/.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Dataflow.groovy
index 0fe9504e8a6..bd04d3e0c3a 100644
---
a/.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Dataflow.groovy
+++
b/.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Dataflow.groovy
@@ -58,7 +58,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
//
// CronJobBuilder.cronJob(
// 'beam_PostCommit_Python_Chicago_Taxi_Dataflow',
-// 'H 14 * * *',
+// 'H H * * *',
// this
// ) {
// chicagoTaxiJob(delegate)
diff --git
a/.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
b/.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
index 724bc45eb3f..c1b4a4496f2 100644
---
a/.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
+++
b/.test-infra/jenkins/job_PostCommit_Python_Chicago_Taxi_Example_Flink.groovy
@@ -72,7 +72,7 @@ PhraseTriggeringPostCommitBuilder.postCommitJob(
//
// CronJobBuilder.cronJob(
// 'beam_PostCommit_Python_Chicago_Taxi_Flink',
-// 'H 14 * * *',
+// 'H H * * *',
// this
// ) {
// chicagoTaxiJob(delegate)
