使用flink时,使用外部rocksdb和内部rocksdb有什么性能/可伸缩性优势吗。
内部岩石
streamexecutionenvironment env=streamexecutionenvironment.getexecutionenvironment();env.setStateBendback(新的fsStateBendback(“hdfs://namenode:40010/flink/checkpoints“);
或者完全可以配置外部rocksdb吗?
使用flink时,使用外部rocksdb和内部rocksdb有什么性能/可伸缩性优势吗。
内部岩石
streamexecutionenvironment env=streamexecutionenvironment.getexecutionenvironment();env.setStateBendback(新的fsStateBendback(“hdfs://namenode:40010/flink/checkpoints“);
或者完全可以配置外部rocksdb吗?
暂无答案!
目前还没有任何答案,快来回答吧!