Omit CSOT-calculated maxTimeMS if it's greater than max int32.

mongo/integration/csot_test.go

@@ -234,7 +234,11 @@ func TestCSOT(t *testing.T) {
 			sendsMaxTimeMSWithTimeoutMS:       true,
 			sendsMaxTimeMSWithContextDeadline: true,
 			preventsConnClosureWithTimeoutMS:  true,
-			topologies:                        []mtest.TopologyKind{mtest.ReplicaSet},
+			// Change Streams aren't supported on standalone topologies.
+			topologies: []mtest.TopologyKind{
+				mtest.ReplicaSet,
+				mtest.Sharded,
+			},
 		},
 		{
 			desc:        "Cursor getMore",
@@ -436,6 +440,21 @@ func TestCSOT(t *testing.T) {
 			}
 		})
 	}
+
+	csotOpts := mtest.NewOptions().ClientOptions(options.Client().SetTimeout(10 * time.Second))
+	mt.RunOpts("maxTimeMS is omitted for values greater than 2147483647ms]", csotOpts, func(mt *mtest.T) {
+		ctx, cancel := context.WithTimeout(context.Background(), (2147483647+1)*time.Millisecond)
+		defer cancel()
+		_, err := mt.Coll.InsertOne(ctx, bson.D{})
+		require.NoError(t, err)
+
+		evt := mt.GetStartedEvent()
+		_, err = evt.Command.LookupErr("maxTimeMS")
+		assert.ErrorIs(mt,
+			err,
+			bsoncore.ErrElementNotFound,
+			"expected maxTimeMS BSON value to be missing, but is present")
+	})
 }
 
 func TestCSOT_errors(t *testing.T) {

x/mongo/driver/operation.go

@@ -1588,6 +1588,15 @@ func (op Operation) calculateMaxTimeMS(ctx context.Context, mon RTTMonitor) (uin
 					ErrDeadlineWouldBeExceeded)
 			}
 
+			// The server will return a "BadValue" error if maxTimeMS is greater
+			// than the maximum positive int32 value (about 24.9 days). If the
+			// user specified a timeout value greater than that,  omit maxTimeMS
+			// and let the client-side timeout handle cancelling the op if the
+			// timeout is ever reached.
+			if maxTimeMS > math.MaxInt32 {
+				return 0, nil
+			}
+
 			return uint64(maxTimeMS), nil
 		}
 	} else if op.MaxTime != nil {