Skip to content

Commit 45dce6b

Browse files
committed
Testing without Spanner query for FlowControl
1 parent 1557dab commit 45dce6b

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/services/FlowControlService.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,9 @@ public Counter addRequestAndGetCounter(ProgramRunId programRunId, ProgramOptions
8888
throw new Exception("None time-based UUIDs are not supported");
8989
}
9090

91-
Counter counter = TransactionRunners.run(transactionRunner, context -> {
91+
Counter counter = new Counter(5, 5);
92+
/*
93+
TransactionRunners.run(transactionRunner, context -> {
9294
AppMetadataStore store = AppMetadataStore.create(context);
9395
store.recordProgramPending(programRunId,
9496
programOptions.getArguments().asMap(),
@@ -98,6 +100,8 @@ public Counter addRequestAndGetCounter(ProgramRunId programRunId, ProgramOptions
98100
int runningCount = store.getFlowControlRunningCount(readStalenessSeconds);
99101
return new Counter(launchingCount, runningCount);
100102
});
103+
104+
*/
101105
LOG.info("Added request with runId {}.", programRunId);
102106
emitMetrics(Constants.Metrics.FlowControl.LAUNCHING_COUNT, counter.getLaunchingCount());
103107

0 commit comments

Comments
 (0)