Realize this is a bit late but I ran into you're emails when I encountered the same issue on a my installation of NiFi. I don't know what the too many users message is about but I do know why NiFi gets a null pointer exception. The PutHiveStreaming Processor uses the HiveEndpoint Class to communicate with Hive and when you tell it to auto create partitions it creates a new instance of CliSessionState an extended version of SessionState. This can be seen on line 458 at https://github.com/apache/hive/blob/master/hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/HiveEndPoint.java. Unfortunately CliSessionState doesn't set the ip address. If you look at the line in AuthorizationMetaStoreFilterHook mentioned you'll see it's calling getUserIpAddress on a SessionState instance. Since the partition is actually created that error must be occurring afterwards. I'm assuming this a bug but none of this code has been changed in a really long time.
I'm going to try building the Hive Streaming example outside of NiFi and see if it works at all.
Thanks
Shawn

On 2018/02/15 17:44:10, Michal Tomaszewski <[EMAIL PROTECTED]> wrote:

> nifi conf directory contains actual Hadoop configuration files: core-site.xml, hbase-site.xml, hdfs-site.xml, hive-site.xml, yarn-site.xml>

> HiveQL queries in NIFI (both SelectHiveQL and PutHiveQL) are working properly and fast.>
>
> The same error exists when using Hortonworks original 1.5 NiFi compilation installed automatically by Ambari using HDF 3.1 pack.>

>
> nifi-app.log:>
>
> 2018-02-15 17:42:29,889 INFO [put-hive-streaming-0] org.apache.hadoop.hive.ql.hooks.ATSHook Created ATS Hook>
> 2018-02-15 17:42:29,889 INFO [put-hive-streaming-0] org.apache.hadoop.hive.ql.log.PerfLogger <PERFLOG method=PostHook.org.apache.hadoop.hive.ql.hooks.ATSHook from=org.apache.hadoop.hive.ql.Driver>>

> 2018-02-15 17:42:29,890 INFO [put-hive-streaming-0] org.apache.hadoop.hive.ql.log.PerfLogger </PERFLOG method=PostHook.org.apache.hadoop.hive.ql.hooks.ATSHook start=1518712949889 end=1518712949890 duration=1 from=org.apache.hadoop.hive.ql.Driver>>

> 2018-02-15 17:42:29,890 INFO [put-hive-streaming-0] org.apache.hadoop.hive.ql.Driver Resetting the caller context to>

> 2018-02-15 17:42:29,890 INFO [put-hive-streaming-0] org.apache.hadoop.hive.ql.log.PerfLogger </PERFLOG method=Driver.execute start=1518712949845 end=1518712949890 duration=45 from=org.apache.hadoop.hive.ql.Driver>>

> 2018-02-15 17:42:29,890 INFO [put-hive-streaming-0] org.apache.hadoop.hive.ql.Driver OK>
> 2018-02-15 17:42:29,890 INFO [put-hive-streaming-0] org.apache.hadoop.hive.ql.log.PerfLogger <PERFLOG method=releaseLocks from=org.apache.hadoop.hive.ql.Driver>>

> 2018-02-15 17:42:29,890 INFO [put-hive-streaming-0] o.a.hadoop.hive.ql.lockmgr.DbTxnManager Stopped heartbeat for query: nifi_20180215174229_58046dbe-0af7-41ae-94c4-7bb692053d67>

> 2018-02-15 17:42:29,890 INFO [put-hive-streaming-0] o.a.hadoop.hive.ql.lockmgr.DbLockManager releaseLocks: [lockid:5010336 queryId=nifi_20180215174229_58046dbe-0af7-41ae-94c4-7bb692053d67 txnid:0]>

> 2018-02-15 17:42:29,894 INFO [put-hive-streaming-0] org.apache.hadoop.hive.ql.log.PerfLogger </PERFLOG method=releaseLocks start=1518712949890 end=1518712949894 duration=4 from=org.apache.hadoop.hive.ql.Driver>>

> 2018-02-15 17:42:29,894 INFO [put-hive-streaming-0] org.apache.hadoop.hive.ql.log.PerfLogger </PERFLOG method=Driver.run start=1518712949819 end=1518712949894 duration=75 from=org.apache.hadoop.hive.ql.Driver>>





[message truncated...]