IP属地：广东
由于项目的原因，需要将Flink运行在GCP上，因此File System自然是想使用GCS. 在网上搜了很多，由于众所周知的原因，国内使用Go...
本文探讨Flink on YARN 单一作业提交模式下的并发以及Task Manager等特性。 Flink on YARN支持两种模式，一种是...
在Flink example中，有两个Wordcount的example特别类似，一个是batch下的WordCount一个是streaming...
Flink的Checkpoint机制是Flink容错能力的基本保证，能够对流处理运行时的状态进行保存，当故障发生时，能够备份的状态中还原。例如，...
OKD 3.11 提供了mysql数据库的catalog，以下为使用okd311从web console拉起mysql的步骤。 创建storag...
本文参考openshift 3.11离线安装，遇到了一些环境相关的问题，所以梳理了以下，如果遇到类似问题，可以参考。 环境准备 硬件环境公司内部...
在使用TensorFlow进行建模、训练和预测时，可以使用estimator这样的高阶函数方便使用。基本的套路是： 训练 fit 初始化clas...
在python中使用Pandas和Numpy库创建一个Pandas DataFrame是一个常见的操作，但就是这一个常见的操作也会在特定的场景下...
笔者作为一名根正苗红的理工男，内心却常常有很多文艺青年才会有的想法，例如写首诗、做首词，甚至包括春节写副对联，空有一番愿望却胸无点墨。随着对机器...