little improvement
Project: http://git-wip-us.apache.org/repos/asf/trafodion/repo Commit: http://git-wip-us.apache.org/repos/asf/trafodion/commit/5cd19f67 Tree: http://git-wip-us.apache.org/repos/asf/trafodion/tree/5cd19f67 Diff: http://git-wip-us.apache.org/repos/asf/trafodion/diff/5cd19f67 Branch: refs/heads/master Commit: 5cd19f67339ed8a3595266cc6ac921a476b7c647 Parents: 0d6ce6f Author: SuJinpei <[email protected]> Authored: Thu Feb 1 15:03:08 2018 +0800 Committer: SuJinpei <[email protected]> Committed: Thu Feb 1 15:03:08 2018 +0800 ---------------------------------------------------------------------- core/conn/odb/src/odb.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/trafodion/blob/5cd19f67/core/conn/odb/src/odb.c ---------------------------------------------------------------------- diff --git a/core/conn/odb/src/odb.c b/core/conn/odb/src/odb.c index 211623e..fa3e732 100755 --- a/core/conn/odb/src/odb.c +++ b/core/conn/odb/src/odb.c @@ -5491,7 +5491,7 @@ static void etabadd(char type, char *run, int id) } } else { /* not a load job */ etab[no].k = no; /* record grandparent for copy/diff ops */ - if ( etab[no].ps ){ + if ( etab[no].ps > 1 ){ etab[no].TotalMaxRecords = etab[no].mr; etab[no].mr /= etab[no].ps; /* each thread will get a portion of the max record to fetch */ if (etab[0].r > etab[0].mr) /* rowset size should not exceeds the max size */
