Re: Re: we finished a Chinesization & a Japanize version of Nifi 1.1

2017-03-14 Thread Koji Kawamura
Hi Dustin, Petter, Sorry for the delayed response. I think it is necessary for us as a community to the official Apache NiFi master branch. Because I think that's the only way to maintain localized content in the future, so that it will not being left behind. I wrote a NiFi Feature Proposal on L

ExecuteScript for lua

2017-03-14 Thread L Robin
Thanks Matt. This will be helpful to get started.And I will try it later

Re: Connection Issue

2017-03-14 Thread Oleg Zhurakousky
Anil I understand that you are having an issue and we are here to help, but we can only do this if you help us just a little more, so it would be very helpful if you provided a stack trace (I understand if you have to mask sensitive information). The “. . .fails saying cannot create AQSession.

Re: Connection Issue

2017-03-14 Thread Anil Rai
Here is the behaviour that we have seen so forhope this helps 1. When we run the java code in eclipse, it works and this is the connection object that is printed -> oracle.jdbc.driver.T4CConnection@6f75e721 2. When we hard code all the values as mentioned in my first email in a

Re: ConvertJSONToAvro converts only last valid JASON record from an Input file with many JSON records

2017-03-14 Thread James Wing
Anshuman, What kind of error messages are you seeing? If the input is newline-delimited JSON records, I believe ConvertJSONToAvro should transfer all valid records to the "success" relationship as a single Avro, and the entire input flowfile to the "incompatible" output if any are invalid. Does yo

Re: Connection Issue

2017-03-14 Thread Oleg Zhurakousky
Anil When you say "it does not like the connection object. . .” what do you mean by that? Can you please provide stack trace or some other details? Cheers Oleg > On Mar 14, 2017, at 4:06 PM, Anil Rai wrote: > > Thanks Russ. Yes, we are doing exactly the same thing. > >driverClass = c

Re: Connection Issue

2017-03-14 Thread Anil Rai
Thanks Russ. Yes, we are doing exactly the same thing. driverClass = context.getProperty(DRIVER_CLASS).getValue(); queueName = context.getProperty(QUEUE_NAME).getValue(); databaseSchema = context.getProperty(DATABASE_SCHEMA).getValue(); consumerName = context.getPro

Re: Connection Issue

2017-03-14 Thread Russell Bateman
Anil, Typically, your custom processor should have a property, something like public static final PropertyDescriptor DBCP_SERVICE = new PropertyDescriptor.Builder() .name("Database Connection Pooling Service") .description("The Controller Service that is used to obt

Connection Issue

2017-03-14 Thread Anil Rai
We have a use case to connect to oracle database and subscribe to Advanced Queuing (https://docs.oracle.com/cd/A58617_01/server.804/a58241/ch_aq.htm). Below is the java snippet to establish this connection from a java client. We can run this in eclipse and consume message from the advanced queue. *

Apache NiFi nifi-nar-maven-plugin-1.2.0 Release Helper Guide

2017-03-14 Thread Bryan Bende
Hello Apache NiFi community, Please find the associated guidance to help those interested in validating/verifying the release so they can vote. # Download latest KEYS file: https://dist.apache.org/repos/dist/dev/nifi/KEYS # Import keys file: gpg --import KEYS # [optional] Clear out local maven

[VOTE] Release Apache NiFi nifi-nar-maven-plugin-1.2.0

2017-03-14 Thread Bryan Bende
Hello, I am pleased to be calling this vote for the source release of Apache NiFi nifi-nar-maven-plugin-1.2.0. The source zip, including signatures, digests, etc. can be found at: https://repository.apache.org/content/repositories/orgapachenifi-1101 The Git tag is nifi-nar-maven-plugin-1.2.0-RC1

ConvertJSONToAvro converts only last valid JASON record from an Input file with many JSON records

2017-03-14 Thread Anshuman Ghosh
Hello Group/ Bryan, Anshu here. While trying the "*ConvertJSONToAvro*" processor, I came across the following issue. I am not sure whether it is correct or not though. So I have this input JSON file which might contain one or more valid/ invalid JSON records. Need to use this processor to convert

Re: ExecuteScript for lua

2017-03-14 Thread Matt Burgess
L Robin, I have an example of using LuaJ in ExecuteScript on my blog [1], but I believe you have found that and are looking for an example to also read in an incoming flow file and manipulate the contents. Often the scripting examples use Apache Commons' IOUtils class to read the entire flow file

Re: Re: we finished a Chinesization & a Japanize version of Nifi 1.1

2017-03-14 Thread wangj...@weiresearch.com
Hi Koji, Today ,we created the new repository of Nifi ,thr url : https://github.com/wangrenlei/nifi , the branch of master is based on branch NIFI-2676-rc1 ,nothing for modified , the branch of NIFI-cn-v1 is the Chinesization & a Japanize version of Nifi 1.1.0 ,the branch of NIFI-cn-pro-v1

ExecuteScript for lua

2017-03-14 Thread L Robin
Hi, I am using lua with ExecuteScript,and i am must get the flowFile from upstream for use session:get() and then i must deal with the flowFile,in the end write the flowFile to the downstream,can you help me and give me a simple example.Thank You!!