flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hagersaleh <loveallah1...@yahoo.com>
Subject when run this example disply error Error: The program execution failed: java.lang.NullPointerException why?
Date Sat, 06 Jun 2015 20:03:15 GMT
when run this example from command line more error display why
public static Map<String, Integer> map = new HashMap<String, Integer>();
public static void main(String[] args) throws Exception {
map.put("C_MKTSEGMENT", 2);
   
        ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironment();
          DataSet<Customer3>
customers=env.readCsvFile("/home/hadoop/Desktop/Dataset/customer.csv")
					.fieldDelimiter('|')
					.includeFields("11000010").ignoreFirstLine()
					.tupleType(Customer3.class);
           customers = customers.filter(new FilterFunction<Customer3>() 
                        {
                            @Override                    
                            public boolean filter(Customer3 c) {
                             int 
index1=Integer.parseInt(map.get("C_MKTSEGMENT").toString()); 
                            return c.getField(index1).equals("AUTOMOBILE");
                        }
                });
           
           customers.print();
           customers.writeAsCsv("/home/hadoop/Desktop/Dataset/out1.csv",
"\n", "|",WriteMode.OVERWRITE);               
        env.execute("TPCH Query 3 Example");	
}


hadoop@ubuntu:~/Desktop/flink-0.7.0-incubating$ bin/flink run
/home/hadoop/Desktop/where_operation_final/dist/where_operation_final.jar
06/06/2015 13:12:31:	Job execution switched to status RUNNING
06/06/2015 13:12:31:	CHAIN DataSource (CSV Input (|)
/home/hadoop/Desktop/Dataset/customer.csv) -> Filter
(org.apache.flink.examples.java.relational.TPCHQuery3$1) (1/1) switched to
SCHEDULED
06/06/2015 13:12:31:	CHAIN DataSource (CSV Input (|)
/home/hadoop/Desktop/Dataset/customer.csv) -> Filter
(org.apache.flink.examples.java.relational.TPCHQuery3$1) (1/1) switched to
DEPLOYING
06/06/2015 13:12:31:	CHAIN DataSource (CSV Input (|)
/home/hadoop/Desktop/Dataset/customer.csv) -> Filter
(org.apache.flink.examples.java.relational.TPCHQuery3$1) (1/1) switched to
RUNNING
06/06/2015 13:12:31:	CHAIN DataSource (CSV Input (|)
/home/hadoop/Desktop/Dataset/customer.csv) -> Filter
(org.apache.flink.examples.java.relational.TPCHQuery3$1) (1/1) switched to
FAILED
java.lang.NullPointerException
	at
org.apache.flink.examples.java.relational.TPCHQuery3$1.filter(TPCHQuery3.java:73)
	at
org.apache.flink.examples.java.relational.TPCHQuery3$1.filter(TPCHQuery3.java:70)
	at
org.apache.flink.api.java.operators.translation.PlanFilterOperator$FlatMapFilter.flatMap(PlanFilterOperator.java:47)
	at
org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver.collect(ChainedFlatMapDriver.java:79)
	at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:215)
	at
org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:235)
	at java.lang.Thread.run(Thread.java:745)

06/06/2015 13:12:31:	Job execution switched to status FAILING
06/06/2015 13:12:31:	DataSink(Print to System.out) (1/1) switched to
CANCELED
06/06/2015 13:12:31:	DataSink(CsvOutputFormat (path:
/home/hadoop/Desktop/Dataset/out1.csv, delimiter: |)) (1/1) switched to
CANCELED
06/06/2015 13:12:31:	Job execution switched to status FAILED
Error: The program execution failed: java.lang.NullPointerException
	at
org.apache.flink.examples.java.relational.TPCHQuery3$1.filter(TPCHQuery3.java:73)
	at
org.apache.flink.examples.java.relational.TPCHQuery3$1.filter(TPCHQuery3.java:70)
	at
org.apache.flink.api.java.operators.translation.PlanFilterOperator$FlatMapFilter.flatMap(PlanFilterOperator.java:47)
	at
org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver.collect(ChainedFlatMapDriver.java:79)
	at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:215)
	at
org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:235)
	at java.lang.Thread.run(Thread.java:745)





--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/when-run-this-example-disply-error-Error-The-program-execution-failed-java-lang-NullPointerException-tp1527.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message