flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hb <343122...@163.com>
Subject Re:flink sql 处理时间 时区问题
Date Tue, 12 May 2020 05:02:44 GMT
有人能帮忙看下这个问题么



在 2020-05-01 16:26:35,"hb" <343122422@163.com> 写道:



``` 代码
  val env = StreamExecutionEnvironment.getExecutionEnvironment
  val settings: EnvironmentSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()
  val tEnv: StreamTableEnvironment = StreamTableEnvironment.create(env, settings)


  val t2 = env.fromElements("a", "b", "c")
  t2.toTable(tEnv, 'f1, 'proc.proctime).toAppendStream[Row].print()
```


  // 时区上海, 当前时间为 2020-05-01 15点
  // 结果显示 a,2020-05-01T09:11:05.633, 处理时间相差8小时, 请问如何让 proctime
结果显示不差8小时.




 
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message