From ec99a93029d9953210cfdf73a496863add46ff9b Mon Sep 17 00:00:00 2001 From: Deepyaman Datta Date: Fri, 21 Jul 2023 13:30:07 -0500 Subject: [PATCH] Properly alias the created `SUM(payAmount)` column --- pyflink-walkthrough/payment_msg_proccessing.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pyflink-walkthrough/payment_msg_proccessing.py b/pyflink-walkthrough/payment_msg_proccessing.py index bc2a1c7..f486f1a 100644 --- a/pyflink-walkthrough/payment_msg_proccessing.py +++ b/pyflink-walkthrough/payment_msg_proccessing.py @@ -76,7 +76,7 @@ def log_processing(): t_env.from_path("payment_msg") \ .select(call('province_id_to_name', col('provinceId')).alias("province"), col('payAmount')) \ .group_by(col('province')) \ - .select(col('province'), call('sum', col('payAmount').alias("pay_amount"))) \ + .select(col('province'), call('sum', col('payAmount')).alias("pay_amount")) \ .execute_insert("es_sink")