240 发简信
IP属地:河南
  • 120
    基于Flink+ClickHouse打造轻量级点击流实时数仓

    前言 今天事情又比较多,写得言简意赅一些,看官勿怪。 Flink和ClickHouse分别是实时计算和(近实时)OLAP领域的翘楚,也是近些年非常火爆的开源框架,很多大厂都在...

  • K8S多种时区问题解决方案

    POD与NODE不一致 这种情况有三种方案: 在dockerFile中配置: 通过PodPreset配置(需要先启用PodPreset): 通过deployment设置: C...

  • asyncio源码分析之基本执行流程

    原生协程是基于async关键字的 可以看到cor的类型<class 'function'>函数类型,说明async关键字修饰的函数也是一个函数而已,跟普通函数在定义上没啥什么...

  • 解决了,我的 6.3.0 版本,es-data-stateful.yaml 中是 mountPath: /data

    使用阿里云kubernetes部署ElasticSearch生产级别集群

    市面上kubernetes没有提供比较好的ElasticSearch集群配置。 这里基于 pires尝试写了一个。1 使用elastic.io官方的镜像,默认包含x-pac...

  • `kubectl create -f stateful/es-data-svc.yaml`

    出错了,提示文件夹权限不对,楼主有遇到吗
    ```
    Caused by: java.nio.file.AccessDeniedException: /usr/share/elasticsearch/data/nodes
    at sun.nio.fs.UnixException.translateToIOException(UnixException.java:90) ~[?:?]
    at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:111) ~[?:?]
    at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:116) ~[?:?]
    at sun.nio.fs.UnixFileSystemProvider.createDirectory(UnixFileSystemProvider.java:385) ~[?:?]
    at java.nio.file.Files.createDirectory(Files.java:682) ~[?:?]
    at java.nio.file.Files.createAndCheckIsDirectory(Files.java:789) ~[?:?]
    at java.nio.file.Files.createDirectories(Files.java:775) ~[?:?]
    at org.elasticsearch.env.NodeEnvironment.<init>(NodeEnvironment.java:203) ~[elasticsearch-6.3.0.jar:6.3.0]
    at org.elasticsearch.node.Node.<init>(Node.java:270) ~[elasticsearch-6.3.0.jar:6.3.0]
    at org.elasticsearch.node.Node.<init>(Node.java:252) ~[elasticsearch-6.3.0.jar:6.3.0]
    at org.elasticsearch.bootstrap.Bootstrap$5.<init>(Bootstrap.java:213) ~[elasticsearch-6.3.0.jar:6.3.0]
    at org.elasticsearch.bootstrap.Bootstrap.setup(Bootstrap.java:213) ~[elasticsearch-6.3.0.jar:6.3.0]
    at org.elasticsearch.bootstrap.Bootstrap.init(Bootstrap.java:326) ~[elasticsearch-6.3.0.jar:6.3.0]
    at org.elasticsearch.bootstrap.Elasticsearch.init(Elasticsearch.java:136) ~[elasticsearch-6.3.0.jar:6.3.0]
    ... 6 more
    ```

    使用阿里云kubernetes部署ElasticSearch生产级别集群

    市面上kubernetes没有提供比较好的ElasticSearch集群配置。 这里基于 pires尝试写了一个。1 使用elastic.io官方的镜像,默认包含x-pac...

  • elasticsearch-spark更新文档

    先看源码: 其中:es.input.json控制你输入的是否是json格式的,这里的lines用的是Map所以注释掉。另外一处注释是注释掉的脚本,此脚本在es客户端是可以运行...

  • 120
    Storm 性能优化

    目录 场景假设 调优步骤和方法 Storm 的部分特性 Storm 并行度 Storm 消息机制 Storm UI 解析 性能优化 场景假设 在介绍 Storm 的性能调优方...