From 842934ec2491890dac8f0df05c73fca9e1f5cb3d Mon Sep 17 00:00:00 2001 From: zentol Date: Fri, 19 Feb 2016 11:11:04 +0100 Subject: [PATCH] [FLINK-3416] [py] Support for spaces in flink path --- flink-dist/src/main/flink-bin/bin/pyflink2.bat | 2 +- flink-dist/src/main/flink-bin/bin/pyflink3.bat | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-dist/src/main/flink-bin/bin/pyflink2.bat b/flink-dist/src/main/flink-bin/bin/pyflink2.bat index 9d94a69086378..1122ed43bbc57 100644 --- a/flink-dist/src/main/flink-bin/bin/pyflink2.bat +++ b/flink-dist/src/main/flink-bin/bin/pyflink2.bat @@ -22,4 +22,4 @@ setlocal EnableDelayedExpansion SET bin=%~dp0 SET FLINK_ROOT_DIR=%bin%.. -%FLINK_ROOT_DIR%\bin\flink run -v %FLINK_ROOT_DIR%\lib\flink-python*.jar 2 %* \ No newline at end of file +"%FLINK_ROOT_DIR%\bin\flink" run -v "%FLINK_ROOT_DIR%"\lib\flink-python*.jar 2 %* \ No newline at end of file diff --git a/flink-dist/src/main/flink-bin/bin/pyflink3.bat b/flink-dist/src/main/flink-bin/bin/pyflink3.bat index 43c9384f7761f..0294e37da558c 100644 --- a/flink-dist/src/main/flink-bin/bin/pyflink3.bat +++ b/flink-dist/src/main/flink-bin/bin/pyflink3.bat @@ -22,4 +22,4 @@ setlocal EnableDelayedExpansion SET bin=%~dp0 SET FLINK_ROOT_DIR=%bin%.. -%FLINK_ROOT_DIR%\bin\flink run -v %FLINK_ROOT_DIR%\lib\flink-python*.jar 3 %* \ No newline at end of file +"%FLINK_ROOT_DIR%\bin\flink" run -v "%FLINK_ROOT_DIR%"\lib\flink-python*.jar 3 %* \ No newline at end of file