diff --git a/cpp/src/arrow/flight/integration_tests/test_integration.cc b/cpp/src/arrow/flight/integration_tests/test_integration.cc index e8abfa1d614a5..e1d39ae5d7264 100644 --- a/cpp/src/arrow/flight/integration_tests/test_integration.cc +++ b/cpp/src/arrow/flight/integration_tests/test_integration.cc @@ -419,18 +419,18 @@ class OrderedScenario : public Scenario { /// three FlightEndpoints: /// /// 1. No expiration time -/// 2. 2 seconds expiration time -/// 3. 3 seconds expiration time +/// 2. 5 seconds expiration time +/// 3. 6 seconds expiration time /// /// The client can't read data from the first endpoint multiple times /// but can read data from the second and third endpoints. The client -/// can't re-read data from the second endpoint 2 seconds later. The -/// client can't re-read data from the third endpoint 3 seconds +/// can't re-read data from the second endpoint 5 seconds later. The +/// client can't re-read data from the third endpoint 6 seconds /// later. /// /// The client can cancel a returned FlightInfo by pre-defined /// CancelFlightInfo action. The client can't read data from endpoints -/// even within 3 seconds after the action. +/// even within 6 seconds after the action. /// /// The client can extend the expiration time of a FlightEndpoint in /// a returned FlightInfo by pre-defined RenewFlightEndpoint @@ -457,10 +457,10 @@ class ExpirationTimeServer : public FlightServerBase { auto schema = BuildSchema(); std::vector endpoints; AddEndpoint(endpoints, "No expiration time", std::nullopt); - AddEndpoint(endpoints, "2 seconds", - Timestamp::clock::now() + std::chrono::seconds{2}); - AddEndpoint(endpoints, "3 seconds", - Timestamp::clock::now() + std::chrono::seconds{3}); + AddEndpoint(endpoints, "5 seconds", + Timestamp::clock::now() + std::chrono::seconds{5}); + AddEndpoint(endpoints, "6 seconds", + Timestamp::clock::now() + std::chrono::seconds{6}); ARROW_ASSIGN_OR_RAISE( auto info, FlightInfo::Make(*schema, descriptor, endpoints, -1, -1, false)); *result = std::make_unique(info); diff --git a/go/arrow/internal/flight_integration/scenario.go b/go/arrow/internal/flight_integration/scenario.go index ff621d2069811..fb876eb2edd6d 100644 --- a/go/arrow/internal/flight_integration/scenario.go +++ b/go/arrow/internal/flight_integration/scenario.go @@ -759,10 +759,10 @@ func (tester *expirationTimeScenarioTester) GetFlightInfo(ctx context.Context, d ) var endpoints []*flight.FlightEndpoint endpoints = tester.AppendGetFlightInfo(endpoints, "No expiration time", nil) - expirationTime2 := time.Now().Add(time.Second * 2) - endpoints = tester.AppendGetFlightInfo(endpoints, "2 seconds", &expirationTime2) - expirationTime3 := time.Now().Add(time.Second * 3) - endpoints = tester.AppendGetFlightInfo(endpoints, "3 seconds", &expirationTime3) + expirationTime5 := time.Now().Add(time.Second * 5) + endpoints = tester.AppendGetFlightInfo(endpoints, "5 seconds", &expirationTime2) + expirationTime6 := time.Now().Add(time.Second * 6) + endpoints = tester.AppendGetFlightInfo(endpoints, "6 seconds", &expirationTime3) return &flight.FlightInfo{ Schema: flight.SerializeSchema(schema, memory.DefaultAllocator), FlightDescriptor: desc, diff --git a/java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/ExpirationTimeProducer.java b/java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/ExpirationTimeProducer.java index 42144f5ce204c..7838667e4d208 100644 --- a/java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/ExpirationTimeProducer.java +++ b/java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/ExpirationTimeProducer.java @@ -56,19 +56,19 @@ * *
    *
  1. No expiration time
  2. - *
  3. 2 seconds expiration time
  4. - *
  5. 3 seconds expiration time
  6. + *
  7. 5 seconds expiration time
  8. + *
  9. 6 seconds expiration time
  10. *
* * The client can't read data from the first endpoint multiple times * but can read data from the second and third endpoints. The client - * can't re-read data from the second endpoint 2 seconds later. The - * client can't re-read data from the third endpoint 3 seconds + * can't re-read data from the second endpoint 5 seconds later. The + * client can't re-read data from the third endpoint 6 seconds * later. *

* The client can cancel a returned FlightInfo by pre-defined * CancelFlightInfo action. The client can't read data from endpoints - * even within 3 seconds after the action. + * even within 6 seconds after the action. *

* The client can extend the expiration time of a FlightEndpoint in * a returned FlightInfo by pre-defined RenewFlightEndpoint @@ -93,8 +93,8 @@ public FlightInfo getFlightInfo(CallContext context, FlightDescriptor descriptor List endpoints = new ArrayList<>(); Instant now = Instant.now(); endpoints.add(addEndpoint("No expiration time", null)); - endpoints.add(addEndpoint("2 seconds", now.plus(2, ChronoUnit.SECONDS))); - endpoints.add(addEndpoint("3 seconds", now.plus(3, ChronoUnit.SECONDS))); + endpoints.add(addEndpoint("5 seconds", now.plus(5, ChronoUnit.SECONDS))); + endpoints.add(addEndpoint("6 seconds", now.plus(6, ChronoUnit.SECONDS))); return new FlightInfo(SCHEMA, descriptor, endpoints, -1, -1); }