flink1.12.2 Windows下安装配置

红太狼 2022-11-09 11:22 339阅读 0赞

# flink1.12.2 Windows下安装配置 #

好久没有写文章了，发现flink版本没有.bat文件

flink.bat

start-cluster.bat

::###############################################################################
    ::  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_HOME=%bin%..
    SET FLINK_LIB_DIR=%FLINK_HOME%\lib
    SET FLINK_PLUGINS_DIR=%FLINK_HOME%\plugins
    SET FLINK_CONF_DIR=%FLINK_HOME%\conf
    SET FLINK_LOG_DIR=%FLINK_HOME%\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

其他一概如旧

![20210314210253120.png][]

[20210314210253120.png]: /images/20221023/8d4a8073144e47ae98b5d79a279b0501.png