From 64187d5e3635aa652333b9c6fcc6a3df0057b239 Mon Sep 17 00:00:00 2001 From: David Kornel Date: Thu, 7 Nov 2024 15:18:52 +0100 Subject: [PATCH] Small format fix for operator installer (#92) Signed-off-by: David Kornel --- src/test/java/io/streams/e2e/flink/sql/SqlExampleST.java | 7 +++++-- src/test/java/io/streams/e2e/flink/sql/SqlJobRunnerST.java | 7 +++++-- 2 files changed, 10 insertions(+), 4 deletions(-) diff --git a/src/test/java/io/streams/e2e/flink/sql/SqlExampleST.java b/src/test/java/io/streams/e2e/flink/sql/SqlExampleST.java index 105b3e5..3da70cf 100644 --- a/src/test/java/io/streams/e2e/flink/sql/SqlExampleST.java +++ b/src/test/java/io/streams/e2e/flink/sql/SqlExampleST.java @@ -67,8 +67,11 @@ public class SqlExampleST extends Abstract { @BeforeAll void prepareOperators() throws Exception { - OperatorInstaller.installRequiredOperators(EOperator.FLINK, EOperator.APICURIO, - EOperator.STRIMZI, EOperator.CERT_MANAGER); + OperatorInstaller.installRequiredOperators( + EOperator.FLINK, + EOperator.APICURIO, + EOperator.STRIMZI, + EOperator.CERT_MANAGER); } @TestDoc( diff --git a/src/test/java/io/streams/e2e/flink/sql/SqlJobRunnerST.java b/src/test/java/io/streams/e2e/flink/sql/SqlJobRunnerST.java index 2405fe2..3fd1ff1 100644 --- a/src/test/java/io/streams/e2e/flink/sql/SqlJobRunnerST.java +++ b/src/test/java/io/streams/e2e/flink/sql/SqlJobRunnerST.java @@ -76,8 +76,11 @@ public class SqlJobRunnerST extends Abstract { @BeforeAll void prepareOperators() throws Exception { - OperatorInstaller.installRequiredOperators(EOperator.FLINK, EOperator.APICURIO, - EOperator.STRIMZI, EOperator.CERT_MANAGER); + OperatorInstaller.installRequiredOperators( + EOperator.FLINK, + EOperator.APICURIO, + EOperator.STRIMZI, + EOperator.CERT_MANAGER); } @TestDoc(