Thank you for your suggestion Ramandeep , but the code is not clear to me.
Could you please explain it? Particularly this part :
Flowable.zip[java.lang.Long, Row, Row](delSt, itF, new
BiFunction[java.lang.Long, Row, Row]() {
Also , is it possible to achieve this without third party
Do you mean you run the same code on yarn and standalone? Can you check if they
are running the same python versions?
From: Bryan Cutler
Sent: Thursday, January 10, 2019 5:29 PM
To: libinsong1...@gmail.com
Cc: zlist Spark
Subject: Re: spark2.4 arrow enabled