Skip to content

Commit 200724c

Browse files
authored
Fix a few log spams (#3220)
1 parent c0750bf commit 200724c

File tree

5 files changed

+13
-1
lines changed

5 files changed

+13
-1
lines changed

it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/AbstractPipelineLauncher.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -315,8 +315,12 @@ protected final LaunchInfo getJobInfo(LaunchConfig options, JobState state, Job
315315
/** Waits until the specified job is not in a pending state. */
316316
public JobState waitUntilActive(String project, String region, String jobId) throws IOException {
317317
JobState state = getJobStatus(project, region, jobId);
318+
boolean logOnce = false;
318319
while (PENDING_STATES.contains(state)) {
319-
LOG.info("Job still pending. Will check again in 15 seconds");
320+
if (!logOnce) {
321+
LOG.info("Job still pending. Will check again in 15 seconds");
322+
logOnce = true;
323+
}
320324
try {
321325
TimeUnit.SECONDS.sleep(15);
322326
} catch (InterruptedException e) {
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
org.slf4j.simpleLogger.log.org.apache.kafka.clients=ERROR
2+
org.slf4j.simpleLogger.log.org.apache.beam.it.testcontainers.TestContainerResourceManager=WARN
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
org.slf4j.simpleLogger.log.org.apache.kafka.clients=ERROR
2+
org.slf4j.simpleLogger.log.org.apache.beam.it.testcontainers.TestContainerResourceManager=WARN
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
org.slf4j.simpleLogger.log.org.apache.kafka.clients=ERROR
2+
org.slf4j.simpleLogger.log.org.apache.beam.it.testcontainers.TestContainerResourceManager=WARN
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
org.slf4j.simpleLogger.log.org.apache.kafka.clients=ERROR
2+
org.slf4j.simpleLogger.log.org.apache.beam.it.testcontainers.TestContainerResourceManager=WARN

0 commit comments

Comments
 (0)