spark+kafka報錯java.lang.IllegalArgumentException: requirement failed: numRecords must not be negative

在執行kafka+spark程序時報錯以下內容 ERROR JobScheduler: Error generating jobs for time 1588074000000 ms java.lang.IllegalArgumentException: requirement failed: numRecords must not be negative at scala.Predef$.req
相關文章
相關標籤/搜索