java - NoClassDefFound错误: org/apache/nifi/registry/VariableRegistry while running nifi test cases

Question

我对 apache nifi 还很陌生。几天前我停留在 this问题(这涉及到自定义 nifi 处理器的行为缺失)。调试对我没有太大帮助。因此，我决定探索 nifi 模拟框架(我应该已经这样做了，但没有这样做:)，正如对该问题的评论中所建议的那样。

我正在从以下链接获取帮助:1 , 2

我试图做的是将单个流文件发送到自定义处理器。为此，我按照建议使用 MergeContent(使用 FlowFile v3 版本)和 PutFile 处理器保存/序列化了实际流文件 here 。现在我尝试使用 GetFile 处理器通过测试中的代码重新读取此文件，如下所示:

import static org.junit.Assert.*;

import java.util.List;

import org.junit.Test;

import org.apache.nifi.util.TestRunners;
import org.apache.nifi.processors.standard.GetFile;
import org.apache.nifi.util.MockFlowFile;
import org.apache.nifi.util.TestRunner;

public class MyCustomProcessorTest {

    @Test
    public void testOnTrigger() {
        TestRunner runner = TestRunners.newTestRunner(new GetFile());
        runner.setProperty(GetFile.DIRECTORY, "C:\\Mahesh\\delete\\serialized-flow-files");
        runner.setProperty(GetFile.KEEP_SOURCE_FILE, "true");
        runner.run(1);

        List<MockFlowFile> results = runner.getFlowFilesForRelationship(GetFile.REL_SUCCESS);
        System.out.println("done");
    }
}

这给了我以下错误:

我应该包含哪个 Maven 依赖项才能获取此类？我的方法还好吗，或者还有更好的方法吗？

Answer 1

我会仔细检查 org.apache.nifi:nifi-api: 是否在类路径中。

如果使用maven我会运行“mvn dependency:tree”进行检查。