@rahulsingh710 ,   Could you please click on the "Nodes" link in the RM UI and share the content of it?   André ... View more

@templarian ,   Would you be able to bump your NiFi log level to DEBUG and restart the service? Your nifi-app.log only seems to have INFO level messages.   André   ... View more

Hi, @Yemre ,   This is the way the Kafka Partitioners typically work. In general it's a safer approach since every record will be guaranteed to be routed to a valid partition. If the processor was using the literal value of the expression as the partition number, it could happen that some values could not be valid partitions, if proper care is not taken.   I don't think there's currently a way to explicitly specify the exact partition in the PublishKafka processors. However, if you use the method you mentioned, you will guarantee that every message with the same result for the expression that you specified will always be sent to the same partition. Isn't this enough for your use case? If not, could you please explain what are you trying to achieve?   Cheers, André   ... View more

@rahulsingh710 ,   Is 231GB the total physical memory of each NodeManager host? What's the current configuration of the yarn.nodemanager.resource.memory-mb parameter in your YARN service? That's the value that will be reported to the Resource Manager.   Regards, André   ... View more

@georg    Did the above answer your question?   Cheers, André ... View more

@wert_1311 ,   What are the symptoms of the ticket renewal failure? Are there any error messages anywhere? How did you conclude it's a ticket renewal problem?   Cheers, André   ... View more

@spserd    Interesting findings. Could you please share the differences in you pom file between the 2 runs? What are the Flink and NiFi artifacts you're using and their exact versions?   André   ... View more

@Nandy113 , does that answer your question? ... View more

Let's start from the beginning 🙂 What are the symptoms you see? ... View more

Good to hear! Which CDH/CDP version are you using?   Do you have any application error message regarding the failure of renewing the ticket?   André ... View more