Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

QueryRecord Processor on Avro

Highlighted

QueryRecord Processor on Avro

Super Guru

2018-10-15 13:13:24,027 ERROR - o.a.nifi.processors.standard.QueryRecord QueryRecord[id=d0258284-69ae-34f6-97df-fa5c82402ef3] Unable to query StandardFlowFileRecord[uuid=641adc15-d0c2-48b9-a4c9-530690dc652e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1539622751488-207, container=default, section=207], offset=747784, length=319593],offset=0,name=511461965839665,size=319593] due to org.apache.nifi.processor.exception.ProcessException: Failed to read next record in stream for StandardFlowFileRecord[uuid=641adc15-d0c2-48b9-a4c9-530690dc652e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1539622751488-207, container=default, section=207], offset=747784, length=319593],offset=0,name=511461965839665,size=319593] due to null: org.apache.nifi.processor.exception.ProcessException: Failed to read next record in stream for StandardFlowFileRecord[uuid=641adc15-d0c2-48b9-a4c9-530690dc652e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1539622751488-207, container=default, section=207], offset=747784, length=319593],offset=0,name=511461965839665,size=319593] due to null org.apache.nifi.processor.exception.ProcessException: Failed to read next record in stream for StandardFlowFileRecord[uuid=641adc15-d0c2-48b9-a4c9-530690dc652e,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1539622751488-207, container=default, section=207], offset=747784, length=319593],offset=0,name=511461965839665,size=319593] due to null at org.apache.nifi.queryrecord.FlowFileEnumerator.moveNext(FlowFileEnumerator.java:65) at Baz$1$1.moveNext(Unknown Source) at org.apache.calcite.linq4j.Linq4j$EnumeratorIterator.<init>(Linq4j.java:664) at org.apache.calcite.linq4j.Linq4j.enumeratorIterator(Linq4j.java:98) at org.apache.calcite.linq4j.AbstractEnumerable.iterator(AbstractEnumerable.java:33) at org.apache.calcite.avatica.MetaImpl.createCursor(MetaImpl.java:89) at org.apache.calcite.avatica.AvaticaResultSet.execute(AvaticaResultSet.java:196) at org.apache.calcite.jdbc.CalciteResultSet.execute(CalciteResultSet.java:67) at org.apache.calcite.jdbc.CalciteResultSet.execute(CalciteResultSet.java:44) at org.apache.calcite.avatica.AvaticaConnection$1.execute(AvaticaConnection.java:607) at org.apache.calcite.jdbc.CalciteMetaImpl.prepareAndExecute(CalciteMetaImpl.java:600) at org.apache.calcite.avatica.AvaticaConnection.prepareAndExecuteInternal(AvaticaConnection.java:615) at org.apache.calcite.avatica.AvaticaStatement.executeInternal(AvaticaStatement.java:148) at org.apache.calcite.avatica.AvaticaStatement.executeQuery(AvaticaStatement.java:218) at org.apache.nifi.processors.standard.QueryRecord.query(QueryRecord.java:527) at org.apache.nifi.processors.standard.QueryRecord.onTrigger(QueryRecord.java:303) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1165) at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:203) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.ArrayIndexOutOfBoundsException: null

For Query AVRO in, AVRO Out

SELECT * FROM FLOWFILE WHERE isBackPressureEnabled IS NOT NULL AND isBackPressureEnabled = 'true'

Data is coming in and sometimes works.

Don't have an account?
Coming from Hortonworks? Activate your account here