use config.getLong to access dpl.pth_06.batch.size.totalObjectCountLimit so that it is properly converted to long instead of float (#730)

kortemik · web-flow · commit 631c37055be8 · 2025-12-01T15:10:48.000+02:00
diff --git a/src/main/java/com/teragrep/pth_10/datasources/DPLDatasource.java b/src/main/java/com/teragrep/pth_10/datasources/DPLDatasource.java
@@ -177,10 +177,11 @@ private Dataset<Row> archiveStreamConsumerDataset(ArchiveQuery query, boolean is
         }
 
         if (config.hasPath("dpl.pth_06.batch.size.totalObjectCountLimit")) {
+            final long totalObjectCountLimit = config.getLong("dpl.pth_06.batch.size.totalObjectCountLimit");
+
             reader = reader
-                    .option(
-                            "batch.size.totalObjectCountLimit",
-                            config.getString("dpl.pth_06.batch.size.totalObjectCountLimit")
+                    .option("batch.size.totalObjectCountLimit", String.valueOf(totalObjectCountLimit)
+
                     );
         }
 

Original file line number	Diff line number	Diff line change
`@@ -177,10 +177,11 @@ private Dataset<Row> archiveStreamConsumerDataset(ArchiveQuery query, boolean is`
`177`	`177`	`}`
`178`	`178`
`179`	`179`	`if (config.hasPath("dpl.pth_06.batch.size.totalObjectCountLimit")) {`
	`180`	`+ final long totalObjectCountLimit = config.getLong("dpl.pth_06.batch.size.totalObjectCountLimit");`
	`181`	`+`
`180`	`182`	`reader = reader`
`181`		`- .option(`
`182`		`- "batch.size.totalObjectCountLimit",`
`183`		`- config.getString("dpl.pth_06.batch.size.totalObjectCountLimit")`
	`183`	`+ .option("batch.size.totalObjectCountLimit", String.valueOf(totalObjectCountLimit)`
	`184`	`+`
`184`	`185`	`);`
`185`	`186`	`}`
`186`	`187`