[ https://issues.apache.org/jira/browse/SPARK-48442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hyukjin Kwon resolved SPARK-48442. ---------------------------------- Fix Version/s: 4.0.0 Resolution: Fixed Issue resolved by pull request 46779 [https://github.com/apache/spark/pull/46779] > Add parenthesis to awaitTermination call > ---------------------------------------- > > Key: SPARK-48442 > URL: https://issues.apache.org/jira/browse/SPARK-48442 > Project: Spark > Issue Type: Bug > Components: PySpark > Affects Versions: 3.4.3 > Reporter: Riya Verma > Assignee: Riya Verma > Priority: Trivial > Labels: correctness, pull-request-available, starter > Fix For: 4.0.0 > > > In {{test_stream_reader}} and {{test_stream_writer}} of > {*}test_python_streaming_datasource.py{*}, the call {{q.awaitTermination}} > does not invoke a function call as intended, but instead returns a python > function object. The fix is to change this to {{{}q.awaitTermination(){}}}. -- This message was sent by Atlassian Jira (v8.20.10#820010) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org