| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/ |
| H A D | TaskImpl.java | 129 private TaskAttemptId commitAttempt; field in TaskImpl
568 if (commitAttempt != null) { in canCommit()
569 canCommit = taskAttemptID.equals(commitAttempt); in canCommit()
741 task.commitAttempt = null; in unSucceed()
915 if (task.commitAttempt == null) { in transition()
917 task.commitAttempt = attemptID; in transition()
922 LOG.info(task.commitAttempt in transition()
973 if ((task.commitAttempt != null) && (task.commitAttempt == taskAttemptId)) { in transition()
974 task.commitAttempt = null; in transition()
1043 if (taskAttemptId.equals(task.commitAttempt)) { in transition()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/job/impl/ |
| H A D | TestTaskImpl.java | 499 TaskAttemptId commitAttempt = getLastAttempt().getAttemptId(); in testKillDuringTaskAttemptCommit() local
501 killRunningTaskAttempt(commitAttempt); in testKillDuringTaskAttemptCommit()
503 assertFalse(mockTask.canCommit(commitAttempt)); in testKillDuringTaskAttemptCommit()
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 392 func (cs *clientStream) commitAttempt() { func
519 cs.commitAttempt()
576 cs.commitAttempt()
|
| /dports/www/fabio/fabio-1.5.14/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 392 func (cs *clientStream) commitAttempt() { func
519 cs.commitAttempt()
576 cs.commitAttempt()
|
| /dports/www/fabio/fabio-1.5.14/vendor/google.golang.org/grpc/grpc-go-1.16.0/ |
| H A D | stream.go | 392 func (cs *clientStream) commitAttempt() { func
519 cs.commitAttempt()
576 cs.commitAttempt()
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 392 func (cs *clientStream) commitAttempt() { func
519 cs.commitAttempt()
576 cs.commitAttempt()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 392 func (cs *clientStream) commitAttempt() { func
519 cs.commitAttempt()
576 cs.commitAttempt()
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/consul/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 392 func (cs *clientStream) commitAttempt() { func
519 cs.commitAttempt()
576 cs.commitAttempt()
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/vault/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 392 func (cs *clientStream) commitAttempt() { func
519 cs.commitAttempt()
576 cs.commitAttempt()
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 437 func (cs *clientStream) commitAttempt() { func
561 cs.commitAttempt()
632 cs.commitAttempt()
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 458 func (cs *clientStream) commitAttempt() { func
592 cs.commitAttempt()
663 cs.commitAttempt()
|
| /dports/security/lego/lego-4.5.3/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 455 func (cs *clientStream) commitAttempt() { func
579 cs.commitAttempt()
650 cs.commitAttempt()
|
| /dports/security/vault/vault-1.8.2/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 454 func (cs *clientStream) commitAttempt() { func
578 cs.commitAttempt()
649 cs.commitAttempt()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 455 func (cs *clientStream) commitAttempt() { func
579 cs.commitAttempt()
650 cs.commitAttempt()
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 429 func (cs *clientStream) commitAttempt() { func
553 cs.commitAttempt()
624 cs.commitAttempt()
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 455 func (cs *clientStream) commitAttempt() { func
579 cs.commitAttempt()
650 cs.commitAttempt()
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/cli/cli-20.10.2/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 455 func (cs *clientStream) commitAttempt() { func
579 cs.commitAttempt()
650 cs.commitAttempt()
|
| /dports/sysutils/helmfile/vault-f6547fa8e820/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 455 func (cs *clientStream) commitAttempt() { func
579 cs.commitAttempt()
650 cs.commitAttempt()
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 455 func (cs *clientStream) commitAttempt() { func
579 cs.commitAttempt()
650 cs.commitAttempt()
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 455 func (cs *clientStream) commitAttempt() { func
579 cs.commitAttempt()
650 cs.commitAttempt()
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 455 func (cs *clientStream) commitAttempt() { func
579 cs.commitAttempt()
650 cs.commitAttempt()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-jwt/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 454 func (cs *clientStream) commitAttempt() { func
578 cs.commitAttempt()
649 cs.commitAttempt()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-gcp/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 437 func (cs *clientStream) commitAttempt() { func
561 cs.commitAttempt()
632 cs.commitAttempt()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-gcpkms/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 437 func (cs *clientStream) commitAttempt() { func
561 cs.commitAttempt()
632 cs.commitAttempt()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-kv/vendor/google.golang.org/grpc/ |
| H A D | stream.go | 437 func (cs *clientStream) commitAttempt() { func
561 cs.commitAttempt()
632 cs.commitAttempt()
|