diff --git a/sdks/java/extensions/sql/jdbc/src/main/java/org/apache/beam/sdk/extensions/sql/jdbc/BeamSqlLine.java b/sdks/java/extensions/sql/jdbc/src/main/java/org/apache/beam/sdk/extensions/sql/jdbc/BeamSqlLine.java index 299d9daa774a..49b90187b537 100644 --- a/sdks/java/extensions/sql/jdbc/src/main/java/org/apache/beam/sdk/extensions/sql/jdbc/BeamSqlLine.java +++ b/sdks/java/extensions/sql/jdbc/src/main/java/org/apache/beam/sdk/extensions/sql/jdbc/BeamSqlLine.java @@ -68,7 +68,8 @@ static Status runSqlLine( @Nullable OutputStream errorStream) throws IOException { String[] modifiedArgs = checkConnectionArgs(args); - // JLine uses UnixTerminal on Linux and macOS. We swap in a subclass that lets us interrupt the terminal + // JLine uses UnixTerminal on Linux and macOS. We swap in a subclass that lets us interrupt the + // terminal TerminalFactory.registerFlavor(TerminalFactory.Flavor.UNIX, InterruptRestoringTerminal.class); SqlLine sqlLine = new SqlLine(); @@ -87,8 +88,8 @@ static Status runSqlLine( * Makes sure Ctrl+C can always stop a running query. * *
JLine turns off Ctrl+C while it reads a line, then turns it back on. Sometimes it forgets to - * hand it back, and Ctrl+C can't stop queries anymore. This class saves the Ctrl+C character and hands it back - * when needed. + * hand it back, and Ctrl+C can't stop queries anymore. This class saves the Ctrl+C character and + * hands it back when needed. */ public static class InterruptRestoringTerminal extends UnixTerminal { private @Nullable String intr;