Removed import and throws statement
@@ -35,7 +35,6 @@ import org.apache.nifi.logging.ComponentLog;
import org.apache.nifi.processor.ProcessContext;
import org.apache.nifi.processor.ProcessSession;
import org.apache.nifi.processor.Relationship;
-import org.apache.nifi.processor.exception.ProcessException;
import org.apache.nifi.processor.util.StandardValidators;
import org.apache.nifi.util.StopWatch;
@@ -56,7 +55,6 @@ import java.util.concurrent.TimeUnit;
)
public class ExecuteHQLStatement extends AbstractNiFiProcessor {
-
public static final PropertyDescriptor THRIFT_SERVICE = new PropertyDescriptor.Builder()
.name("Database Connection Pooling Service")
.description("The Controller Service that is used to obtain connection to database")
@@ -96,7 +94,7 @@ public class ExecuteHQLStatement extends AbstractNiFiProcessor {
}
@Override
- public void onTrigger(final ProcessContext context, final ProcessSession session) throws RuntimeException {
+ public void onTrigger(final ProcessContext context, final ProcessSession session) {
FlowFile flowFile = session.get();
if (flowFile == null) {
return;
