[FLINK-17265] uniform time and timeUnit use

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.10.0
• Component/s: API / Scala
• Assignee: Unassigned
• Reporter: Jake.zhang
• Due: 20/Apr/20
• Created: 20/Apr/20 10:25
• Updated: 12/Apr/21 10:10

Description

// set restart strategy

env.setRestartStrategy(RestartStrategies.failureRateRestart(3,
 org.apache.flink.api.common.time.Time.of(5, TimeUnit.MINUTES), org.apache.flink.api.common.time.Time.of(10, TimeUnit.SECONDS)))

// set window time 

// import org.apache.flink.streaming.api.windowing.time.Time
.timeWindow(Time.minutes(1))

It is strongly recommanded to unify Time and TimeUnit