Skip to content

Commit 0000994

Browse files
committed
replace SPARK-XXXXX with real JIRA ticket
1 parent 79ba311 commit 0000994

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -813,6 +813,7 @@ abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
813813
hasInitialState, planLater(initialState), planLater(child)
814814
) :: Nil
815815
case _: FlatMapGroupsInPandasWithState =>
816+
// TODO(SPARK-40443): support applyInPandasWithState in batch query
816817
throw new UnsupportedOperationException(
817818
"applyInPandasWithState is unsupported in batch query. Use applyInPandas instead.")
818819
case logical.CoGroup(f, key, lObj, rObj, lGroup, rGroup, lAttr, rAttr, oAttr, left, right) =>

sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapGroupsInPandasWithStateExec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ case class FlatMapGroupsInPandasWithStateExec(
6464
eventTimeWatermark: Option[Long],
6565
child: SparkPlan) extends UnaryExecNode with FlatMapGroupsWithStateExecBase {
6666

67-
// TODO(SPARK-XXXXX): Add the support of initial state.
67+
// TODO(SPARK-40444): Add the support of initial state.
6868
override protected val initialStateDeserializer: Expression = null
6969
override protected val initialStateGroupAttrs: Seq[Attribute] = null
7070
override protected val initialStateDataAttrs: Seq[Attribute] = null

0 commit comments

Comments
 (0)