@araujo Thank you for the help.. It works.  ... View more

Thanks André. Our Application is running as http not https. See the result below.   [nifi1 ~]$ openssl s_client -connect ldap.dev.abcde:389 CONNECTED(00000003) write:errno=104 --- no peer certificate available --- No client certificate CA names sent --- SSL handshake has read 0 bytes and written 289 bytes --- New, (NONE), Cipher is (NONE) Secure Renegotiation IS NOT supported Compression: NONE Expansion: NONE No ALPN negotiated SSL-Session:     Protocol  : TLSv1.2     Cipher    : 0000     Session-ID:     Session-ID-ctx:     Master-Key:     Key-Arg   : None     Krb5 Principal: None     PSK identity: None     PSK identity hint: None     Start Time: 1662113057     Timeout   : 300 (sec)     Verify return code: 0 (ok) --- Please advise if there something we need to install/configure in our application   Thanks, Alvin ... View more

@araujo thank you! I had gotten around the issue by using a replaceText loop to search for capitals within' the keys 1 at a time and prepend underscores, followed by a jolt to lowercase all keys. You're script returns the same result, very impressed. Thanks again.   ... View more

@Rgupta7 ,   Check your flows for flowfiles stuck in queues (.e.g. maybe you have connections to stopped processors or dead-end funnels and messages stay there indefinitely).   Flowfiles are physically stored in bigger files that contain many flowfiles. If even one of those flowfiles are referenced by any queues, those files are never removed from disk.   Cheers, André   ... View more

@hegdemahendra ,   You need to set the time characteristic of the stream for it to work. For example, try setting it to processing time, as shown below: DataStream<String> matechedStream = patternStream .inProcessingTime() .process(new PatternProcessFunction<String, String>() { @Override public void processMatch(Map<String, List<String>> map, Context context, Collector<String> collector) throws Exception { collector.collect(map.get("start").toString()); } } );   Cheers, André ... View more

@ramesh0430 ,   What's the throughput that you are expecting?  What's your processor configurations?   Cheers, André   ... View more

@FozzieN ,   You can do exactly what you're trying to achieve using standard NiFi processors and a schema to describe your data structure. Please see attached a flow example that replicates what you are doing without the need for scripting. This flow uses the following schema, set as a parameter: { "type": "record", "name": "MyData", "fields": [ { "name": "source_timestamp", "type": "string" }, { "name": "signal", "type": "string" }, { "name": "value", "type": "string" }, { "name": "fecha_envio", "type": ["null", "string"], "default": null } ] }   Cheers, André ... View more