【Oracle】并行等待之PX Deq: Table Q Normal

简介:
本系列文章将会介绍在并行操作过程中 slave 进程和 QC 进程经常遇到的等待事件!
Waiting Processes:Slave
在并行执行环境中我们建立建立producer consumer 模型: 
处理数据(比如 从磁盘获取数据并做join 连接)的slave 集叫做producer slave ;另外一些等待获取处理结果数据的slave 称为consumer slave 。等待事件 "PX Deq: Table Q Normal" 意味着消费者slave进程等待生产者slave进程传递数据,然后他们(消费者)进程才能进行工作! 
v$session_wait 中该等待事件对应的参数:
P1 = sleeptime/senderid
P2 = passes
P3 = not used
sleeptime/senderid
我们可以使用如下语句获取 信息:
set SERVEROUTPUT on
undef p1
declare
    inst varchar(20);
    sender varchar(20);
begin
   select bitand(&&p1, 16711680) - 65535 as SNDRINST,
    decode(bitand(&&p1, 65535),65535, 'QC', 'P'||to_char(bitand(&&p1, 65535),'fm000') ) as SNDR
    into inst , sender
   from dual
   where bitand(&&p1, 268435456) = 268435456;
    dbms_output.put_line('Instance = '||inst);
    dbms_output.put_line('Sender = '||sender );
end;
如果P1的值为空,则意味slave 不需要等待任何进程
比如p1的值为268501004,则上面的sql会返回:
Instance = 1
Sender = P012
等待时间:空闲等待事件
这虽然是一个空闲等待事件,但是较长的等待时间意味着生产者slave 没有足够快的产生数据或者slave 集之间的通信方面存在问题!
解决办法:
   Investigate the slaves in  other slave set why they are not able to send the data faster.
相关文章
|
存储 Oracle 关系型数据库
Oracle中“ORA-00060: 等待资源时检测到死锁” 或存储过程编译卡死的一种解决方法
Oracle中“ORA-00060: 等待资源时检测到死锁” 或存储过程编译卡死的一种解决方法
861 0
|
6月前
|
SQL 监控 Oracle
关系型数据库Oracle并行执行
【7月更文挑战第12天】
147 14
|
6月前
|
SQL Oracle 关系型数据库
关系型数据库Oracle并行查询
【7月更文挑战第12天】
122 15
|
6月前
|
Oracle 关系型数据库 数据处理
|
6月前
|
SQL 监控 Oracle
|
6月前
|
SQL 监控 Oracle
|
7月前
|
消息中间件 Oracle 关系型数据库
使用 cx_Oracle 在 Oracle 中等待记录并执行操作
问题背景: 在第一个 Python 项目中,需要等待记录被插入 Oracle 表中,一旦记录存在,就调用 Python 函数。目前使用 cx_Oracle 库,采用一种无限循环的方式来查询表。如果记录存在,就调用函数,然后等待 5 秒后重新开始循环。但这种方式效率不高,等待时间太长,并且系统看起来很慢。如果不想要每秒都向数据库发送查询,是否有其他方法来等待记录并执行操作?
|
8月前
|
Oracle 关系型数据库 数据库
Oracle数据恢复—Oracle数据库误truncate table的数据恢复案例
北京某国企客户Oracle 11g R2数据库误truncate table CM_CHECK_ITEM_HIS,表数据丢失,业务查询到该表时报错,数据库的备份不可用,无法查询表数据。 Oracle数据库执行Truncate命令的原理:在执行Truncate命令后ORACLE会在数据字典和Segment Header中更新表的Data Object ID,但不会修改实际数据部分的块。由于数据字典与段头的DATA_OBJECT_ID与后续的数据块中的并不一致,所以ORACLE服务进程在读取全表数据时不会读取到已经被TRUNCATE的记录,但是实际数据未被覆盖。
Oracle数据恢复—Oracle数据库误truncate table的数据恢复案例
|
8月前
|
SQL 消息中间件 关系型数据库
实时计算 Flink版产品使用合集之flink-cdc-oracle 可以并行读取吗
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
SQL 存储 Oracle
flink-cdc-oracle 可以并行读取吗
flink-cdc-oracle 可以并行读取吗, 同步1000万数据,我这边半天没同步完, 这个有什么优化策略吗?这个怎么设置先全量并行读,然后增量 是flink sql跑的?
114 1