You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by le...@apache.org on 2021/07/01 19:14:29 UTC
[gobblin] branch master updated (4b1d57f -> d5a85e3)
This is an automated email from the ASF dual-hosted git repository.
lesun pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git.
from 4b1d57f [GOBBLIN-1485]Enable feature to get schema from writer schema when do hive registration (#3324)
add d5a85e3 Add initial version of automatic troubleshooter (#3296)
No new revisions were added by this update.
Summary of changes:
gobblin-all/build.gradle | 1 +
.../gobblin/configuration/ConfigurationKeys.java | 28 ++-
.../gobblin/cluster/GobblinHelixJobLauncher.java | 3 +-
.../gobblin-troubleshooter}/build.gradle | 14 +-
.../AutoTroubleshooterLogAppender.java | 173 +++++++++++++++++++
.../AutomaticTroubleshooterImpl.java | 188 +++++++++++++++++++++
.../AutoTroubleshooterLogAppenderTest.java | 130 ++++++++++++++
.../AutomaticTroubleshooterTest.java | 121 +++++++++++++
gobblin-runtime/build.gradle | 1 +
.../gobblin/runtime/AbstractJobLauncher.java | 28 ++-
.../gobblin/runtime/GobblinMultiTaskAttempt.java | 41 ++++-
.../org/apache/gobblin/runtime/JobContext.java | 18 +-
.../java/org/apache/gobblin/runtime/TaskState.java | 49 +++++-
.../gobblin/runtime/TaskStateCollectorService.java | 47 +++++-
.../gobblin/runtime/ThrowableWithErrorCode.java | 17 +-
.../gobblin/runtime/mapreduce/MRJobLauncher.java | 22 ++-
.../troubleshooter/AutomaticTroubleshooter.java | 99 +++++++++++
.../AutomaticTroubleshooterConfig.java | 58 +++++++
.../AutomaticTroubleshooterFactory.java | 84 +++++++++
.../troubleshooter/DefaultIssueRefinery.java | 60 +++++++
.../troubleshooter/InMemoryIssueRepository.java | 111 ++++++++++++
.../gobblin/runtime/troubleshooter/Issue.java | 81 +++++++++
.../runtime/troubleshooter/IssueEventBuilder.java | 99 +++++++++++
.../runtime/troubleshooter/IssueRefinery.java | 14 +-
.../runtime/troubleshooter/IssueRepository.java | 63 +++++++
.../runtime/troubleshooter/IssueSeverity.java | 18 +-
.../NoopAutomaticTroubleshooter.java | 79 +++++++++
.../runtime/troubleshooter/NoopIssueRefinery.java | 12 +-
.../troubleshooter/NoopIssueRepository.java | 43 +++--
.../TroubleshooterException.java} | 20 ++-
.../{RuntimeConstructs.java => GsonUtils.java} | 34 ++--
.../apache/gobblin/runtime/DummyJobContext.java | 9 +-
.../runtime/TaskStateCollectorServiceTest.java | 7 +-
.../org/apache/gobblin/runtime/TaskStateTest.java | 30 +++-
.../AutomaticTroubleshooterConfigTest.java | 25 +--
.../AutomaticTroubleshooterFactoryTest.java | 52 ++++++
.../InMemoryIssueRepositoryTest.java | 128 ++++++++++++++
.../troubleshooter/IssueEventBuilderTest.java | 59 +++++++
gradle/scripts/dependencyDefinitions.gradle | 1 +
39 files changed, 1933 insertions(+), 134 deletions(-)
copy {gobblin-runtime-hadoop => gobblin-modules/gobblin-troubleshooter}/build.gradle (74%)
create mode 100644 gobblin-modules/gobblin-troubleshooter/src/main/java/org/apache/gobblin/troubleshooter/AutoTroubleshooterLogAppender.java
create mode 100644 gobblin-modules/gobblin-troubleshooter/src/main/java/org/apache/gobblin/troubleshooter/AutomaticTroubleshooterImpl.java
create mode 100644 gobblin-modules/gobblin-troubleshooter/src/test/java/org/apache/gobblin/troubleshooter/AutoTroubleshooterLogAppenderTest.java
create mode 100644 gobblin-modules/gobblin-troubleshooter/src/test/java/org/apache/gobblin/troubleshooter/AutomaticTroubleshooterTest.java
copy gobblin-api/src/main/java/org/apache/gobblin/runtime/JobShutdownException.java => gobblin-runtime/src/main/java/org/apache/gobblin/runtime/ThrowableWithErrorCode.java (71%)
create mode 100644 gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/AutomaticTroubleshooter.java
create mode 100644 gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/AutomaticTroubleshooterConfig.java
create mode 100644 gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/AutomaticTroubleshooterFactory.java
create mode 100644 gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/DefaultIssueRefinery.java
create mode 100644 gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/InMemoryIssueRepository.java
create mode 100644 gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/Issue.java
create mode 100644 gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/IssueEventBuilder.java
copy gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/KeyValuePusher.java => gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/IssueRefinery.java (73%)
create mode 100644 gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/IssueRepository.java
copy gobblin-core/src/main/java/org/apache/gobblin/source/extractor/exception/ExtractPrepareException.java => gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/IssueSeverity.java (71%)
create mode 100644 gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/NoopAutomaticTroubleshooter.java
copy gobblin-core/src/main/java/org/apache/gobblin/writer/ConsoleWriterBuilder.java => gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/NoopIssueRefinery.java (77%)
copy gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/SelectAllPolicy.java => gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/NoopIssueRepository.java (56%)
copy gobblin-runtime/src/main/java/org/apache/gobblin/runtime/{ForkException.java => troubleshooter/TroubleshooterException.java} (71%)
copy gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/{RuntimeConstructs.java => GsonUtils.java} (58%)
copy gobblin-modules/gobblin-compliance/src/test/java/org/apache/gobblin/compliance/purger/HivePurgerWriterTest.java => gobblin-runtime/src/test/java/org/apache/gobblin/runtime/troubleshooter/AutomaticTroubleshooterConfigTest.java (60%)
create mode 100644 gobblin-runtime/src/test/java/org/apache/gobblin/runtime/troubleshooter/AutomaticTroubleshooterFactoryTest.java
create mode 100644 gobblin-runtime/src/test/java/org/apache/gobblin/runtime/troubleshooter/InMemoryIssueRepositoryTest.java
create mode 100644 gobblin-runtime/src/test/java/org/apache/gobblin/runtime/troubleshooter/IssueEventBuilderTest.java