in dbeam-core/src/main/java/com/spotify/dbeam/options/JobNameConfiguration.java [40:58]
public static void configureJobName(final PipelineOptions options, final String... parts) {
try {
options.as(ApplicationNameOptions.class).setAppName("JdbcAvroJob");
} catch (Exception e) {
LOGGER.warn("Unable to configure ApplicationName", e);
}
if (options.getJobName() == null || "auto".equals(options.getJobName())) {
final String randomPart = Integer.toHexString(ThreadLocalRandom.current().nextInt());
final String jobName =
String.format(
"dbeam-%s-%s",
Arrays.stream(parts)
.filter(p -> !Strings.isNullOrEmpty(p))
.map(JobNameConfiguration::normalizeString)
.collect(Collectors.joining("-")),
randomPart);
options.setJobName(jobName);
}
}