https://github.com/twitter/heron
Revision 5267285d84d2f1d74ae6e6fb15cf7b93cf542dfc authored by Maosong Fu on 16 November 2017, 01:49:29 UTC, committed by GitHub on 16 November 2017, 01:49:29 UTC
A lot of Twitter internal topology owners complained heron failing to kill an aurora topology because the Aurora service can be unavailable or unstable for a while, or it can sometimes provide a false negative response. This pull request adds retry mechanism to kill an Aurora topology with more confidence. It can increase the robustness of AuroraScheduler regardless of the Aurora Service People can also specify the retry attempts and interval via config. This pull request also re-format some coding-styles for RuntimeManagerRunner.java. Tested with actual Twitter distributed env.
1 parent 57e910f
- HEAD
- refs/heads/0.14.10-rc
- refs/heads/0.14.11-rc
- refs/heads/0.14.11-stmgr-debug
- refs/heads/0.14.12-rc
- refs/heads/0.14.6-rc
- refs/heads/0.14.7-rc
- refs/heads/0.14.7.1-rc
- refs/heads/0.14.7.2-rc
- refs/heads/0.14.7.3-rc
- refs/heads/0.14.8-rc
- refs/heads/0.14.9.1+heapprof+stat+newcap
- refs/heads/0.14.9.1-bound-mempool
- refs/heads/0.14.9.1-heapprof
- refs/heads/0.14.9.1-heapprof-max-heap
- refs/heads/0.14.9.1-heapprof-max-heap-with-cap
- refs/heads/0.14.9.1-heapprof-max-heap-with-cap-with-heap-check
- refs/heads/0.14.9.1-heapprof-no-force-new
- refs/heads/0.14.9.1-rc
- refs/heads/0.15.0-rc
- refs/heads/0.15.1.1-rc
- refs/heads/0.15.1.4-rc
- refs/heads/0.16.4-rc
- refs/heads/0.17.0.1-rc
- refs/heads/0.17.0.2-rc
- refs/heads/0.17.0.3-rc
- refs/heads/0.17.0.4-rc
- refs/heads/0.17.0.5-rc
- refs/heads/0.17.0.6-rc
- refs/heads/0.17.2.1-rc
- refs/heads/0.17.2.2-rc
- refs/heads/0.17.3.1-rc
- refs/heads/0.17.4.1-rc
- refs/heads/0.17.5.1-rc
- refs/heads/0.20.1-incubating
- refs/heads/0.20.4-incubating-rc1-arm64
- refs/heads/0.20.5-incubating-site-changes
- refs/heads/armadillojim-master-fix
- refs/heads/asf-site
- refs/heads/billg/state_manager_packing
- refs/heads/billg/tmaster_packing
- refs/heads/bk_uploader
- refs/heads/bugfix/base-url
- refs/heads/centos7-testing
- refs/heads/cwang/0.14.6.1-release
- refs/heads/cwang/backpressure
- refs/heads/cwang/heap-profiler
- refs/heads/cwang/mempool-debug
- refs/heads/cwang/outgoingpackets-debug
- refs/heads/cwang/protobuf3
- refs/heads/cwang/tuple-metrics
- refs/heads/dcos-support
- refs/heads/docs/0.15.0-release
- refs/heads/feature/arm64
- refs/heads/fix_groupings
- refs/heads/gh-pages
- refs/heads/helm-nodeport
- refs/heads/helm-update
- refs/heads/heron-ui-js-fix
- refs/heads/huijunw/exampletopoexclamation
- refs/heads/java_11_support
- refs/heads/jerrypeng-patch-1
- refs/heads/joshfischer-temp/0.20.3-incubating-rc8-site
- refs/heads/joshfischer/apache-content
- refs/heads/joshfischer/asf-site
- refs/heads/joshfischer/debian-container
- refs/heads/joshfischer/debian9
- refs/heads/joshfischer/fix-javadocs
- refs/heads/joshfischer/native-python-rules
- refs/heads/joshfischer/site-build-mods
- refs/heads/kanishk/ui-bp-metric
- refs/heads/karthik/alltargets
- refs/heads/karthik/appbuildtest
- refs/heads/karthik/appimage
- refs/heads/karthik/applatix-fix
- refs/heads/karthik/applatixchanges
- refs/heads/karthik/applatx
- refs/heads/karthik/appscripts
- refs/heads/karthik/aurora_fix
- refs/heads/karthik/bazel-cleanup
- refs/heads/karthik/bazel0.4.4
- refs/heads/karthik/bazel021
- refs/heads/karthik/bazel051
- refs/heads/karthik/binaryout
- refs/heads/karthik/bk_quickfix
- refs/heads/karthik/bookkeeper_emptydir
- refs/heads/karthik/bzldkrfix
- refs/heads/karthik/c++-packaging
- refs/heads/karthik/cerealrm
- refs/heads/karthik/certjava
- refs/heads/karthik/checkstyle_fix
- refs/heads/karthik/cicd
- refs/heads/karthik/cidocker
- refs/heads/karthik/cifix
- refs/heads/karthik/cifix2
- refs/heads/karthik/dfix
- refs/heads/karthik/dimages
- refs/heads/karthik/docimprov
- refs/heads/karthik/dockerdist
- refs/heads/karthik/dockersize
- refs/heads/karthik/dslfix
- refs/heads/karthik/dstartup
- refs/heads/karthik/dupdate
- refs/heads/karthik/ecofix
- refs/heads/karthik/exclude-scribe
- refs/heads/karthik/execfix
- refs/heads/karthik/fixdocker
- refs/heads/karthik/gflags
- refs/heads/karthik/gflagsrm
- refs/heads/karthik/gtestrm
- refs/heads/karthik/helmcharts
- refs/heads/karthik/helminstall
- refs/heads/karthik/helmupdate
- refs/heads/karthik/heronql
- refs/heads/karthik/hsandbox
- refs/heads/karthik/install
- refs/heads/karthik/installdirs
- refs/heads/karthik/installscripts
- refs/heads/karthik/itestscleanup
- refs/heads/karthik/libunwind-makeinstall
- refs/heads/karthik/mfixes
- refs/heads/karthik/mveco
- refs/heads/karthik/openjdk8
- refs/heads/karthik/pbuilds
- refs/heads/karthik/pdocker
- refs/heads/karthik/pexbuild
- refs/heads/karthik/pexinplace
- refs/heads/karthik/pexu
- refs/heads/karthik/promethus
- refs/heads/karthik/proto3
- refs/heads/karthik/protobuf3
- refs/heads/karthik/protobuf3.4
- refs/heads/karthik/protobufrm
- refs/heads/karthik/protoupgrade
- refs/heads/karthik/pullparams
- refs/heads/karthik/pypackaging
- refs/heads/karthik/pyreadme
- refs/heads/karthik/pyyaml
- refs/heads/karthik/reducepkgs
- refs/heads/karthik/retaincore
- refs/heads/karthik/rmtars
- refs/heads/karthik/rmyamlbinary
- refs/heads/karthik/sbconf
- refs/heads/karthik/scribe
- refs/heads/karthik/sdocker
- refs/heads/karthik/singledockerimage
- refs/heads/karthik/static
- refs/heads/karthik/stormjar
- refs/heads/karthik/tpfix
- refs/heads/karthik/travis-fix
- refs/heads/karthik/travisorg
- refs/heads/karthik/ugtest
- refs/heads/karthik/upgradepex
- refs/heads/karthik/xyz-yaml
- refs/heads/karthik/yaml-cpp-rm
- refs/heads/karthik/zooimage
- refs/heads/master
- refs/heads/mfu/add_stateful_config
- refs/heads/mfu/export_more_instance_metrics
- refs/heads/mfu/fix_checkstyle
- refs/heads/mfu/native_heron_api_example
- refs/heads/neng/clean-py-statemgr
- refs/heads/neng/downloader-deps
- refs/heads/neng/increase_max_runs
- refs/heads/neng/py3-migration
- refs/heads/neng/py3-upgrade
- refs/heads/neng/python3
- refs/heads/nicknezis/bookkeeper-upgrade
- refs/heads/nicknezis/mobile-website-fix
- refs/heads/nicknezis/netty-upgrade
- refs/heads/nicknezis/travis-update
- refs/heads/nicknezis/trykker-font-fix
- refs/heads/nwang/exclude_website_from_release
- refs/heads/objmagic/limit-msg-size
- refs/heads/objmagic/split-aurora-args
- refs/heads/objmagic/stmgr-heap-profiling
- refs/heads/python-3-upgrade
- refs/heads/real-time-io-redirection
- refs/heads/release-v-0.20.0-incubating-candidate-5
- refs/heads/release/0.17.8
- refs/heads/release/0.17.9
- refs/heads/release/0.20.1-incubating-rc1
- refs/heads/release/0.20.1-incubating-rc2
- refs/heads/release/0.20.3-incubating-rc8
- refs/heads/release/0.20.3-incubating-rc9
- refs/heads/release/0.20.3_incubating_rc1
- refs/heads/release/0.20.3_incubating_rc2
- refs/heads/release/0.20.3_incubating_rc3
- refs/heads/release/0.20.5-incubating
- refs/heads/release/v-0.20.0-incubating
- refs/heads/release/v0.20.1-incubating-rc1
- refs/heads/remove-scripts-centos-build-file
- refs/heads/revert-2311-rli/include-override-yaml
- refs/heads/revert-2624-lperkins/fix-website-asset-pipeline
- refs/heads/revert-3778-joshfischer/3774/pom-dependencies
- refs/heads/rli/include-override-yaml
- refs/heads/rli/java-decode-tracker
- refs/heads/roundrobin-improvement
- refs/heads/s3-uploader
- refs/heads/saadurrahman/3829-Deprecate-Apache-Aurora-dev
- refs/heads/saadurrahman/native-python-rules-phase1
- refs/heads/sanjeevk/emit_batch_size
- refs/heads/sanjeevk/encryption
- refs/heads/sanjeevk/ext1_protopool
- refs/heads/sanjeevk/fixtopo
- refs/heads/sanjeevk/full_proto3
- refs/heads/sanjeevk/makeglog_shared
- refs/heads/sanjeevk/moveto_tupleset2
- refs/heads/sanjeevk/python3fy
- refs/heads/sanjeevk/python_shading
- refs/heads/sanjeevk/python_updateworkspace
- refs/heads/sanjeevk/remove_unusedproto
- refs/heads/sanjeevk/upgrade_gflags
- refs/heads/sanjeevk/upgrade_pylint
- refs/heads/sanjeevk/use_statefulwindowing
- refs/heads/testing-after-cleaning
- refs/heads/tracker-conf
- refs/heads/ubuntu20.04-arm64
- refs/heads/ubuntu20.04-rpi-arm64
- refs/heads/v0.20.1-incubating-rc1
- refs/notes/release
- refs/notes/release-candidate
- refs/remotes/jrcrawfo/dcos-support
- refs/remotes/origin/helm-bookkeeper-fix
- refs/remotes/sijie/bk_uploader
- refs/tags/0.13.0-C
- refs/tags/0.13.1
- refs/tags/0.13.1-C
- refs/tags/0.13.2
- refs/tags/0.13.3
- refs/tags/0.13.4
- refs/tags/0.13.5
- refs/tags/0.13.6
- refs/tags/0.13.7
- refs/tags/0.14.0
- refs/tags/0.14.1
- refs/tags/0.14.11
- refs/tags/0.14.2
- refs/tags/0.14.3
- refs/tags/0.14.4
- refs/tags/0.14.5
- refs/tags/0.15.0
- refs/tags/0.15.0-rc1
- refs/tags/0.15.1
- refs/tags/0.15.2
- refs/tags/0.15.2rc1
- refs/tags/0.15.2rc2
- refs/tags/0.15.2rc3
- refs/tags/0.15.3
- refs/tags/0.15.3rc1
- refs/tags/0.16.0
- refs/tags/0.16.1
- refs/tags/0.16.2
- refs/tags/0.16.3
- refs/tags/0.16.4
- refs/tags/0.16.5
- refs/tags/0.17.0
- refs/tags/0.17.1
- refs/tags/0.17.2
- refs/tags/0.17.3
- refs/tags/0.17.4
- refs/tags/0.17.5
- refs/tags/0.17.7
- refs/tags/0.17.8
- refs/tags/0.17.9
- refs/tags/0.20.1-incubating-rc3
- refs/tags/0.20.2-incubating-rc1
- refs/tags/0.20.3-incubating-rc3-test2
- refs/tags/0.20.4-incubating-rc1
- refs/tags/0.20.5-incubating-rc1
- refs/tags/v-0.20.0-incubating
- refs/tags/v-0.20.0-incubating-candidate-1
- refs/tags/v-0.20.0-incubating-candidate-1-test
- refs/tags/v-0.20.0-incubating-candidate-1-test2
- refs/tags/v-0.20.0-incubating-candidate-2
- refs/tags/v-0.20.0-incubating-candidate-3
- refs/tags/v-0.20.0-incubating-candidate-4
- refs/tags/v-0.20.0-incubating-candidate-5
- 5267285d84d2f1d74ae6e6fb15cf7b93cf542dfc
- v0.20.1-incubating-rc1
- snapshot_2019_08_21
- nwang/0.20.1-incubating-rc2-test
- heron-spi-0.20.3-incubating
- exclude_website
- build_test
- 0.21.2-incubating-line
- 0.21.1-incubating-rc2-line
- 0.20.5-incubating-rc4
- 0.20.5-incubating-rc3
- 0.20.5-incubating-rc2
- 0.20.5-incubating-rc1-20220214
- 0.20.4-incubating-rc2-line
- 0.20.4-incubating-rc1-line
- 0.20.4-incubating-rc1-20210601
- 0.20.4-incubaging-rc1-20210614
- 0.20.3-incubating-rc9
- 0.20.3-incubating-rc8
- 0.20.3-incubating-rc7-line
- 0.20.3-incubating-rc7
- 0.20.3-incubating-rc6
- 0.20.3-incubating-rc5
- 0.20.3-incubating-rc4
- 0.20.3-incubating-rc3-test3
- 0.20.3-incubating-rc3-test
- 0.20.3-incubating-rc3-line
- 0.20.3-incubating-rc3
- 0.20.3-incubating-rc2
- 0.20.3-incubating-rc1
- 0.20.3-incubating-line
- 0.20.3-incubaging-rc7-line
- 0.20.2-incubating-line
- 0.20.1-incubating-rc2-valgrind
- 0.20.1-incubating-rc2
- 0.20.1-incubating-line
- 0.20.1-incubating-dmitry-rc2
- 0.20.1-incubating
- 0.19.0.9
- 0.19.0.8
- 0.19.0.7
- 0.19.0.6
- 0.19.0.5
- 0.19.0.4
- 0.19.0.3
- 0.19.0.2
- 0.19.0.16
- 0.19.0.15
- 0.19.0.14
- 0.19.0.13
- 0.19.0.12
- 0.19.0.11
- 0.19.0.10
- 0.19.0.1
- 0.18.0.3
- 0.18.0.2
- 0.18.0.1-tw-1
- 0.18.0.1
- 0.17.8.9
- 0.17.8.8
- 0.17.8.7
- 0.17.8.6
- 0.17.8.5
- 0.17.8.4
- 0.17.8.3
- 0.17.8.2
- 0.17.8.11
- 0.17.8.10
- 0.17.8.1-tw-1
- 0.17.8.1
- 0.17.6
- 0.17.5.1
- 0.17.4.1
- 0.17.3.1
- 0.17.2.2
- 0.17.2.1
- 0.17.0.6
- 0.17.0.5
- 0.17.0.4
- 0.17.0.3
- 0.17.0.2
- 0.17.0.1
- 0.16.5.3
- 0.16.5.2
- 0.16.5.1
- 0.16.4.3
- 0.16.4.2
- 0.16.4.1
- 0.16.0.1
- 0.15.1.5
- 0.15.1.4
- 0.15.1.3
- 0.15.1.2
- 0.15.1.1
- 0.14.9.1
- 0.14.9
- 0.14.8
- 0.14.7.3
- 0.14.7.2
- 0.14.7.1
- 0.14.7
- 0.14.6.3
- 0.14.6.2
- 0.14.6.1
- 0.14.6
- 0.14.12
- 0.14.10
History 
Cook and download a directory from the Software Heritage Vault
You have requested the cooking of the directory with identifier swh:1:dir:f1a2a115aafb89efa47ab8c6ec529040cd845925 into a standard tar.gz archive.
Are you sure you want to continue ?
Download a directory from the Software Heritage Vault
You have requested the download of the directory with identifier swh:1:dir:f1a2a115aafb89efa47ab8c6ec529040cd845925 as a standard tar.gz archive.
Are you sure you want to continue ?
Cook and download a revision from the Software Heritage Vault
You have requested the cooking of the history heading to revision with identifier swh:1:rev:5267285d84d2f1d74ae6e6fb15cf7b93cf542dfc into a bare git archive.
Are you sure you want to continue ?
Download a revision from the Software Heritage Vault
You have requested the download of the history heading to revision with identifier swh:1:rev:5267285d84d2f1d74ae6e6fb15cf7b93cf542dfc as a bare git archive.
Are you sure you want to continue ?
Invalid Email !
The provided email is not well-formed.
Download link has expired
The requested archive is no longer available for download from the Software Heritage Vault.
Do you want to cook it again ?
Take a new snapshot of a software origin
If the archived software origin currently browsed is not synchronized with its upstream version (for instance when new commits have been issued), you can explicitly request Software Heritage to take a new snapshot of it.
Use the form below to proceed. Once a request has been submitted and accepted, it will be processed as soon as possible. You can then check its processing state by visiting this dedicated page. Processing "take a new snapshot" request ...
Permalinks
To reference or cite the objects present in the Software Heritage archive, permalinks based on SoftWare Hash IDentifiers (SWHIDs) must be used.
Select below a type of object currently browsed in order to display its associated SWHID and permalink.
Tip revision: 5267285d84d2f1d74ae6e6fb15cf7b93cf542dfc authored by Maosong Fu on 16 November 2017, 01:49:29 UTC
Retry when failing to kill an Aurora topology (#2554)
Retry when failing to kill an Aurora topology (#2554)
Tip revision: 5267285
| File | Mode | Size |
|---|---|---|
| config | ||
| deploy | ||
| docker | ||
| examples | ||
| heron | ||
| heronpy | ||
| integration_test | ||
| release | ||
| scripts | ||
| storm-compatibility | ||
| storm-compatibility-examples | ||
| third_party | ||
| tools | ||
| vagrant | ||
| website | ||
| .gitignore | -rw-r--r-- | 1.9 KB |
| .gitmodules | -rw-r--r-- | 115 bytes |
| .travis.yml | -rw-r--r-- | 955 bytes |
| ADOPTERS.md | -rw-r--r-- | 538 bytes |
| CONTRIBUTING.md | l--------- | 46 bytes |
| LICENSE | -rw-r--r-- | 11.1 KB |
| NOTICE | -rw-r--r-- | 270 bytes |
| README.md | -rw-r--r-- | 1.9 KB |
| WORKSPACE | -rw-r--r-- | 16.2 KB |
| bazel_configure.py | -rwxr-xr-x | 14.9 KB |
The diff you're trying to view is too large. Only the first 1000 changed files have been loaded.
Computing file changes ...
