[
https://issues.apache.org/jira/browse/FLINK-6489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371322#comment-16371322
]
ASF GitHub Bot commented on FLINK-6489:
---------------------------------------
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5528#discussion_r169622022
--- Diff: flink-dist/src/main/flink-bin/bin/start-cluster.bat ---
@@ -0,0 +1,77 @@
+::###############################################################################
+:: 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-%computername%.log
+SET logname_tm=flink-%username%-taskmanager-%computername%.log
+SET log_jm=%FLINK_LOG_DIR%\%logname_jm%
+SET log_tm=%FLINK_LOG_DIR%\%logname_tm%
+SET outname_jm=flink-%username%-jobmanager-%computername%.out
+SET outname_tm=flink-%username%-taskmanager-%computername%.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/.
--- End diff --
ok 👍
> Rework 'start-local.bat' to 'start-local-cluster.bat'
> -----------------------------------------------------
>
> Key: FLINK-6489
> URL: https://issues.apache.org/jira/browse/FLINK-6489
> Project: Flink
> Issue Type: Sub-task
> Components: Startup Shell Scripts
> Reporter: Stephan Ewen
> Assignee: Stephan Ewen
> Priority: Major
>
> To get rid of the JobManager local mode, we need to make sure that the
> {{start-local.bat}} script for windows also starts a separate JobManager and
> TaskManager process, rather than only the JobManager (and relying on that one
> to spawn a TaskManager)
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
