How frequently is this occurring? It is worth checking network drops or you might consider increasing the timeouts on both sides ie. Resource Manager and Zookeeper. ... View more

@wffger2 @cotopaul  The InstanceIdentifier was introduced when NiFi switched from using the flow.xml.gz to the flow.josn.gz for flow persistence.  It is also currently being written to the flows stored in the NiFi-Registry.  I say "currently" because this jira exist and is still open: https://issues.apache.org/jira/browse/NIFI-11321 So as @cotopaul points out, the "instanceIdentifier" will be unique for each instantiation of the flow definition, but the "identifier" will be the same.  Downside here is every time you want to do a comparison, you'll need to download latest flow definition from DEV and UAT environments and compare for difference based on the Identifiers. Thanks, Matt ... View more

Hi @Albap    Based on the logs, i can see you have created streaming application. By default streaming application will run 24*7, it will stop only when we kill or some interrupted event happen at the system level.    Better way to kill/shutdown the spark streaming applications is by using graceful shutdown.   If you need further help, please raise an cloudera case we will work on.    ... View more

I assume you meant NVL function returns 0 or 1 if a null is found, or the specified expression in the argument - when using Hive. With Impala and NVL2 you would still need to have the outer query to "sum" up all the 1 values what we have mapped from the column value (from their real value to 0 or to 1). It would just be a bit nicer, but no real change. ... View more

Closing the connection while the query is still executing is generally not good practice. Think of it as taking ownership for the query you've executed, sort of like turning the lights off before you leave a room. If you're going to close the session (leave the room), you need to first cancel the query that's consuming resources (turn off the lights you turned on). The normal expectation is that an executing query will have an associated active session. ... View more

@Me Yes, that is the solution to your post, thank you for coming back with the fix. This will help more users in the future. Thanks for your contribution! ... View more

Thank you for your help, after I tried to change the Java version, the service started normally, because the Java version I used was too high for my installed CDH, thank you for your reply to my post！！！ ... View more

@Confluent61 Welcome to the Cloudera Community! To help you get the best possible solution, I have tagged our Kafka experts @paras and @rki_  who may be able to assist you further. Please keep us updated on your post, and we hope you find a satisfactory solution to your query. ... View more

@annakim Welcome to the Cloudera Community! To help you get the best possible solution, I have tagged our Zeppelin experts @Scharan and @iks  who may be able to assist you further. Please keep us updated on your post, and we hope you find a satisfactory solution to your query. ... View more