We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
想请教下, checkpoint: dir: /Users/xuanbo/temp/checkpoint 这个地址是根据什么来配置的, 还有就是Flink Local 是在本地环境安装 Flink么?
The text was updated successfully, but these errors were encountered:
目前Local模式,是将flink的依赖全部打包到这个项目中,直接java -jar启动就用了flink的环境。
checkpoint这个地址就是本地的一个路径,自己定即可。
暂时还没测试集群,如果是集群,checkpoint就是hdfs的路径了。
Sorry, something went wrong.
No branches or pull requests
想请教下,
checkpoint:
dir: /Users/xuanbo/temp/checkpoint
这个地址是根据什么来配置的,
还有就是Flink Local 是在本地环境安装 Flink么?
The text was updated successfully, but these errors were encountered: