Transfer relationship not specified and failed to create session in nifi

shreyanshu_pare — Mon, 05 Mar 2018 17:56:26 GMT

	@Tags({"json mapping with entitymaker"})
@CapabilityDescription("Provide a description")
public class MyProcessor extends AbstractProcessor {
    public static final Relationship SUCCESS = new Relationship.Builder()
            .name("SUCCESS")
            .description("Successfully converted incoming json file to EntitymakerJSON")
            .build();
    public static final Relationship FALIURE = new Relationship.Builder()
            .name("FALIURE")
            .description("Successfully converted incoming json file to EntitymakerJSON")
            .build();
    private Set<Relationship> relationships;
    @Override
    protected void init(final ProcessorInitializationContext context) {
        
    	final Set<Relationship> relationships = new HashSet<Relationship>();
        relationships.add(SUCCESS);
        relationships.add(FALIURE);
        this.relationships = Collections.unmodifiableSet(relationships);
    }
    @Override
    public Set<Relationship> getRelationships() {
        return relationships;
    }
    
   /* public final List<PropertyDescriptor> getSupportedPropertyDescriptors() {
		return null ;
     
    }
    @OnScheduled
    public void onScheduled(final ProcessContext context) {
    }*/
	@Override
    public void onTrigger(final ProcessContext context, final ProcessSession session) 
    		throws ProcessException,FlowFileHandlingException {
       
        final AtomicReference<String> value = new AtomicReference<>();
        FlowFile flowFile = session.get();
        
        if ( flowFile == null ) {
            return;
        }
        session.read(flowFile, new InputStreamCallback() {
            @Override
            public void process(InputStream in) throws IOException {
                try{
                	JSONParser parser = new JSONParser();
                    JSONArray inputdata;
                    
                    String json = IOUtils.toString(in);
                    inputdata = (JSONArray) parser.parse(json);
                
                    Jsonmapping jsm = new Jsonmapping();
        	        for (Object o : inputdata) 
        			{
        	        	JSONObject person = (JSONObject) o;
        	            JSONObject jo = jsm.finaljson(person);
        	            value.set(jo.toString());
        			} 
                }catch(Exception ex){
                    ex.printStackTrace();
                    getLogger().error("Failed to read json string.");
                }
            }
        });
        flowFile = session.write(flowFile, new OutputStreamCallback() {
            @Override
            public void process(OutputStream out) throws IOException {
            	out.write(value.get().getBytes());
            }
        });
        session.transfer(flowFile, SUCCESS);
        
        
    }
}

Re: Transfer relationship not specified and failed to create session in nifi

bbende — Mon, 05 Mar 2018 22:30:59 GMT

Please format the code so that it is readable.

Re: Transfer relationship not specified and failed to create session in nifi

shreyanshu_pare — Tue, 06 Mar 2018 12:45:55 GMT

Hi @Bryan Bende, I have formatted the code please check.

Re: Transfer relationship not specified and failed to create session in nifi

shreyanshu_pare — Tue, 06 Mar 2018 14:16:20 GMT

I think I have not used Failure Relationship, that's why is showing Error. Because when I create another processor and take only SUCCESS now it is solved.

Re: Transfer relationship not specified and failed to create session in nifi

asabatino — Mon, 24 Jun 2019 05:09:12 GMT

It's because you have a typo in your code: .name("FALIURE")

question Re: Transfer relationship not specified and failed to create session in nifi in Archives of Support Questions (Read Only)

Transfer relationship not specified and failed to create session in nifi

Re: Transfer relationship not specified and failed to create session in nifi

Re: Transfer relationship not specified and failed to create session in nifi

Re: Transfer relationship not specified and failed to create session in nifi

Re: Transfer relationship not specified and failed to create session in nifi