[NSE-770] [NSE-774] Fix runtime issues on spark 3.2 #773
Conversation
PHILO-HE
changed the title
|
Thanks for opening a pull request! Could you open an issue for this pull request on Github Issues? https://github.com/oap-project/native-sql-engine/issues Then could you also rename commit message and pull request title in the following format? See also: |
| (that canEqual this) && super.equals(that) | ||
| case _ => false | ||
| } | ||
|
|
||
| // For spark3.2. | ||
| override protected def withNewChildInternal(newChild: SparkPlan): ColumnarBroadcastExchangeAdaptor = |
There was a problem hiding this comment.
looks like no need to override here
There was a problem hiding this comment.
Yes, should remove it for spark 3.1 compatibility. Just fixed in a new commit.
PHILO-HE
changed the title
|
The above commits have been cherry-picked into gazelle 1.3.1 branch. |
| @@ -375,6 +375,12 @@ case class ColumnarPostOverrides() extends Rule[SparkPlan] { | |||
| var isSupportAdaptive: Boolean = true | |||
|
|
|||
| def replaceWithColumnarPlan(plan: SparkPlan): SparkPlan = plan match { | |||
| case RowToColumnarExec(child: BroadcastQueryStageExec) => | |||
There was a problem hiding this comment.
can you also make a note here?
| case RowToColumnarExec(child: BroadcastQueryStageExec) => | ||
| logDebug(s"$child Due to a fallback of BHJ inserted into plan." + | ||
| s" See above override in BroadcastQueryStageExec") | ||
| val localBroadcastXchg = child.plan.asInstanceOf[BroadcastExchangeExec] |
There was a problem hiding this comment.
may need to guard this logic, like check if child.isInstanceOf[xxx] first
There was a problem hiding this comment.
Fixed in new commit. Thanks!
PHILO-HE
force-pushed
the
spark3.2-issues
branch
from
e89fd4e
to
773414e
Compare
|
Note: Spark 321 is ok to run on AQE + DPP with this patch |
Signed-off-by: Yuan Zhou <yuan.zhou@intel.com>
PHILO-HE
force-pushed
the
spark3.2-issues
branch
from
773414e
to
50594bc
Compare
|
Just rebased the code. |
PHILO-HE
changed the title
This PR includes some fixes for runtime issues on spark 3.2. Thanks Yuan's help in fixing the issues when AQE is turned on.