Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class ConnectionInputFormat extends FileInputFormat<Text, Connection> {
- @Override
- public RecordReader<Text, Connection> createRecordReader(InputSplit split, TaskAttemptContext context) throws IOException, InterruptedException {
- return new ConnectionRecordReader();
- }
- }
- Exception in thread "main" java.lang.RuntimeException: java.lang.NoSuchMethodException: testingground.TestInputJob$ConnectionInputFormat.<init>()
- at org.apache.hadoop.util.ReflectionUtils.newInstance(ReflectionUtils.java:115)
- at org.apache.hadoop.mapred.JobClient.writeNewSplits(JobClient.java:882)
- at org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:779)
- at org.apache.hadoop.mapreduce.Job.submit(Job.java:432)
- at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:447)
- at testingground.TestInputJob.run(TestInputJob.java:141)
- at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)
- at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:79)
- at testingground.TestInputJob.main(TestInputJob.java:156)
- Caused by: java.lang.NoSuchMethodException: testingground.TestInputJob$ConnectionInputFormat.<init>()
- at java.lang.Class.getConstructor0(Class.java:2706)
- at java.lang.Class.getDeclaredConstructor(Class.java:1985)
- at org.apache.hadoop.util.ReflectionUtils.newInstance(ReflectionUtils.java:109)
- ... 8 more
- Java Result: 1
- public class ConnectionInputFormat extends FileInputFormat<Text, Connection> {
- public ConnectionInputFormat() {
- System.out.println("NetflowInputFormat Constructor");
- }
- @Override
- public RecordReader<Text, Connection> createRecordReader(InputSplit split, TaskAttemptContext context) throws IOException, InterruptedException {
- return new ConnectionRecordReader();
- }
- }
- public class ConnectionInputFormat extends FileInputFormat<Text, Connection> {
- public ConnectionInputFormat() {
- System.out.println("NetflowInputFormat Constructor");
- }
- public ConnectionInputFormat(Object... o) {
- System.out.println("NetflowInputFormat Constructor");
- }
- @Override
- public RecordReader<Text, Connection> createRecordReader(InputSplit split, TaskAttemptContext context) throws IOException, InterruptedException {
- return new ConnectionRecordReader();
- }
- }
Add Comment
Please, Sign In to add comment