You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by ga...@apache.org on 2023/06/02 01:54:44 UTC
[doris] branch master updated: [Bug](runtime filter) fix NPE if runtime filter has no target (#20338)
This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 937f04033f [Bug](runtime filter) fix NPE if runtime filter has no target (#20338)
937f04033f is described below
commit 937f04033fa37b31ad8c69bee1033ab0d95e3da6
Author: Gabriel <ga...@gmail.com>
AuthorDate: Fri Jun 2 09:54:37 2023 +0800
[Bug](runtime filter) fix NPE if runtime filter has no target (#20338)
---
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
index a502abef9d..1ec5fe623b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -3141,6 +3141,9 @@ public class Coordinator {
params.params.runtime_filter_params.setRuntimeFilterMergeAddr(runtimeFilterMergeAddr);
if (instanceExecParam.instanceId.equals(runtimeFilterMergeInstanceId)) {
for (RuntimeFilter rf : assignedRuntimeFilters) {
+ if (!ridToTargetParam.containsKey(rf.getFilterId())) {
+ continue;
+ }
List<FRuntimeFilterTargetParam> fParams = ridToTargetParam.get(rf.getFilterId());
rf.computeUseRemoteRfOpt();
if (rf.getUseRemoteRfOpt()) {
@@ -3244,6 +3247,9 @@ public class Coordinator {
localParams.runtime_filter_params.setRuntimeFilterMergeAddr(runtimeFilterMergeAddr);
if (instanceExecParam.instanceId.equals(runtimeFilterMergeInstanceId)) {
for (RuntimeFilter rf : assignedRuntimeFilters) {
+ if (!ridToTargetParam.containsKey(rf.getFilterId())) {
+ continue;
+ }
List<FRuntimeFilterTargetParam> fParams = ridToTargetParam.get(rf.getFilterId());
rf.computeUseRemoteRfOpt();
if (rf.getUseRemoteRfOpt()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org