• geek2020
    2020-09-25
    老师，如果代码中没有使用env.setStreamTimeCharacteristic设置时间，那datastream还会有时间的概念么？比如是否会有个默认的时间类型

    作者回复: 默认ProcessingTime

    
    1
  • 小虞君
    2020-10-20
    由于业务需要，我在flink算子中使用了wait方法，但是flink抛出了异常，原因是null不能传递给下一个算子。网上找了好久没找到答案，请问老师如何在flink算子中实现线程等待呢，感谢。

    作者回复: 不太理解你说的null什么情况，以及你这种操作的意义，可以具体一点吗？基于StreamTask线程模型要通过控制信息才能控制线程的，可以往这个方面想想

    共 2 条评论
    
  • Geek_dc018e
    2022-05-31
    是内容太多了，老师讲的时候许多内容一语带过。。。。对0基础同学不大友好
    
    1
  • 伶傅
    2022-06-23
    FlinkKafkaProducer.Semantic.EXACTLY_ONCE 这个在Flink-connection-kafka-0.11中没有啊？这是怎么回事？
    
    
  • Geek_5c44aa
    2021-03-13
    老师，如果kafka服务器上的时间与我们本地系统的时间存在几小时的时间差的话，使用EventTime的话会不会有数据进不了timeWindow的情况？
    
    
  • 马来酸
    2021-02-23
    老师请问可以通过assignTimestamps()将数据的eventTime设置为未来的时间吗? 我使用.flatMap()生成预测数据, 然后.assignTime（）指定eventTime是预测出的时间, .flatMap() // 对于每条轨迹, 预测输出其后续10s的轨迹, 比如0秒来了一条轨迹数据, 预测输出1~10秒的轨迹 .assignTime() // 将后续10s轨迹的eventTime设置为刚才预测计算的时间 .window(1s) // 比较后续 第11秒时, 12秒....20秒时时的轨迹点是否有距离过近的 但遇到了WARN AscendingTimestampExtractor [] - Timestamp monotony violated, 1614009701000 < 1614009730000 请问可以这样写吗, 不行的话要这个逻辑怎么实现好呢，网上找了好久也没有答案。感谢老师！
    
    