[jira] [Created] (FLINK-31749) The Using Hadoop OutputFormats example is not avaliable for DataStream

["junzhong qin (Jira)" <ji...@apache.org>]

junzhong qin created FLINK-31749:
------------------------------------

             Summary: The Using Hadoop OutputFormats example is not avaliable for DataStream
                 Key: FLINK-31749
                 URL: https://issues.apache.org/jira/browse/FLINK-31749
             Project: Flink
          Issue Type: Improvement
          Components: Documentation
    Affects Versions: 1.15.4, 1.17.0
            Reporter: junzhong qin


The following example shows how to use Hadoop’s {{TextOutputFormat from the doc: https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/formats/hadoop/#using-hadoop-outputformats . But the DataStream has no outpu()).}}
{code:java}
// Obtain the result we want to emit
DataStream<Tuple2<Text, IntWritable>> hadoopResult = [...]

// Set up the Hadoop TextOutputFormat.
HadoopOutputFormat<Text, IntWritable> hadoopOF =
  // create the Flink wrapper.
  new HadoopOutputFormat<Text, IntWritable>(
    // set the Hadoop OutputFormat and specify the job.
    new TextOutputFormat<Text, IntWritable>(), job
  );
hadoopOF.getConfiguration().set("mapreduce.output.textoutputformat.separator", " ");
TextOutputFormat.setOutputPath(job, new Path(outputPath));

// Emit data using the Hadoop TextOutputFormat.
hadoopResult.output(hadoopOF); {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)