Skip to content

Commit bf4daa8

Browse files
authored
Fix logging in run-flink-code template (#10)
1 parent a503fec commit bf4daa8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

python/run-flink-code.py.jinja2

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ FROM
130130
{TEMPORARY_INPUT_VIEW_NAME}
131131
;"""
132132

133-
logging.info(f"Creating temporary view {TEMPORARY_INPUT_VIEW_NAME}: \n{args.query}\n\n")
133+
logging.info(f"Creating temporary view {TEMPORARY_INPUT_VIEW_NAME}.\n")
134134
table_env.create_temporary_view(TEMPORARY_INPUT_VIEW_NAME, execution_output)
135135

136136
logging.info(f"Running generated insert query:\n{load_query}")

0 commit comments

Comments
 (0)