dbms_parallel_execute无法正常使用

clevernby

数据库版本11.2.0.3.1 Linux x86-64 2节点集群

首先创建任务并分配chunk,这个过程正常

1. DECLARE
   
2.   l_varTaskName  VARCHAR2(64) := 'correctdata';
   
3.   l_nBlockNumber NUMBER := 585534;
   
4. BEGIN
   
5.   dbms_parallel_execute.create_task(l_varTaskName);
   
6.   dbms_parallel_execute.create_chunks_by_rowid(task_name   => l_varTaskName
   
7.                                               ,table_owner => 'USER'
   
8.                                               ,table_name  => 'TABLE1'
   
9.                                               ,by_row      => FALSE
   
10.                                               ,chunk_size  => CEIL(l_nBlockNumber / 100));
    
11. END;

复制代码

执行后查看dba_parallel_execute_tasks发现status为chunked

然后执行任务，该过程不正常

1. DECLARE
   
2.   l_nParallelDegree NUMBER := 8;
   
3.   l_varTaskName     VARCHAR2(64) := 'correctdata';
   
4.   l_varSQL          VARCHAR2(4000) := 'update /*+ ROWID(dda) */ USER.TABLE1 SET COL2=COL1 WHERE COL2 IS NULL and rowid between :start_id and :end_id';
   
5. BEGIN
   
6.   dbms_parallel_execute.run_task(task_name      => l_varTaskName
   
7.                                 ,sql_stmt       => l_varSQL
   
8.                                 ,language_flag  => DBMS_SQL.native
   
9.                                 ,parallel_level => l_nParallelDegree);
   
10. END;

复制代码

只花了3秒就结束了，《PL/SQL REF》文档中提到“This procedure returns only when all the chunks are processed”，显然时间不正常。
查看dba_parallel_execute_tasks发现status还是chunked.

1. TASK_OWNER  TASK_NAME    CHUNK_TYPE   STATUS   TABLE_OWNER  TABLE_NAME  NUMBER_COLUMN   TASK_COMMENT    JOB_PREFIX     SQL_STMT                                             LANGUAGE_FLAG EDITION    APPLY_CROSSEDITION_TRIGGER     FIRE_APPLY_TRIGGER PARALLEL_LEVEL JOB_CLASS
   
2. ----------- ------------ ------------ -------- ------------ ----------- --------------- --------------- -------------- ---------------------------------------------------- ------------- ---------- ------------------------------ ------------------ -------------- -----------------
   
3. SYSTEM      correctdata  ROWID_RANGE  CHUNKED  USER         TABLE1                                      TASK$_8        update /*+ ROWID(dda) */ USER.TABLE1 SET COL2=COL1               1 ORA$BASE                                  TRUE                            8 DEFAULT_JOB_CLASS

复制代码

而视图dba_parallel_execute_chunks中显示所有chunked的status均为UNASSIGNED

该数据库job_queue_processes=1000

[ 本帖最后由 clevernby 于 2012-8-10 08:58 编辑 ]

clevernby

问题已解决，SQL语句执行出错，但未提示