Hi @Aditya-Moghe ,   The setup still works in the same way. The only difference is that TLS and authentication are turned on by default for NiFi in the latest version. After you unpack and start the NiFi service, you can now access it through the following URL:   https://<hostname>:8443/nifi/   You can find the generated username and password by grepping the NiFi log. For example: ❯ grep "Generated [PU]" logs/nifi-app.log Generated Username [e4d1972e-88b5-43f1-af15-5b4a54f706c5] Generated Password [n7G7x9ud+2WjQR6aESrnxrjdi6sgqzl+]   Cheers, André   ... View more

@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