You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "suresh b (Jira)" <ji...@apache.org> on 2021/06/18 12:00:07 UTC
[jira] [Created] (NIFI-8715) 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' "
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)