• danhanhan
    2020-10-31
    老师讲得很好，学习了

    作者回复: 谢谢

    
    1
  • 高志强
    2020-12-09
    老师您好，我想问一下这节课的项目实战源码在哪里，想看看学习一下，谢谢

    作者回复: Gitee上就可以下载到

    共 2 条评论
    
  • 南山古月
    2021-02-25
    看完这个实战有点疑惑，似乎完全不需要前两章讲到的flink部署，只需要将依赖的jar包下载下来就能完成flink的窗口计算了，与前面讲的提交作业到Client以及JobGraph的转换和提交是不是没有关系？
    共 2 条评论
    2
  • 碧雪天虹
    2021-01-12
    没有ElasticSearch环境, 相关Sink代码注释掉了. WebSocket提示找不到类, 引入 javax.websocket:javax.websocket-client-api:1.1 提示找不到实现, 上课20分钟配环境2小时.
    
    2
  • 牛年榴莲
    2023-08-28 来自北京
    这节课，貌似跟Flink的Server没有关系
    
    
  • 彭腾辉
    2022-07-08
    flink里面有做哪些数据处理，怎么做的好像没有讲到
    
    
  • 福
    2022-02-16
    不是说windowall要添加触发器的嘛，，，我怎么没有看到触发器，然后窗口自己就触发了
    
    
  • 学无止境
    2021-09-04
    请教一下老师和各位同学，因为process()方法没有设置为1个并行度，这样求出来的uv,pv是不是每个节点的本地值的呢？
    共 1 条评论
    
  • wenjun00
    2021-04-10
    Exception in thread "main" java.lang.RuntimeException: No data for required key 'index' at org.apache.flink.api.java.utils.AbstractParameterTool.getRequired(AbstractParameterTool.java:82) at com.geekbang.flink.project.PVAndUVExample.main(PVAndUVExample.java:99) 这个错误是什么啊，老师，我没看懂这块代码，还有我的es是带用户密码的，我添加一下这块代码： Header[] defaultHeaders = new Header[]{new BasicHeader("elastic", "elastic@admin")}; esSinkBuilder.setRestClientFactory( restClientBuilder -> { restClientBuilder.setDefaultHeaders(defaultHeaders); } );
    共 1 条评论
    
  • 小学生🍭
    2020-11-28
    真实工程会开发时，往往会和spring集成，利用spring的特性方便开发，老师可以讲一下如何集成spring吗
    
    