| ::############################################################################### |
| :: Licensed to the Apache Software Foundation (ASF) under one |
| :: or more contributor license agreements. See the NOTICE file |
| :: distributed with this work for additional information |
| :: regarding copyright ownership. The ASF licenses this file |
| :: to you under the Apache License, Version 2.0 (the |
| :: "License"); you may not use this file except in compliance |
| :: with the License. You may obtain a copy of the License at |
| :: |
| :: http://www.apache.org/licenses/LICENSE-2.0 |
| :: |
| :: Unless required by applicable law or agreed to in writing, software |
| :: distributed under the License is distributed on an "AS IS" BASIS, |
| :: WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| :: See the License for the specific language governing permissions and |
| :: limitations under the License. |
| ::############################################################################### |
| |
| @echo off |
| setlocal EnableDelayedExpansion |
| |
| SET bin=%~dp0 |
| SET FLINK_ROOT_DIR=%bin%.. |
| SET FLINK_LIB_DIR=%FLINK_ROOT_DIR%\lib |
| SET FLINK_CONF_DIR=%FLINK_ROOT_DIR%\conf |
| SET FLINK_LOG_DIR=%FLINK_ROOT_DIR%\log |
| |
| SET JVM_ARGS=-Xms1024m -Xmx1024m |
| |
| SET FLINK_CLASSPATH=%FLINK_LIB_DIR%\* |
| |
| SET logname_jm=flink-%username%-jobmanager.log |
| SET logname_tm=flink-%username%-taskmanager.log |
| SET log_jm=%FLINK_LOG_DIR%\%logname_jm% |
| SET log_tm=%FLINK_LOG_DIR%\%logname_tm% |
| SET outname_jm=flink-%username%-jobmanager.out |
| SET outname_tm=flink-%username%-taskmanager.out |
| SET out_jm=%FLINK_LOG_DIR%\%outname_jm% |
| SET out_tm=%FLINK_LOG_DIR%\%outname_tm% |
| |
| SET log_setting_jm=-Dlog.file="%log_jm%" -Dlogback.configurationFile=file:"%FLINK_CONF_DIR%/logback.xml" -Dlog4j.configuration=file:"%FLINK_CONF_DIR%/log4j.properties" |
| SET log_setting_tm=-Dlog.file="%log_tm%" -Dlogback.configurationFile=file:"%FLINK_CONF_DIR%/logback.xml" -Dlog4j.configuration=file:"%FLINK_CONF_DIR%/log4j.properties" |
| |
| :: Log rotation (quick and dirty) |
| CD "%FLINK_LOG_DIR%" |
| for /l %%x in (5, -1, 1) do ( |
| SET /A y = %%x+1 |
| RENAME "%logname_jm%.%%x" "%logname_jm%.!y!" 2> nul |
| RENAME "%logname_tm%.%%x" "%logname_tm%.!y!" 2> nul |
| RENAME "%outname_jm%.%%x" "%outname_jm%.!y!" 2> nul |
| RENAME "%outname_tm%.%%x" "%outname_tm%.!y!" 2> nul |
| ) |
| RENAME "%logname_jm%" "%logname_jm%.0" 2> nul |
| RENAME "%logname_tm%" "%logname_tm%.0" 2> nul |
| RENAME "%outname_jm%" "%outname_jm%.0" 2> nul |
| RENAME "%outname_tm%" "%outname_tm%.0" 2> nul |
| DEL "%logname_jm%.6" 2> nul |
| DEL "%logname_tm%.6" 2> nul |
| DEL "%outname_jm%.6" 2> nul |
| DEL "%outname_tm%.6" 2> nul |
| |
| for %%X in (java.exe) do (set FOUND=%%~$PATH:X) |
| if not defined FOUND ( |
| echo java.exe was not found in PATH variable |
| goto :eof |
| ) |
| |
| echo Starting a local cluster with one JobManager process and one TaskManager process. |
| |
| echo You can terminate the processes via CTRL-C in the spawned shell windows. |
| |
| echo Web interface by default on http://localhost:8081/. |
| |
| start java %JVM_ARGS% %log_setting_jm% -cp "%FLINK_CLASSPATH%"; org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint --configDir "%FLINK_CONF_DIR%" > "%out_jm%" 2>&1 |
| start java %JVM_ARGS% %log_setting_tm% -cp "%FLINK_CLASSPATH%"; org.apache.flink.runtime.taskexecutor.TaskManagerRunner --configDir "%FLINK_CONF_DIR%" > "%out_tm%" 2>&1 |
| |
| endlocal |