[CDAP-21235] : Introduce Spark Task attempt based record count metrics, buffer and dedup while run and Emit only on task success - #16182

Open

sahusanket wants to merge 1 commit into

CDAP-21235_record_count_fix

SonarQubeCloud / SonarCloud Code Analysis succeeded Jul 2, 2026 in 1m 52s

Quality Gate passed

Issues
3 New issues
0 Accepted issues

Measures
0 Security Hotspots
88.6% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud

Annotations

Check warning on line 193 in cdap-spark-core3_2.12/target/generated-sources/cdap-spark-core-base/src/main/java/io/cdap/cdap/app/runtime/spark/SparkRuntimeContext.java

sonarqubecloud / SonarCloud Code Analysis

Remove useless curly braces around statement

See more on https://sonarcloud.io/project/issues?id=cdapio_cdap&issues=AZ8j1LJqvs9BZkREq60s&open=AZ8j1LJqvs9BZkREq60s&pullRequest=16182

Check warning on line 192 in cdap-spark-core3_2.12/target/generated-sources/cdap-spark-core-base/src/main/java/io/cdap/cdap/app/runtime/spark/SparkRuntimeContext.java

sonarqubecloud / SonarCloud Code Analysis

Use a primitive boolean expression here.

See more on https://sonarcloud.io/project/issues?id=cdapio_cdap&issues=AZ8j1LJqvs9BZkREq60q&open=AZ8j1LJqvs9BZkREq60q&pullRequest=16182

Check warning on line 198 in cdap-spark-core3_2.12/target/generated-sources/cdap-spark-core-base/src/main/java/io/cdap/cdap/app/runtime/spark/SparkRuntimeContext.java

sonarqubecloud / SonarCloud Code Analysis

Use a primitive boolean expression here.

See more on https://sonarcloud.io/project/issues?id=cdapio_cdap&issues=AZ8j1LJqvs9BZkREq60r&open=AZ8j1LJqvs9BZkREq60r&pullRequest=16182

View more details on SonarQubeCloud