Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1682

Task callback timeout should not apply when wrapping StreamTask with AsyncStreamTaskAdapter

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • None
    • 0.15.0
    • None
    • None

    Description

      When using the AsyncRunLoop (i.e., with "single.thread.mode" = false), StreamTasks are wrapped in AsyncStreamTaskAdapter. This means that the task.callback.timeout.ms configuration applies to these StreamTask too. This can cause confusion since the user isn't expecting any callbacks. The documentation for the task.callback.timeout.ms configuration is also unclear, and states that it only applies to AsyncStreamTask.

      We should default the callback to Integer.MAX_VALUE when wrapping an StreamTask.

      Attachments

        Issue Links

          is duplicated by

          Bug - A problem which impairs or prevents the functions of the product. SAMZA-1680 There should be no TaskCallbackTimeoutException for StreamTask jobs.

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              Unassigned Unassigned
              pmaheshwari Prateek Maheshwari
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: