compilation errors fixed

cloudera · Oct 24, 2024 · acb5448 · acb5448
1 parent 81a4038
commit acb5448
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/.github/workflows/build_and_test.yml b/.github/workflows/build_and_test.yml
@@ -28,7 +28,7 @@ jobs:
           restore-keys: |
             ${{ runner.os }}-maven-
       - name: Check codestyle
-        run: mvn -B validate --file flink-cyber/pom.xml
+        run: mvn -B compile -T 1C --file flink-cyber/pom.xml
       - name: Build and Test with Maven
         run: mvn -P '!add-dependencies-for-IDEA,!full-build,!include-front-end' -B verify --file flink-cyber/pom.xml
 

diff --git a/flink-cyber/flink-dedupe/src/main/java/com/cloudera/cyber/dedupe/DedupeJobKafka.java b/flink-cyber/flink-dedupe/src/main/java/com/cloudera/cyber/dedupe/DedupeJobKafka.java
@@ -69,7 +69,7 @@ protected DataStream<Message> createSource(StreamExecutionEnvironment env, Param
 
         WatermarkStrategy<Message> watermarkStrategy = WatermarkStrategy.<Message>forBoundedOutOfOrderness(
                                                                               Duration.ofMillis(params.getLong(PARAM_DEDUPE_LATENESS, 0L)))
-                                                                        .thTimestampAssigner(
+                                                                        .withTimestampAssigner(
                                                                               (event, timestamp) -> event.getTs());
         return env.fromSource(createKafkaSource(inputTopic,
                         params,

diff --git a/...er-java/src/main/java/com/cloudera/cyber/profiler/FieldValueProfileAggregateFunction.java b/...er-java/src/main/java/com/cloudera/cyber/profiler/FieldValueProfileAggregateFunction.java
@@ -32,7 +32,7 @@ public ProfileGroupAcc createAccumulator() {
     @Override
     protected Map<String, DecimalFormat> getMeasurementFormats() {
         return profileGroupConfig.getMeasurements().stream()
-                                 .llect(Collectors.toMap(ProfileMeasurementConfig::getResultExtensionName,
+                                 .collect(Collectors.toMap(ProfileMeasurementConfig::getResultExtensionName,
                                        ProfileMeasurementConfig::getDecimalFormat));
     }
 }