Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25883

The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Minor
    • Resolution: Fixed
    • None
    • 1.12.8, 1.14.4, 1.15.0, 1.13.7
    • None
    • None

    • Windows, Python 3.8

    Description

      In this line, the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to 3153600000. This is more than the default value of threading.TIMEOUT_MAX on Windows Python, which is 4294967. Due to this, "OverflowError: timeout value is too large" error is produced.

      Full traceback:

       File "G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py", line 218, in run
  while not self._finished.wait(next_call - time.time()):
 File "C:\Python38\lib\threading.py", line 558, in wait
  signaled = self._cond.wait(timeout)
 File "C:\Python38\lib\threading.py", line 306, in wait
  gotit = waiter.acquire(True, timeout)
OverflowError: timeout value is too large

      Attachments

        Issue Links

          is duplicated by

          Bug - A problem which impairs or prevents the functions of the product. FLINK-25207 sample pyflink from documentation doesn't work in jupyter notebooks

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Activity

            People

              dianfu Dian Fu
              Karganak Mikhail
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: