suresh b created NIFI-8715:
------------------------------
Summary: Nifi 1.13 Execute script raising issue "failed to process
due to org.apache.nifi.processor.exception.ProcessException:
javax.script.ScriptException: SyntaxError: no viable alternative at input
'import' "
Key: NIFI-8715
URL: https://issues.apache.org/jira/browse/NIFI-8715
Project: Apache NiFi
Issue Type: Bug
Components: Core Framework, Core UI
Affects Versions: 1.13.2
Environment: Ubuntu 18.04
16 GB RAM
intel i7 10th gen
Reporter: suresh b
Fix For: 1.11.4
{code:java}
import json
from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback,InputStreamCallback,
OutputStreamCallback
class PyInputStreamCallback(InputStreamCallback):
def __init__(self):
self.json_content = {}
def process(self, inputStream):
text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
print(" text %s " %text)
class OutputWrite(OutputStreamCallback):
def __init__(self, obj):
self.obj = obj
def process(self, outputStream):
outputStream.write(bytearray(json.dumps(self.obj).encode('utf')))
###end class###
flowfile = session.get()
if flowfile != None:
py_is = PyInputStreamCallback()
session.read(flowfile, py_is)
flowfile = session.write(flowfile, OutputWrite(py_is.json_content))
session.transfer(flowfile, REL_SUCCESS)
session.commit()
session.close()
{code}
2021-06-18 16:00:00,513 ERROR [Timer-Driven Process Thread-10]
o.a.nifi.processors.script.ExecuteScript
ExecuteScript[id=f2ea959c-c0e5-3698-42a5-19993fbdb19b]
ExecuteScript[id=f2ea959c-c0e5-3698-42a5-19993fbdb19b] failed to process due to
org.apache.nifi.processor.exception.ProcessException:
javax.script.ScriptException: SyntaxError: no viable alternative at input
'import' in <script> at line number 2 at column number 59; rolling back
session: org.apache.nifi.processor.exception.ProcessException:
javax.script.ScriptException: SyntaxError: no viable alternative at input
'import' in <script> at line number 2 at column number 59
Above script is working fine in 1.11.4 nifi version, but it is raising
exception in latest nifi version. can any one help me how to fix it.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
