Fix cherry-pick

be/src/exec/pipeline/analysis/analytic_sink_operator.cpp

@@ -104,6 +104,7 @@ Status AnalyticSinkOperator::push_chunk(RuntimeState* state, const vectorized::C
 
     _analytor->input_chunks().emplace_back(chunk);
 
+    RETURN_IF_ERROR((this->*_process_by_partition_if_necessary)());
     return _analytor->check_has_error();
 }
 

fe/fe-core/src/test/java/com/starrocks/sql/plan/LowCardinalityTest.java

@@ -269,6 +269,7 @@ public void testDecodeRewrite9Scan() throws Exception {
     public void testDecodeNodeRewrite10() throws Exception {
         String sql = "select upper(S_ADDRESS) as a, count(*) from supplier group by a";
         String plan = getFragmentPlan(sql);
+        System.out.println("plan = " + plan);
         Assert.assertTrue(plan.contains("  3:Decode\n" +
                 "  |  <dict id 12> : <string id 9>"));
         Assert.assertTrue(plan.contains("<function id 12> : DictExpr(11: S_ADDRESS,[upper(<place-holder>)])"));
@@ -910,12 +911,7 @@ public void testMultiMaxMin() throws Exception {
                 "min(upper(S_COMMENT)) from supplier_nullable " +
                 "group by upper(S_COMMENT)";
         plan = getFragmentPlan(sql);
-        Assert.assertTrue(plan.contains("  5:Decode\n" +
-                "  |  <dict id 17> : <string id 12>\n" +
-                "  |  <dict id 15> : <string id 9>\n" +
-                "  |  string functions:\n" +
-                "  |  <function id 17> : DictExpr(14: S_COMMENT,[upper(<place-holder>)])\n" +
-                "  |  <function id 15> : DictExpr(14: S_COMMENT,[upper(<place-holder>)])"));
+        Assert.assertFalse(plan.contains("Decode"));
 
         connectContext.getSessionVariable().setNewPlanerAggStage(0);