问题

你有表访问控制(AWS|Azure|GCP)上启用您的集群。

你试图运行一个结构化流查询和获取和错误消息。

py4j.security。公共org.apache.spark.sql.streaming Py4JSecurityException:方法。DataStreamReader org.apache.spark.sql.SQLContext.readStream()类类org.apache.spark.sql.SQLContext不是白名单

导致

不支持流媒体集群,桌子上启用访问控制。

允许你设置访问控制权限数据对象在一个集群中。它需要用户交互验证和更新凭证。

因为流连续运行查询,它不支持集群表访问控制。

解决方案

您应该使用一个集群没有表启用访问控制流查询。