diff --git a/flink_sql_statements/create_airline_flights_table.fql b/flink_sql_statements/create_airline_flights_table.fql index 4b454a6..af496d3 100644 --- a/flink_sql_statements/create_airline_flights_table.fql +++ b/flink_sql_statements/create_airline_flights_table.fql @@ -1,7 +1,7 @@ CREATE TABLE airline_flights ( - email_address STRING, - departure_time STRING, departure_airport_code STRING, + email_address STRING, + departure_time STRING, arrival_time STRING, arrival_airport_code STRING, flight_number STRING,