[FLINK-11656] Remove redundant test path in WordCountMapredITCase

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.6.4, 1.7.2, 1.8.0
• Fix Version/s: 1.8.0
• Component/s: API / DataSet, Connectors / Hadoop Compatibility, Tests
• Labels: pull-request-available
• Assignee: TANG Wen-hui
• Reporter: vinoyang
• Created: 19/Feb/19 08:09
• Updated: 15/Mar/19 11:39
• Resolved: 22/Feb/19 12:38

Description

method : 

@Override
protected void testProgram() throws Exception {
   internalRun(true);
   postSubmit();
   resultPath = getTempDirPath("result2");
   internalRun(false);
   postSubmit();
}

Previously, in order to test the deprecated API, the following code snippet existed:

if (isTestDeprecatedAPI) {
   input = env.createInput(HadoopInputs.readHadoopFile(new TextInputFormat(),
      LongWritable.class, Text.class, textPath));
} else {
   input = env.createInput(readHadoopFile(new TextInputFormat(),
      LongWritable.class, Text.class, textPath));
}

But now, the related APIs have been removed from the DataSet, so the code needs to be refactored to make it clearer.

 

Issue Links

• links to: GitHub Pull Request #7771