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 <gabrielleeb...@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-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
