Fix Flaky Integration Tests + Migrate some tests to Test Containers

[siri-varma]

Phase 1 — Fix Flaky Integration Tests + Migrate Some ITs to Testcontainers

What this PR does

1. Fixes flakes in the existing sdk-tests harness (actor registration race, tracing span-name mismatch, streaming subscription reconnect).
2. Migrates 13 ITs off the legacy BaseIT/DaprRun harness (which requires a host-installed Dapr CLI + dapr init) onto Testcontainers via DaprContainer, matching the spring-boot-4-sdk-tests module.

Notable behavior fixes

• Actor IT registration timeout — BaseContainerIT.startAppAndAttach now starts AppRun before the daprd container, with daprd's HTTP/gRPC host ports pinned (via setPortBindings) to the same DaprPorts values the app's env already received. Previously daprd would probe the app channel before the JVM had bound the host port, fetch /dapr/config against the SSH bridge, get nothing, report actor types [] to placement, and never re-query.
• Tracing span name — Zipkin records calllocal/<APP_NAME>/<method>; the assertion expected the bogus <APP_NAME>-service suffix. Fixed in both grpc and http TracingITs.
• Streaming subscription reconnect (sdk/src/main/java/io/dapr/client/Subscription.java) — receiver thread now releases the state-change semaphore on onError, sleeps with a doubled-long backoff (1s → 30s cap, no overflow path), and is interrupted on close() so shutdown isn't blocked by a backoff sleep.

Files deleted in this PR — and why

File	Lines	Replacement	Notes
pubsub/http/PubSubIT.java	723	testcontainers/pubsub/http/DaprPubSubIT.java	Legacy BaseIT harness. Method mapping: publishPubSubNotFound→shouldReceiveInvalidArgument, testBulkPublishPubSubNotFound→shouldReceiveInvalidArgumentWithBulkPublish, testBulkPublish→shouldPublishSomePayloadTypesWithNoError, testPubSub→testPubSub, testPubSubBinary→shouldPublishBinary, testPubSubTTLMetadata→testPubSubTTLMetadata, testLongValues→testLongValues. testPubSubBulkSubscribe was missing — added on the migrated DaprPubSubIT in this PR.
pubsub/http/SubscriberController.java	265	(n/a)	Companion subprocess for legacy PubSubIT. The Testcontainers IT runs the Spring Boot subscriber inside the test JVM, so a separate process file isn't needed; a different SubscriberController already lives under testcontainers/pubsub/http/.
pubsub/http/SubscriberService.java	46	(n/a)	main() entry-point that spawned the legacy subscriber. No replacement needed.
pubsub/stream/PubSubStreamIT.java	339	testcontainers/pubsub/stream/DaprPubSubStreamIT.java	testPubSubDeadLetterTopic was missing — added on the migrated DaprPubSubStreamIT in this PR.
state/HelloWorldClientIT.java	74	state/GRPCStateClientIT.rawGrpcStubGetAndDeleteState	Single test of DaprClient.newGrpcStub(...) (raw DaprGrpc.DaprBlockingStub save/get/delete). Restored as a method on the migrated GRPCStateClientIT — no companion subprocess needed.
state/HelloWorldGrpcStateService.java	68	(n/a)	Companion subprocess for HelloWorldClientIT.

Mongo state store

AbstractStateClientIT.saveAndQueryAndDeleteState (Dapr preview Query State API, requires Mongo) was briefly @Disabled during the migration since Redis doesn't support that API and we'd dropped the docker-compose Mongo service. Now restored: SharedTestInfra.mongo() runs a pinned mongo:7 Testcontainer, and BaseContainerIT.mongoStateStore(...) registers a state.mongodb component on GRPCStateClientIT.

Container image pinning

SharedTestInfra now pins all three shared containers (redis:7-alpine, mongo:7, openzipkin/zipkin:3.4) instead of letting any of them float on :latest.

ITs intentionally NOT migrated (per spec Non-Goals)

BindingIT, ActorReminderFailoverIT, ActorReminderRecoveryIT, ActorTimerRecoveryIT, ActorStateIT, WaitForSidecarIT, ActorSdkResiliencyIT, plus 2 ITs in durabletask-client/. These remain on the legacy BaseIT/DaprRun harness.

Checklist

• Code compiles correctly
• Created/updated tests
• Extended the documentation

[siri-varma]

@javier-aliaga / @dapr/maintainers-java-sdk / @cicoyle This PR reduce some flakiness when running integration tests. I ran 5-6 times and all of them succeeded.

Could you folks please review ? Thank you.

[siri-varma]

Looks like last commit is having some issues

Restore parity for two legacy ITs deleted earlier

Let me look into that

[siri-varma]

@javier-aliaga / @cicoyle / @dapr/maintainers-java-sdk This PR is ready to be reveiwed. Ran the tests 5-6 times and all the instances succeeded.

So, we should definitely see a reduction in number of failures due to flakiness

[siri-varma]

I think next task would be to see how we can reduce the tests runtime to lower than 20 mins

[siri-varma]

@javier-aliaga / @cicoyle Just a bump on this PR. Would like to merge and get as many runs as possible to get data points

[javier-aliaga]

Where do we reset the backoff?

[javier-aliaga]

this still applies https://github.com/dapr/java-sdk/pull/1741/changes#r3265853071

[siri-varma]

Repasting the comment for easy reference. Apologies for missing it

This call is a sync call, no grpc stream call, this releases the lock but is not telling the stream to be closed.

2 possibilities here;

Do we want to kill the stream because one event fails? or we just notifiy the listener and we keep going?

} catch (Exception e) {
    listener.onError(DaprException.propagate(e));
    // optionally ack as RETRY so the broker can redeliver
    // do NOT call this.onError and do NOT release the semaphore
  }
If we want to close the stream then

  } catch (Exception e) {
    var s = streamRef.get();
    if (s != null) {
      try {
        s.onError(DaprException.propagate(e));  // client-side cancel of the gRPC stream
      } catch (Throwable ignore) {
        // already terminated
      }
    }
    // do NOT call this.onError(...) or release the semaphore here —
    // gRPC will invoke the server→client onError callback on cancellation,
    // which is the path at line 126, and that one releases the semaphore.
  }
I prefer the listener option, wdyt?

[codecov]

Codecov Report

❌ Patch coverage is 73.33333% with 4 lines in your changes missing coverage. Please review.
✅ Project coverage is 77.00%. Comparing base (3c12975) to head (aa2a7f9).

Files with missing lines	Patch %	Lines
sdk/src/main/java/io/dapr/client/Subscription.java	73.33%	4 Missing ⚠️

Additional details and impacted files

@@             Coverage Diff              @@
##             master    #1754      +/-   ##
============================================
+ Coverage     76.93%   77.00%   +0.07%     
- Complexity     2318     2322       +4     
============================================
  Files           245      245              
  Lines          7180     7194      +14     
  Branches        756      759       +3     
============================================
+ Hits           5524     5540      +16     
+ Misses         1289     1288       -1     
+ Partials        367      366       -1     

☔ View full report in Codecov by Harness.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:

• ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.