Skip to content
Permalink
Browse files
IGNITE-16277 Query failed with assertion (#548)
  • Loading branch information
korlov42 committed Jan 17, 2022
1 parent 40841cd commit 65ce2371b6c148df256390e4bea52ec06a6853d7
Showing 2 changed files with 6 additions and 6 deletions.
@@ -29,9 +29,6 @@
* TODO Documentation https://issues.apache.org/jira/browse/IGNITE-15859
*/
public class QueryTaskExecutorImpl implements QueryTaskExecutor, Thread.UncaughtExceptionHandler {
/** Default Ignite thread keep alive time. */
public static final long DFLT_THREAD_KEEP_ALIVE_TIME = 60_000L;

private static final IgniteLogger LOG = IgniteLogger.forClass(QueryTaskExecutorImpl.class);

private final String nodeName;
@@ -54,8 +51,8 @@ public void start() {
4,
NamedThreadFactory.threadPrefix(nodeName, "calciteQry"),
null,
true,
DFLT_THREAD_KEEP_ALIVE_TIME
false,
0
);
}

@@ -18,6 +18,7 @@
package org.apache.ignite.internal.sql.engine.exec.rel;

import static org.apache.ignite.internal.util.CollectionUtils.nullOrEmpty;
import static org.apache.ignite.lang.IgniteStringFormatter.format;

import java.util.Collection;
import java.util.Comparator;
@@ -193,7 +194,9 @@ protected void checkState() throws Exception {
if (thread == null) {
thread = Thread.currentThread();
} else {
assert thread == Thread.currentThread();
assert thread == Thread.currentThread() : format("expThread={}, actThread={}, "
+ "qryId={}, fragmentId={}", thread.getName(), Thread.currentThread().getName(),
context().queryId(), context().fragmentId());
}
}

0 comments on commit 65ce237

Please sign in to comment.