I worked out the rowtype input for the conversion to datastream; type_info = Types.ROW_NAMED(['sender', 'stw', 'time'],[Types.STRING(), Types.DOUBLE(), Types.LONG()]) datastream=table_env.to_append_stream(my_table, type_info)
But if i try to assign rowtime and watermarks to the datastream and convert it back to a table, the rowtime/watermarks either get dropped or maybe they are not created properly. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
