????????
Exception in thread Thread-14:
Traceback (most recent call last):
  File "D:\Anaconda3\envs\py37\lib\threading.py", line 926, in 
_bootstrap_inner
    self.run()
  File 
"D:\Anaconda3\envs\py37\lib\site-packages\apache_beam\runners\worker\data_plane.py",
 line 218, in run
    while not self._finished.wait(next_call - time.time()):
  File "D:\Anaconda3\envs\py37\lib\threading.py", line 552, in wait
    signaled = self._cond.wait(timeout)
  File "D:\Anaconda3\envs\py37\lib\threading.py", line 300, in wait
    gotit = waiter.acquire(True, timeout)
OverflowError: timeout value is too large

回复