Updates to Heron UI and Tracker code to work with Python 3 updates (#3786)
authorNicholas Nezis <nicholas.nezis@gmail.com>
Tue, 12 Apr 2022 00:26:51 +0000 (20:26 -0400)
committerGitHub <noreply@github.com>
Tue, 12 Apr 2022 00:26:51 +0000 (20:26 -0400)
commit700125f271b854a5ad2e3fe3204c1e2169ce069a
tree0bce367c5be0fdbe9b006a23d74b7dfd3c2cc876
parentae4099f15d8f7a6a3b9b0eae3112a80e6ae98ed5
Updates to Heron UI and Tracker code to work with Python 3 updates (#3786)

* Fix for missing physical plan in UI
* Fix the Heron UI timeline metrics
* Removed Tracker EnvelopeAPI Router which was not working
* Updated AckingTopology to not burn so much CPU
* Updated pylint due to build issue which resulted in lots of format updates

Co-authored-by: choi se <thinker0@gmail.com>
Co-authored-by: choi se <357785+thinker0@users.noreply.github.com>
Co-authored-by: Saad Ur Rahman <surahman@users.noreply.github.com>
Co-authored-by: Saad Ur Rahman <saadurrahman@apache.org>
139 files changed:
bazel_configure.py
examples/src/java/org/apache/heron/examples/api/AckingTopology.java
examples/src/python/bolt/consume_bolt.py
examples/src/python/bolt/count_bolt.py
examples/src/python/bolt/half_ack_bolt.py
examples/src/python/bolt/stateful_count_bolt.py
examples/src/python/bolt/stream_aggregate_bolt.py
examples/src/python/bolt/window_size_bolt.py
examples/src/python/spout/multi_stream_spout.py
examples/src/python/spout/stateful_word_spout.py
examples/src/python/spout/word_spout.py
heron/common/src/python/pex_loader.py
heron/executor/src/python/heron_executor.py
heron/executor/tests/python/heron_executor_unittest.py
heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/TrackerMetricsProvider.java
heron/instance/src/python/basics/base_instance.py
heron/instance/src/python/basics/bolt_instance.py
heron/instance/src/python/basics/spout_instance.py
heron/instance/src/python/instance.py
heron/instance/src/python/network/gateway_looper.py
heron/instance/src/python/network/heron_client.py
heron/instance/src/python/network/metricsmgr_client.py
heron/instance/src/python/network/protocol.py
heron/instance/src/python/network/socket_options.py
heron/instance/src/python/utils/metrics/metrics_helper.py
heron/instance/src/python/utils/metrics/py_metrics.py
heron/instance/src/python/utils/misc/communicator.py
heron/instance/src/python/utils/misc/custom_grouping_helper.py
heron/instance/src/python/utils/misc/pplan_helper.py
heron/instance/src/python/utils/misc/serializer_helper.py
heron/instance/src/python/utils/topology/topology_context_impl.py
heron/instance/tests/python/utils/mock_generator.py
heron/schedulers/src/java/org/apache/heron/scheduler/kubernetes/V1Controller.java
heron/shell/src/python/handlers/downloadhandler.py
heron/shell/src/python/handlers/killexecutorhandler.py
heron/shell/src/python/handlers/pidhandler.py
heron/shell/src/python/main.py
heron/shell/src/python/utils.py
heron/statemgrs/src/python/configloader.py
heron/statemgrs/src/python/filestatemanager.py
heron/statemgrs/src/python/statemanager.py
heron/statemgrs/src/python/statemanagerfactory.py
heron/statemgrs/src/python/zkstatemanager.py
heron/tools/cli/src/python/activate.py
heron/tools/cli/src/python/args.py
heron/tools/cli/src/python/cdefs.py
heron/tools/cli/src/python/cli_helper.py
heron/tools/cli/src/python/cliconfig.py
heron/tools/cli/src/python/config.py
heron/tools/cli/src/python/deactivate.py
heron/tools/cli/src/python/execute.py
heron/tools/cli/src/python/help.py
heron/tools/cli/src/python/jars.py
heron/tools/cli/src/python/kill.py
heron/tools/cli/src/python/main.py
heron/tools/cli/src/python/opts.py
heron/tools/cli/src/python/restart.py
heron/tools/cli/src/python/result.py
heron/tools/cli/src/python/submit.py
heron/tools/cli/src/python/update.py
heron/tools/cli/src/python/version.py
heron/tools/cli/tests/python/opts_unittest.py
heron/tools/common/src/python/clients/tracker.py
heron/tools/common/src/python/utils/config.py
heron/tools/explorer/src/python/logicalplan.py
heron/tools/explorer/src/python/main.py
heron/tools/explorer/src/python/physicalplan.py
heron/tools/explorer/src/python/topologies.py
heron/tools/tracker/src/python/BUILD
heron/tools/tracker/src/python/app.py
heron/tools/tracker/src/python/config.py
heron/tools/tracker/src/python/main.py
heron/tools/tracker/src/python/metricstimeline.py
heron/tools/tracker/src/python/query_operators.py
heron/tools/tracker/src/python/routers/container.py
heron/tools/tracker/src/python/routers/metrics.py
heron/tools/tracker/src/python/routers/topologies.py
heron/tools/tracker/src/python/topology.py
heron/tools/tracker/src/python/tracker.py
heron/tools/tracker/src/python/utils.py
heron/tools/tracker/tests/python/app_unittest.py
heron/tools/tracker/tests/python/query_operator_unittest.py
heron/tools/ui/resources/static/js/exceptions.js
heron/tools/ui/resources/static/js/physical-plan.js
heron/tools/ui/resources/static/js/plan-controller.js
heron/tools/ui/resources/static/js/topologies.js
heron/tools/ui/src/python/BUILD
heron/tools/ui/src/python/main.py
heronpy/api/bolt/base_bolt.py
heronpy/api/bolt/window_bolt.py
heronpy/api/component/component_spec.py
heronpy/api/metrics.py
heronpy/api/spout/base_spout.py
heronpy/api/stream.py
heronpy/api/tests/python/component_unittest.py
heronpy/api/tests/python/metrics_unittest.py
heronpy/api/topology.py
heronpy/connectors/mock/arraylooper.py
heronpy/connectors/pulsar/pulsarspout.py
heronpy/connectors/pulsar/pulsarstreamlet.py
heronpy/connectors/textfiles/textfilesgenerator.py
heronpy/streamlet/config.py
heronpy/streamlet/impl/consumebolt.py
heronpy/streamlet/impl/filterbolt.py
heronpy/streamlet/impl/flatmapbolt.py
heronpy/streamlet/impl/generatorspout.py
heronpy/streamlet/impl/joinbolt.py
heronpy/streamlet/impl/logbolt.py
heronpy/streamlet/impl/mapbolt.py
heronpy/streamlet/impl/reducebykeyandwindowbolt.py
heronpy/streamlet/impl/reducebywindowbolt.py
heronpy/streamlet/impl/repartitionbolt.py
heronpy/streamlet/impl/supplierspout.py
heronpy/streamlet/impl/transformbolt.py
heronpy/streamlet/impl/unionbolt.py
heronpy/streamlet/keyedwindow.py
heronpy/streamlet/resources.py
heronpy/streamlet/window.py
integration_test/src/python/http_server/main.py
integration_test/src/python/integration_test/common/bolt/count_aggregator_bolt.py
integration_test/src/python/integration_test/common/bolt/word_count_bolt.py
integration_test/src/python/integration_test/core/aggregator_bolt.py
integration_test/src/python/integration_test/core/integration_test_bolt.py
integration_test/src/python/integration_test/core/integration_test_spout.py
integration_test/src/python/integration_test/core/test_runner.py
integration_test/src/python/integration_test/core/test_topology_builder.py
integration_test/src/python/local_test_runner/main.py
integration_test/src/python/local_test_runner/test_kill_bolt.py
integration_test/src/python/local_test_runner/test_scale_up.py
integration_test/src/python/local_test_runner/test_template.py
integration_test/src/python/test_runner/main.py
integration_test/src/python/topology_test_runner/main.py
scripts/shutils/save-logs.py
third_party/python/pylint/BUILD
third_party/python/semver/semver.py
tools/java/src/org/apache/bazel/checkstyle/CppCheckstyle.java
tools/java/src/org/apache/bazel/cppcheck/CppCheck.java
tools/rules/pex/wrapper/pex_wrapper.py
website2/website/versioned_docs/version-0.20.0-incubating/user-manuals-tracker-rest.md