You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@madlib.apache.org by nj...@apache.org on 2017/08/10 18:55:12 UTC

incubator-madlib git commit: WCC: Drop temporary table on completion.

Repository: incubator-madlib
Updated Branches:
  refs/heads/master 019247108 -> 0dc2df943


WCC: Drop temporary table on completion.

A temporary table used to store some intermediate results was not
dropped after completion, dropping it now.


Project: http://git-wip-us.apache.org/repos/asf/incubator-madlib/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-madlib/commit/0dc2df94
Tree: http://git-wip-us.apache.org/repos/asf/incubator-madlib/tree/0dc2df94
Diff: http://git-wip-us.apache.org/repos/asf/incubator-madlib/diff/0dc2df94

Branch: refs/heads/master
Commit: 0dc2df94358bb2ec3fd85865a6d53ae7cbde0226
Parents: 0192471
Author: Nandish Jayaram <nj...@apache.org>
Authored: Thu Aug 10 11:46:59 2017 -0700
Committer: Nandish Jayaram <nj...@apache.org>
Committed: Thu Aug 10 11:46:59 2017 -0700

----------------------------------------------------------------------
 src/ports/postgres/modules/graph/wcc.py_in | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/0dc2df94/src/ports/postgres/modules/graph/wcc.py_in
----------------------------------------------------------------------
diff --git a/src/ports/postgres/modules/graph/wcc.py_in b/src/ports/postgres/modules/graph/wcc.py_in
index 53ebda9..5c00f0b 100644
--- a/src/ports/postgres/modules/graph/wcc.py_in
+++ b/src/ports/postgres/modules/graph/wcc.py_in
@@ -180,6 +180,8 @@ def wcc(schema_madlib, vertex_table, vertex_id, edge_table, edge_args,
             """.format(select_grouping_cols=',' + subq_prefixed_grouping_cols,
                        select_grouping_cols_clause=grouping_cols_comma,
                        **locals()))
+        # drop intermediate table
+        plpy.execute("DROP TABLE IF EXISTS {0}".format(distinct_grp_table))
         plpy.execute("""
                 CREATE TEMP TABLE {message} AS
                 SELECT {vertex_id},