hi:
I found a bug when i run
org.apache.drill.exec.physical.impl.TestDistributedFragmentRun. The following
is a detailed
description:------------------------------------------------------------21:07:03,883
|-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find
resource [logback.groovy]21:07:03,884 |-INFO in
ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource
[logback-test.xml]21:07:03,884 |-INFO in
ch.qos.logback.classic.LoggerContext[default] - Found resource [logback.xml] at
[file:/home/baeeq/workspace/drill/incubator-drill/sandbox/prototype/exec/java-exec/target/test-classes/logback.xml]21:07:03,886
|-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource
[logback.xml] occurs multiple times on the classpath.21:07:03,886 |-WARN in
ch.qos.logback.classic.LoggerContext[default] - Resource [logback.xml] occurs
at
[file:/home/baeeq/workspace/drill/incubator-drill/sandbox/prototype/common/target/test-classes/logback.xml]21:07:03,886
|-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource
[logback.xml] occurs at
[file:/home/baeeq/workspace/drill/incubator-drill/sandbox/prototype/exec/java-exec/target/classes/logback.xml]21:07:03,886
|-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource
[logback.xml] occurs at
[file:/home/baeeq/workspace/drill/incubator-drill/sandbox/prototype/exec/java-exec/target/test-classes/logback.xml]21:07:04,028
|-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - debug
attribute not set21:07:04,033 |-INFO in
ch.qos.logback.core.joran.action.AppenderAction - About to instantiate appender
of type
[de.huxhorn.lilith.logback.appender.ClassicMultiplexSocketAppender]21:07:04,062
|-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming appender as
[SOCKET]21:07:04,133 |-INFO in
de.huxhorn.lilith.logback.appender.ClassicMultiplexSocketAppender[SOCKET] -
Waiting 1s to establish connections.21:07:05,134 |-INFO in
de.huxhorn.lilith.logback.appender.ClassicMultiplexSocketAppender[SOCKET] -
Started
de.huxhorn.lilith.logback.appender.ClassicMultiplexSocketAppender[SOCKET]21:07:05,134
|-INFO in ch.qos.logback.core.joran.action.AppenderAction - About to
instantiate appender of type [ch.qos.logback.core.ConsoleAppender]21:07:05,140
|-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming appender as
[STDOUT]21:07:05,149 |-INFO in
ch.qos.logback.core.joran.action.NestedComplexPropertyIA - Assuming default
type [ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder]
property21:07:05,263 |-INFO in ch.qos.logback.classic.joran.action.LoggerAction
- Setting additivity of logger [org.apache.drill] to false21:07:05,263 |-INFO
in ch.qos.logback.classic.joran.action.LevelAction - org.apache.drill level set
to DEBUG21:07:05,263 |-INFO in
ch.qos.logback.core.joran.action.AppenderRefAction - Attaching appender named
[SOCKET] to Logger[org.apache.drill]21:07:05,264 |-INFO in
ch.qos.logback.classic.joran.action.LevelAction - ROOT level set to
ERROR21:07:05,264 |-INFO in ch.qos.logback.core.joran.action.AppenderRefAction
- Attaching appender named [STDOUT] to Logger[ROOT]21:07:05,264 |-INFO in
ch.qos.logback.classic.joran.action.ConfigurationAction - End of
configuration.21:07:05,266 |-INFO in
ch.qos.logback.classic.joran.JoranConfigurator@10921fc7 - Registering current
configuration as safe fallback point
Exception in thread "WorkManager-1" java.lang.IllegalArgumentException:
resource /org/apache/drill/exec/expr/fn/impl/SimpleRepeatedFunctions.java
relative to
org.apache.drill.exec.expr.fn.impl.SimpleRepeatedFunctions$ContainsBigInt not
found. at
com.google.common.base.Preconditions.checkArgument(Preconditions.java:119)
at com.google.common.io.Resources.getResource(Resources.java:203) at
org.apache.drill.exec.expr.fn.FunctionConverter.getClassBody(FunctionConverter.java:152)
at
org.apache.drill.exec.expr.fn.FunctionConverter.getHolder(FunctionConverter.java:115)
at
org.apache.drill.exec.expr.fn.FunctionImplementationRegistry.<init>(FunctionImplementationRegistry.java:26)
at
org.apache.drill.exec.work.foreman.RunningFragmentManager.runFragments(RunningFragmentManager.java:83)
at
org.apache.drill.exec.work.foreman.Foreman.runPhysicalPlan(Foreman.java:221)
at
org.apache.drill.exec.work.foreman.Foreman.parseAndRunPhysicalPlan(Foreman.java:180)
at org.apache.drill.exec.work.foreman.Foreman.run(Foreman.java:155) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:724)Exception in thread "WorkManager-1"
java.lang.IllegalArgumentException: resource
/org/apache/drill/exec/expr/fn/impl/SimpleRepeatedFunctions.java relative to
org.apache.drill.exec.expr.fn.impl.SimpleRepeatedFunctions$ContainsBigInt not
found. at
com.google.common.base.Preconditions.checkArgument(Preconditions.java:119)
at com.google.common.io.Resources.getResource(Resources.java:203) at
org.apache.drill.exec.expr.fn.FunctionConverter.getClassBody(FunctionConverter.java:152)
at
org.apache.drill.exec.expr.fn.FunctionConverter.getHolder(FunctionConverter.java:115)
at
org.apache.drill.exec.expr.fn.FunctionImplementationRegistry.<init>(FunctionImplementationRegistry.java:26)
at
org.apache.drill.exec.work.foreman.RunningFragmentManager.runFragments(RunningFragmentManager.java:83)
at
org.apache.drill.exec.work.foreman.Foreman.runPhysicalPlan(Foreman.java:221)
at
org.apache.drill.exec.work.foreman.Foreman.parseAndRunPhysicalPlan(Foreman.java:180)
at org.apache.drill.exec.work.foreman.Foreman.run(Foreman.java:155) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:724)Exception in thread "WorkManager-1"
java.lang.IllegalArgumentException: resource
/org/apache/drill/exec/expr/fn/impl/SimpleRepeatedFunctions.java relative to
org.apache.drill.exec.expr.fn.impl.SimpleRepeatedFunctions$ContainsBigInt not
found. at
com.google.common.base.Preconditions.checkArgument(Preconditions.java:119)
at com.google.common.io.Resources.getResource(Resources.java:203) at
org.apache.drill.exec.expr.fn.FunctionConverter.getClassBody(FunctionConverter.java:152)
at
org.apache.drill.exec.expr.fn.FunctionConverter.getHolder(FunctionConverter.java:115)
at
org.apache.drill.exec.expr.fn.FunctionImplementationRegistry.<init>(FunctionImplementationRegistry.java:26)
at
org.apache.drill.exec.work.foreman.RunningFragmentManager.runFragments(RunningFragmentManager.java:83)
at
org.apache.drill.exec.work.foreman.Foreman.runPhysicalPlan(Foreman.java:221)
at
org.apache.drill.exec.work.foreman.Foreman.parseAndRunPhysicalPlan(Foreman.java:180)
at org.apache.drill.exec.work.foreman.Foreman.run(Foreman.java:155) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:724)Screen [endpoint=address:
"localhost"user_port: 31013bit_port: 31014,
getChild()=org.apache.drill.exec.store.mock.MockGroupScanPOP@3b49f171]Exception
in thread "WorkManager-1" java.lang.IllegalArgumentException: resource
/org/apache/drill/exec/expr/fn/impl/SimpleRepeatedFunctions.java relative to
org.apache.drill.exec.expr.fn.impl.SimpleRepeatedFunctions$ContainsBigInt not
found. at
com.google.common.base.Preconditions.checkArgument(Preconditions.java:119)
at com.google.common.io.Resources.getResource(Resources.java:203) at
org.apache.drill.exec.expr.fn.FunctionConverter.getClassBody(FunctionConverter.java:152)
at
org.apache.drill.exec.expr.fn.FunctionConverter.getHolder(FunctionConverter.java:115)
at
org.apache.drill.exec.expr.fn.FunctionImplementationRegistry.<init>(FunctionImplementationRegistry.java:26)
at
org.apache.drill.exec.work.foreman.RunningFragmentManager.runFragments(RunningFragmentManager.java:83)
at
org.apache.drill.exec.work.foreman.Foreman.runPhysicalPlan(Foreman.java:221)
at
org.apache.drill.exec.work.foreman.Foreman.parseAndRunLogicalPlan(Foreman.java:171)
at org.apache.drill.exec.work.foreman.Foreman.run(Foreman.java:152) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at
java.lang.Thread.run(Thread.java:724)------------------------------------------------------------------------I
have a fix on this bug, Please see the attachment.
diff --git
a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/FunctionConverter.java
b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/FunctionConverter.java
index 33f61de..5b35fff 100644
---
a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/FunctionConverter.java
+++
b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/FunctionConverter.java
@@ -148,7 +148,7 @@ public class FunctionConverter {
String path = c.getName();
path = path.replaceFirst("\\$.*", "");
path = path.replace(".", File.separator);
- path = "/" + path + ".java";
+ path = "/" + path + ".class";
URL u = Resources.getResource(c, path);
InputSupplier<InputStream> supplier = Resources.newInputStreamSupplier(u);
try(InputStream is = supplier.getInput()){
