Increase expiration time

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<FlightEndpoint> 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<FlightInfo>(info);

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,

java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/ExpirationTimeProducer.java

@@ -56,19 +56,19 @@
  *
  * <ol>
  * <li>No expiration time</li>
- * <li>2 seconds expiration time</li>
- * <li>3 seconds expiration time</li>
+ * <li>5 seconds expiration time</li>
+ * <li>6 seconds expiration time</li>
  * </ol>
  *
  * 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.
  * <p>
  * 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.
  * <p>
  * 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<FlightEndpoint> 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);
   }