如何解决Nifi 和 Spark 集成
我想在用 Scala 编写的 Nifi 自定义处理器中创建一个 Spark 会话，到目前为止我可以在 Scala 项目上创建我的 Spark 会话，但是当我在 nifi 自定义处理器的 OnTrigger 方法中添加这个 Spark 会话时， spark会话永远不会被创建，有什么办法可以实现吗？到目前为止，我已经导入了 spark-core 和 spark-sql 库 任何反馈表示赞赏
解决方法
无法使用流文件。期间。
您需要在 Spark Streaming 或 Spark Structured Streaming 之间使用 Kafka。顺便说一句，这里很好读：https://community.cloudera.com/t5/Community-Articles/Spark-Structured-Streaming-with-NiFi-and-Kafka-using-PySpark/ta-p/245068
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
