Member since
07-18-2024
6
Posts
8
Kudos Received
0
Solutions
07-27-2024
05:32 AM
1 Kudo
can you give me your email?
... View more
07-27-2024
05:30 AM
1 Kudo
i used this code for testing from nifiapi.flowfiletransform import FlowFileTransform, FlowFileTransformResult
class WriteHelloWorld(FlowFileTransform):
class Java:
implements = ['org.apache.nifi.python.processor.FlowFileTransform']
class ProcessorDetails:
version = '0.0.1-SNAPSHOT'
def __init__(self, **kwargs):
super().__init__(**kwargs)
def transform(self, context, flowfile):
return FlowFileTransformResult(relationship = "success", contents = "Hello World", attributes = {"greeting", "hello"}) python 3.11 , java 21 and Apache nifi 2.0.0 M4
... View more
07-24-2024
04:49 AM
1 Kudo
i used this repo https://github.com/apache/nifi-python-extensions
... View more
07-24-2024
02:35 AM
2 Kudos
ERROR [python-log-97916] py4j.java_gateway There was an exception while executing the Python Proxy on the Python Side. Traceback (most recent call last): File "C:\Nifi\nifi-2.0.0-M4\python\framework\py4j\java_gateway.py", line 2466, in _call_proxy return_value = getattr(self.pool[obj_id], method)(*params) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "C:\Nifi\nifi-2.0.0-M4\.\python\framework\Controller.py", line 75, in createProcessor processor = processorClass(jvm=self.gateway.jvm) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ TypeError: WriteHelloWorld.__init__() got an unexpected keyword argument 'jvm' 2024-07-19 11:08:55,680 ERROR [Initialize Python Processor ca359d33-0190-1000-2b29-ff0f5ad6577a (WriteHelloWorld)] o.a.n.py4j.StandardPythonProcessorBridge Failed to load code for Python Processor ca359d33-0190-1000-2b29-ff0f5ad6577a (WriteHelloWorld). Will try again in 64000 millis py4j.Py4JException: An exception was raised by the Python Proxy. Return Message: Traceback (most recent call last): File "C:\Nifi\nifi-2.0.0-M4\python\framework\py4j\java_gateway.py", line 2466, in _call_proxy return_value = getattr(self.pool[obj_id], method)(*params) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "C:\Nifi\nifi-2.0.0-M4\.\python\framework\Controller.py", line 75, in createProcessor processor = processorClass(jvm=self.gateway.jvm) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ TypeError: WriteHelloWorld.__init__() got an unexpected keyword argument 'jvm'
... View more
Labels:
- Labels:
-
Apache NiFi
07-24-2024
02:26 AM
2 Kudos
Hello, I have a question about the NiFi Python extension. I tried to build my own processor with Hatch and created a NAR file, but when I copy it into the lib folder in NiFi, I encounter this error: "2024-07-22 10:43:47,322 WARN [main] org.apache.nifi.nar.NarClassLoader .\work\nar\extensions\nifi_python_extensions-2.0.0.dev0.nar-unpacked does not contain NAR-INF/bundled-dependencies!" Is there any help available to resolve this?
... View more
Labels:
- Labels:
-
Apache NiFi
07-22-2024
02:53 AM
1 Kudo
Hello, I have a question about the NiFi Python extension. I tried to build my own processor with Hatch and created a NAR file, but when I copy it into the lib folder in NiFi, I encounter this error: "2024-07-22 10:43:47,322 WARN [main] org.apache.nifi.nar.NarClassLoader .\work\nar\extensions\nifi_python_extensions-2.0.0.dev0.nar-unpacked does not contain NAR-INF/bundled-dependencies!" Is there any help available to resolve this?
... View more