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)