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.
