Skip to content

Instantly share code, notes, and snippets.

@codspire
Last active January 4, 2024 12:42
Show Gist options
  • Save codspire/0020b60d5e1cc1f40d312be11829687d to your computer and use it in GitHub Desktop.
Save codspire/0020b60d5e1cc1f40d312be11829687d to your computer and use it in GitHub Desktop.
Running Flink Locally on Windows 10
@nbhusare
Copy link

nbhusare commented Jul 1, 2021

Tx for sharing the above research.
As an alternative, you could specify "FLINK_CONF_DIR" as an environment variable, and just remove the file: protocol.

@ibrahim89
Copy link

I have done the same as mentioned but same error i am getting.

@GeorgeII
Copy link

Thank you! Works fine now!

@jullang
Copy link

jullang commented Nov 9, 2021

Thank you!!! That was really a pain in the a... thanks for sharing.

@eliucinho
Copy link

Thank you! you rock! |m|

@aamitjain
Copy link

Thank You!

@lingandlan
Copy link

linux || mac ,
vim .zshrc
export FLINK_CONF_DIR= condir #eg: /opt/homebrew/Cellar/apache-flink/1.15.0/libexec/conf

@SunnyBoy-WYH
Copy link

SunnyBoy-WYH commented Mar 4, 2023

it is helpful, but when i run flink sql task,cause err,about error:

(8f576766d577ce098b159b95e339034c) switched from INITIALIZING to FAILED with failure cause: java.lang.RuntimeException: Failed to create stage bundle factory! CRITICAL:root:No logging endpoint provided.

at org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.createStageBundleFactory(BeamPythonFunctionRunner.java:429)
at org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.open(BeamPythonFunctionRunner.java:273)
at org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator.open(AbstractPythonFunctionOperator.java:121)
at org.apache.flink.table.runtime.operators.python.AbstractStatelessFunctionOperator.open(AbstractStatelessFunctionOperator.java:116)
at org.apache.flink.table.runtime.operators.python.scalar.AbstractPythonScalarFunctionOperator.open(AbstractPythonScalarFunctionOperator.java:88)
at org.apache.flink.table.runtime.operators.python.scalar.AbstractRowDataPythonScalarFunctionOperator.open(AbstractRowDataPythonScalarFunctionOperator.java:70)
at org.apache.flink.table.runtime.operators.python.scalar.RowDataPythonScalarFunctionOperator.open(RowDataPythonScalarFunctionOperator.java:59)
at org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:442)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:582)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100)
at org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:562)
at org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:537)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
at java.lang.Thread.run(Thread.java:750)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment