code: @Override
      public OutputCommitter getOutputCommitter(TaskAttemptContext taskAttemptContext)
              throws IOException, InterruptedException {
          return new OutputCommitter() {
              @Override
              public void setupJob(JobContext jobContext) throws IOException {
              }
  
              @Override
              public void cleanupJob(JobContext jobContext) throws IOException {
              }
  
              @Override
              public void setupTask(TaskAttemptContext taskAttemptContext) throws IOException {
              }
  
              @Override
              public void commitTask(TaskAttemptContext taskAttemptContext) throws IOException {
              }
  
              @Override
              public void abortTask(TaskAttemptContext taskAttemptContext) throws IOException {
              }
  
              @Override
              public boolean needsTaskCommit(TaskAttemptContext taskAttemptContext) throws IOException {
                  return false;
              }
          };
      }
docs: and writes to that instead.