I've probably overlooked something simple, but when converting a datastream to a table how does one convert a long to timestamp(3) that will not be your event or proc time.
I've tried tEnv.createTemporaryView( "myTable" ,myDatastream ,.... ,$("myLongTS").toTimestamp() ) which produces the exception, org.apache.flink.table.api.ValidationException: Field reference expression or alias on field expression expected. I've also tried, $("myLongTS").toTimestamp().as("myLongTS") $("myLongTS as myLongTS").toTimestamp() Haven't found Gooogling to be of much help on this one. -- Thank You, Aeden