[
https://issues.apache.org/jira/browse/TRAFODION-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16494565#comment-16494565
]
ASF GitHub Bot commented on TRAFODION-2901:
-------------------------------------------
Github user Guhaiyan commented on a diff in the pull request:
https://github.com/apache/trafodion/pull/1581#discussion_r191620727
--- Diff: core/sql/optimizer/RelExpr.cpp ---
@@ -13341,6 +13345,33 @@ void GenericUpdate::pushdownCoveredExpr(const
ValueIdSet &outputExpr,
newExternalInputs,
predicatesOnParent,
&localExprs);
+
+ if (avoidHalloween() && child(0) && child(0)->getGroupAttr())
+ {
+ ValueIdSet cur_output =
child(0)->getGroupAttr()->getCharacteristicOutputs();
+ if (cur_output.isEmpty())
+ {
+ ValueId exprId;
+ ValueId atLeastOne;
+
+ for (exprId = original_output.init();
+ original_output.next(exprId);
+ original_output.advance(exprId))
+ {
+ atLeastOne = exprId;
+ if
(!(exprId.getItemExpr()->doesExprEvaluateToConstant(FALSE, TRUE)))
+ {
+
child(0)->getGroupAttr()->addCharacteristicOutputs(exprId);
+ break;
+ }
+ }
+ cur_output = child(0)->getGroupAttr()->getCharacteristicOutputs();
+ if (cur_output.isEmpty())
--- End diff --
If cur_output is empty, it means that in RelExpr::pushdownCoveredExpr,
child(0).getPtr()->getGroupAttr()->computeCharacteristicIO set requiredOutputs_
to be empty, that is there is no output for Scan. So I go through the
original_output and pick a ValueId which does NOT EvaluateToConst and add it
to the characteristic output of Scan. Since the original_output is not empty,
so we can always find one ValueId to be added to Scan's output . After "for"
loop, atLeastOne is the last ValueId in the original_output, not its initial
value(0), so I do not think the "if" would cause adding an null ValueId in
Scan's output.
> using sequence to do upsert get wrong number of rows after several times
> ------------------------------------------------------------------------
>
> Key: TRAFODION-2901
> URL: https://issues.apache.org/jira/browse/TRAFODION-2901
> Project: Apache Trafodion
> Issue Type: Bug
> Reporter: liu ming
> Assignee: Gu Haiyan
> Priority: Major
>
> create table test_seq
> (id LARGEINT not null
> ) primary key(id)
> SALT USING 48 PARTITIONS
> ATTRIBUTES ALIGNED FORMAT
> HBASE_OPTIONS
> (
> DATA_BLOCK_ENCODING = 'FAST_DIFF',
> MEMSTORE_FLUSH_SIZE = '1073741824'
> );
> create sequence seq1;
> upsert into test_seq select seqnum(seq1, next) from dual;
> upsert into test_seq select seqnum(seq1, next) from test_seq;
> upsert into test_seq select seqnum(seq1, next) from test_seq;
> upsert into test_seq select seqnum(seq1, next) from test_seq;
> upsert into test_seq select seqnum(seq1, next) from test_seq;
> upsert into test_seq select seqnum(seq1, next) from test_seq;
> upsert into test_seq select seqnum(seq1, next) from test_seq;
> upsert into test_seq select seqnum(seq1, next) from test_seq;
> upsert into test_seq select seqnum(seq1, next) from test_seq;
> --- 130 row(s) inserted.
> Should be 128 rows
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
