Merge remote-tracking branch 'origin/master' into HAWQ-459
Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/55be00ce Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/55be00ce Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/55be00ce Branch: refs/heads/HAWQ-459 Commit: 55be00cee13cf1294ec75c7a50a928af735c2d4d Parents: b1198ed 76dc631 Author: Shivram Mani <[email protected]> Authored: Mon Mar 21 15:01:10 2016 -0700 Committer: Shivram Mani <[email protected]> Committed: Mon Mar 21 15:01:10 2016 -0700 ---------------------------------------------------------------------- configure | 27 - configure.in | 27 - .../hawq/mapreduce/TPCHClusterTester.java | 4 +- src/backend/Makefile | 8 +- src/backend/catalog/gp_toolkit.sql.in | 223 ----- src/backend/catalog/system_views.sql | 14 +- src/backend/cdb/cdbcopy.c | 2 +- src/backend/cdb/cdbdatalocality.c | 338 ++++--- src/backend/cdb/cdbdispatchresult.c | 28 +- src/backend/cdb/cdbfilesplit.c | 67 +- src/backend/cdb/cdbmutate.c | 2 +- src/backend/cdb/cdbvars.c | 3 + src/backend/cdb/dispatcher.c | 18 +- src/backend/cdb/dispatcher_mgt.c | 9 +- src/backend/cdb/executormgr.c | 32 +- src/backend/cdb/motion/ic_common.c | 7 +- src/backend/cdb/workermgr.c | 10 + src/backend/commands/analyze.c | 54 +- src/backend/commands/copy.c | 97 +- src/backend/commands/explain.c | 2 +- src/backend/commands/prepare.c | 2 +- src/backend/commands/tablecmds.c | 50 +- src/backend/executor/execDML.c | 99 +- src/backend/executor/execMain.c | 13 +- src/backend/executor/execUtils.c | 2 +- src/backend/executor/nodeDML.c | 2 +- src/backend/executor/spi.c | 71 +- src/backend/gpopt/gpopt.mk | 18 +- src/backend/gpopt/ivy.xml | 2 +- .../gpopt/translate/CTranslatorDXLToPlStmt.cpp | 2 + .../translate/CTranslatorRelcacheToDXL.cpp | 9 + src/backend/gpopt/utils/COptTasks.cpp | 4 +- src/backend/nodes/copyfuncs.c | 1 + src/backend/nodes/outfast.c | 1 + src/backend/nodes/outfuncs.c | 1 + src/backend/nodes/readfast.c | 1 + src/backend/optimizer/plan/planner.c | 60 +- src/backend/optimizer/util/clauses.c | 11 +- src/backend/optimizer/util/relnode.c | 2 +- src/backend/optimizer/util/walkers.c | 1 + src/backend/parser/analyze.c | 45 +- src/backend/parser/gram.y | 9 +- src/backend/postmaster/identity.c | 2 +- src/backend/postmaster/postmaster.c | 2 - .../communication/rmcomm_AsyncComm.c | 317 +++--- .../communication/rmcomm_Connect.c | 11 +- .../communication/rmcomm_Message.c | 6 +- .../communication/rmcomm_MessageHandler.c | 15 +- .../communication/rmcomm_MessageServer.c | 134 +-- .../communication/rmcomm_QD2RM.c | 149 +-- .../communication/rmcomm_RM2RMSEG.c | 42 +- .../communication/rmcomm_RMSEG2RM.c | 6 +- .../communication/rmcomm_SyncComm.c | 108 +- src/backend/resourcemanager/conntrack.c | 90 +- .../include/communication/rmcomm_AsyncComm.h | 36 +- .../include/communication/rmcomm_Connect.h | 1 - .../communication/rmcomm_MessageServer.h | 12 +- .../include/communication/rmcomm_SyncComm.h | 9 - src/backend/resourcemanager/include/conntrack.h | 11 +- src/backend/resourcemanager/include/errorcode.h | 1 + .../resourcemanager/include/resourcepool.h | 47 +- .../include/utils/network_utils.h | 40 +- src/backend/resourcemanager/requesthandler.c | 178 ++-- .../resourcemanager/requesthandler_RMSEG.c | 6 +- .../resourcebroker/resourcebroker_LIBYARN.c | 98 +- .../resourcebroker_LIBYARN_proc.c | 3 +- src/backend/resourcemanager/resourcemanager.c | 236 ++--- .../resourcemanager/resourcemanager_RMSEG.c | 1 - src/backend/resourcemanager/resourcepool.c | 986 +++++++++++++------ src/backend/resourcemanager/resqueuemanager.c | 42 +- .../resourcemanager/utils/network_utils.c | 407 +++++--- src/backend/tcop/postgres.c | 7 +- src/backend/utils/adt/test/Makefile | 42 + src/backend/utils/adt/test/varlena_test.c | 251 +++++ src/backend/utils/adt/varlena.c | 334 +++++-- src/backend/utils/cache/relcache.c | 2 +- src/backend/utils/gp/segadmin.c | 3 +- src/backend/utils/misc/etc/gpcheck.cnf | 2 +- src/backend/utils/misc/etc/hdfs-client.xml | 2 +- src/backend/utils/misc/faultinjector.c | 9 +- src/backend/utils/misc/guc.c | 51 +- src/bin/gpcheckhdfs/Makefile | 2 +- src/bin/gpfilesystem/hdfs/Makefile | 2 +- src/include/access/filesplit.h | 2 +- src/include/catalog/gp_configuration.h | 27 +- src/include/catalog/gp_segment_config.h | 11 +- src/include/catalog/pg_proc.h | 5 +- src/include/cdb/cdbdatalocality.h | 21 +- src/include/cdb/cdbvars.h | 3 + src/include/executor/execDML.h | 3 +- src/include/executor/spi.h | 7 + src/include/gpopt/translate/CTranslatorUtils.h | 4 - src/include/nodes/execnodes.h | 7 +- src/include/nodes/plannodes.h | 2 + src/include/optimizer/planner.h | 4 + src/include/postmaster/identity.h | 2 +- src/include/utils/builtins.h | 1 + src/include/utils/faultinjector.h | 2 + src/include/utils/guc.h | 1 + .../expected/create_table_distribution.out | 102 +- src/test/regress/expected/function.out | 16 + .../regress/expected/function_optimizer.out | 16 + src/test/regress/expected/goh_partition.out | 126 +++ .../expected/gpsql_alter_table_optimizer.out | 2 +- src/test/regress/expected/insert_optimizer.out | 2 +- src/test/regress/output/exttab1.source | 6 +- .../regress/output/exttab1_optimizer.source | 6 +- .../regress/sql/create_table_distribution.sql | 41 +- src/test/regress/sql/function.sql | 12 + src/test/regress/sql/goh_partition.sql | 68 ++ tools/bin/gppylib/data/2.0.json | 32 +- tools/bin/gppylib/programs/clsInjectFault.py | 5 +- tools/bin/hawq_ctl | 117 ++- tools/bin/hawqextract | 32 +- tools/bin/hawqpylib/HAWQ_HELP.py | 2 +- tools/bin/hawqpylib/hawqlib.py | 129 ++- tools/bin/hawqpylib/programs/clsInjectFault.py | 5 +- tools/bin/lib/hawqinit.sh | 66 +- 118 files changed, 3884 insertions(+), 2084 deletions(-) ----------------------------------------------------------------------
