--------------------------------------------------------------------------- AnalysisException Traceback (most recent call last) <ipython-input-4-56e6a7999ebb> in <module>() 1 expn_cd = spark.table("expn_cd") 2 ----> 3 results = expn_cd .groupBy("PAYEE_NAMF", "PAYEE_NAML") .agg({"amount": "sum"}) .selectExpr("concat(PAYEE_NAMF,PAYEE_NAML) as payee", "sum(amount) as total_amount") .orderBy("total_amount", ascending=False) 4 5 display(results) /databricks/spark/python/pyspark/sql/dataframe.py in selectExpr(self, *expr) 876 if len(expr) == 1 and isinstance(expr[0], list): 877 expr = expr[0] --> 878 jdf = self._jdf.selectExpr(self._jseq(expr)) 879 return DataFrame(jdf, self.sql_ctx) 880 /databricks/spark/python/lib/py4j-0.10.1-src.zip/py4j/java_gateway.py in __call__(self, *args) 931 answer = self.gateway_client.send_command(command) 932 return_value = get_return_value( --> 933 answer, self.gateway_client, self.target_id, self.name) 934 935 for temp_arg in temp_args: /databricks/spark/python/pyspark/sql/utils.py in deco(*a, **kw) 67 e.java_exception.getStackTrace())) 68 if s.startswith('org.apache.spark.sql.AnalysisException: '): ---> 69 raise AnalysisException(s.split(': ', 1)[1], stackTrace) 70 if s.startswith('org.apache.spark.sql.catalyst.analysis'): 71 raise AnalysisException(s.split(': ', 1)[1], stackTrace) AnalysisException: u"cannot resolve '`amount`' given input columns: [PAYEE_NAMF, PAYEE_NAML, sum(amount)]; line 1 pos 4"