我正在尝试迭代数据源：

val env = ExecutionEnvironment.getExecutionEnvironment
      env.setParallelism(1)

      val job = Job.getInstance
      FileInputFormat.addInputPath(
        job,
        new Path("file.parquet.gz")
      )

      val hadoopInputFormat: HadoopInputFormat[Void, GenericRecord] =
        new HadoopInputFormat(
          new AvroParquetInputFormat[GenericRecord],
          classOf[Void],
          classOf[GenericRecord],
          job
        )
       val data: DataSource[tuple.Tuple2[Void, GenericRecord]] = env.createInput(hadoopInputFormat)

当我做data.print时，我可以看到元组中的数据。
但当我这么做的时候：

data.map
     {
       res =>
         println("!!!!!!!!!!!111")
         println( res.f1)
     }

什么也没印出来。
我想迭代数据源并获取genericord。请帮帮我。