message: add test with shared job name
diff: @@ -529,7 +529,7 @@ class DataServiceOpsTest(data_service_test_base.TestBase,
  processing_mode="invalid", service="grpc://localhost:5000"))
  @combinations.generate(test_base.eager_only_combinations())
  - def testZipDatasetsWithDifferentProcessingModes(self):
  + def testZipDifferentProcessingModesDatasets(self):
  cluster = self.create_cluster(num_workers=2)
  num_elements = 100
  ds1 = dataset_ops.Dataset.range(num_elements)
  @@ -543,6 +543,21 @@ class DataServiceOpsTest(data_service_test_base.TestBase,
  ds, list(zip(range(num_elements), range(num_elements))),
  assert_items_equal=True)
  + @combinations.generate(test_base.eager_only_combinations())
  + def testZipDifferentProcessingModesDatasetsSharedJobName(self):
  + cluster = self.create_cluster(num_workers=2)
  + num_elements = 100
  + ds1 = dataset_ops.Dataset.range(num_elements)
  + ds1 = self.make_distributed_dataset(
  + ds1, cluster, processing_mode="distributed_epoch", job_name="job_name")
  + ds2 = dataset_ops.Dataset.range(num_elements)
  + ds2 = self.make_distributed_dataset(
  + ds2, cluster, processing_mode="parallel_epochs", job_name="job_name")
  + ds = dataset_ops.Dataset.zip(ds1, ds2)
  + self.assertDatasetProduces(
  + ds, list(zip(range(num_elements), range(num_elements))),
  + assert_items_equal=True)
  +
  @combinations.generate(test_base.eager_only_combinations())
  def testFromDatasetId(self):
  cluster = self.create_cluster(num_workers=1)
  