[ https://issues.apache.org/jira/browse/BEAM-10414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Maximilian Michels updated BEAM-10414: -------------------------------------- Description: The proprietary {{FlinkStreamingImpulse}} stopped working from 2.20.0 on. Fortunately, its functionality can now be realized via timers, e.g. https://github.com/mxm/beam/blob/d106f263e625e5d7c4f3848f16da301871f65142/sdks/python/apache_beam/testing/load_tests/pardo_test.py#L206. (was: The proprietary {{FlinkStreamingImpulse}} stopped working from 2.20.0 on. Fortunately, it's functionality can now be realized via timers, e.g. https://github.com/mxm/beam/blob/d106f263e625e5d7c4f3848f16da301871f65142/sdks/python/apache_beam/testing/load_tests/pardo_test.py#L206.) > FlinkStreamingImpulseSource fails in from_runner_api > ---------------------------------------------------- > > Key: BEAM-10414 > URL: https://issues.apache.org/jira/browse/BEAM-10414 > Project: Beam > Issue Type: Bug > Components: runner-flink, sdk-py-core > Affects Versions: 2.20.0, 2.21.0, 2.22.0, 2.23.0 > Reporter: Maximilian Michels > Assignee: Maximilian Michels > Priority: P3 > > The proprietary {{FlinkStreamingImpulse}} stopped working from 2.20.0 on. > Fortunately, its functionality can now be realized via timers, e.g. > https://github.com/mxm/beam/blob/d106f263e625e5d7c4f3848f16da301871f65142/sdks/python/apache_beam/testing/load_tests/pardo_test.py#L206. -- This message was sent by Atlassian Jira (v8.3.4#803005)