This is an automated email from the ASF dual-hosted git repository.
panjuan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere-elasticjob.git
from 922b04386 Move TimeService to infra package (#2344)
new dfaa33dd9 Move ExecutionType to executor package
new 3cfd9209b Move util to infra package
new dc0b75fc9 Refactor error-handler
new 16e55486f Refactor error-handler
new f034a23e4 Move package of JobFacade
new 49d58dd98 Add elasticjob-error-handler-normal module
new 6c796462a Fix test cases
new 095643741 Merge pull request #2345 from terrymanu/dev
The 2405 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
bootstrap/pom.xml | 5 ++++
bootstrap/src/test/resources/logback-test.xml | 5 ----
.../error-handler/{type => }/dingtalk/pom.xml | 2 +-
.../handler/dingtalk/DingtalkJobErrorHandler.java | 0
...DingtalkJobErrorHandlerPropertiesValidator.java | 0
.../dingtalk/DingtalkPropertiesConstants.java | 0
...internal.executor.error.handler.JobErrorHandler | 0
...rror.handler.JobErrorHandlerPropertiesValidator | 0
...talkJobErrorHandlerPropertiesValidatorTest.java | 0
.../dingtalk/DingtalkJobErrorHandlerTest.java | 0
.../fixture/DingtalkInternalController.java | 0
.../dingtalk/src/test/resources/logback-test.xml | 0
ecosystem/error-handler/{type => }/email/pom.xml | 2 +-
.../error/handler/email/EmailJobErrorHandler.java | 0
.../EmailJobErrorHandlerPropertiesValidator.java | 0
.../handler/email/EmailPropertiesConstants.java | 0
...internal.executor.error.handler.JobErrorHandler | 0
...rror.handler.JobErrorHandlerPropertiesValidator | 0
...mailJobErrorHandlerPropertiesValidatorTest.java | 0
.../handler/email/EmailJobErrorHandlerTest.java | 0
.../email/src/test/resources/logback-test.xml | 0
.../simple => error-handler/normal}/pom.xml | 7 ++---
.../handler/normal}/IgnoreJobErrorHandler.java | 2 +-
.../error/handler/normal}/LogJobErrorHandler.java | 2 +-
.../handler/normal}/ThrowJobErrorHandler.java | 4 +--
...internal.executor.error.handler.JobErrorHandler | 4 ++-
.../handler/normal}/IgnoreJobErrorHandlerTest.java | 2 +-
.../handler/normal}/LogJobErrorHandlerTest.java | 2 +-
.../handler/normal}/ThrowJobErrorHandlerTest.java | 4 +--
.../normal}/src/test/resources/logback-test.xml | 7 +++--
ecosystem/error-handler/pom.xml | 5 +++-
ecosystem/error-handler/type/pom.xml | 34 ----------------------
ecosystem/error-handler/{type => }/wechat/pom.xml | 2 +-
.../handler/wechat/WechatJobErrorHandler.java | 0
.../WechatJobErrorHandlerPropertiesValidator.java | 0
.../handler/wechat/WechatPropertiesConstants.java | 0
...internal.executor.error.handler.JobErrorHandler | 0
...rror.handler.JobErrorHandlerPropertiesValidator | 0
...chatJobErrorHandlerPropertiesValidatorTest.java | 0
.../handler/wechat/WechatJobErrorHandlerTest.java | 0
.../wechat/fixture/WechatInternalController.java | 0
.../wechat/src/test/resources/logback-test.xml | 0
.../tracing/rdb/storage/RDBJobEventStorage.java | 2 +-
.../rdb/listener/RDBTracingListenerTest.java | 2 +-
.../rdb/storage/RDBJobEventStorageTest.java | 2 +-
.../{internal => infra}/util/BlockUtils.java | 2 +-
.../util/SensitiveInfoUtils.java | 2 +-
.../kernel/internal/context/TaskContext.java | 2 +-
.../kernel/internal/election/LeaderService.java | 2 +-
.../internal/executor/ElasticJobExecutor.java | 1 +
.../executor}/ExecutionType.java | 2 +-
.../internal/executor/{ => facade}/JobFacade.java | 2 +-
.../{ => facade}/JobJobRuntimeServiceImpl.java | 2 +-
.../kernel/internal/schedule/JobScheduler.java | 2 +-
.../kernel/internal/server/ServerService.java | 2 +-
.../kernel/internal/sharding/ShardingService.java | 2 +-
.../kernel/internal/snapshot/SnapshotService.java | 2 +-
.../tracing/event/JobStatusTraceEvent.java | 2 +-
.../AbstractDistributeOnceElasticJobListener.java | 2 +-
.../util/SensitiveInfoUtilsTest.java | 2 +-
.../kernel/internal/context/TaskContextTest.java | 2 +-
.../kernel/internal/context/fixture/TaskNode.java | 2 +-
.../internal/executor/ElasticJobExecutorTest.java | 3 +-
.../error/handler/JobErrorHandlerReloaderTest.java | 23 +++++++--------
.../fixture/BarJobErrorHandlerFixture.java} | 9 ++----
.../fixture/FooJobErrorHandlerFixture.java} | 11 +++----
.../executor/{ => facade}/JobFacadeTest.java | 10 +++----
.../DistributeOnceElasticJobListenerTest.java | 6 ++--
.../listener/fixture/ElasticJobListenerCaller.java | 2 +-
.../TestDistributeOnceElasticJobListener.java | 2 +-
.../listener/fixture/TestElasticJobListener.java | 2 +-
...internal.executor.error.handler.JobErrorHandler | 5 ++--
...here.elasticjob.spi.listener.ElasticJobListener | 4 +--
kernel/src/test/resources/logback-test.xml | 5 ----
.../src/test/resources/META-INF/logback-test.xml | 2 +-
.../namespace/src/test/resources/logback-test.xml | 2 +-
test/e2e/src/test/resources/logback-test.xml | 5 ----
77 files changed, 88 insertions(+), 131 deletions(-)
rename ecosystem/error-handler/{type => }/dingtalk/pom.xml (97%)
rename ecosystem/error-handler/{type =>
}/dingtalk/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/dingtalk/DingtalkJobErrorHandler.java
(100%)
rename ecosystem/error-handler/{type =>
}/dingtalk/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/dingtalk/DingtalkJobErrorHandlerPropertiesValidator.java
(100%)
rename ecosystem/error-handler/{type =>
}/dingtalk/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/dingtalk/DingtalkPropertiesConstants.java
(100%)
rename ecosystem/error-handler/{type =>
}/dingtalk/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
(100%)
rename ecosystem/error-handler/{type =>
}/dingtalk/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandlerPropertiesValidator
(100%)
rename ecosystem/error-handler/{type =>
}/dingtalk/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/dingtalk/DingtalkJobErrorHandlerPropertiesValidatorTest.java
(100%)
rename ecosystem/error-handler/{type =>
}/dingtalk/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/dingtalk/DingtalkJobErrorHandlerTest.java
(100%)
rename ecosystem/error-handler/{type =>
}/dingtalk/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/dingtalk/fixture/DingtalkInternalController.java
(100%)
rename ecosystem/error-handler/{type =>
}/dingtalk/src/test/resources/logback-test.xml (100%)
rename ecosystem/error-handler/{type => }/email/pom.xml (96%)
rename ecosystem/error-handler/{type =>
}/email/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/email/EmailJobErrorHandler.java
(100%)
rename ecosystem/error-handler/{type =>
}/email/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/email/EmailJobErrorHandlerPropertiesValidator.java
(100%)
rename ecosystem/error-handler/{type =>
}/email/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/email/EmailPropertiesConstants.java
(100%)
rename ecosystem/error-handler/{type =>
}/email/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
(100%)
rename ecosystem/error-handler/{type =>
}/email/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandlerPropertiesValidator
(100%)
rename ecosystem/error-handler/{type =>
}/email/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/email/EmailJobErrorHandlerPropertiesValidatorTest.java
(100%)
rename ecosystem/error-handler/{type =>
}/email/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/email/EmailJobErrorHandlerTest.java
(100%)
rename ecosystem/error-handler/{type =>
}/email/src/test/resources/logback-test.xml (100%)
copy ecosystem/{executor/simple => error-handler/normal}/pom.xml (90%)
copy
{kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/general
=>
ecosystem/error-handler/normal/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/normal}/IgnoreJobErrorHandler.java
(92%)
rename
{kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/general
=>
ecosystem/error-handler/normal/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/normal}/LogJobErrorHandler.java
(93%)
copy
{kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/general
=>
ecosystem/error-handler/normal/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/normal}/ThrowJobErrorHandler.java
(93%)
copy ecosystem/error-handler/{type/wechat =>
normal}/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
(78%)
rename
{kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/general
=>
ecosystem/error-handler/normal/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/normal}/IgnoreJobErrorHandlerTest.java
(93%)
rename
{kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/general
=>
ecosystem/error-handler/normal/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/normal}/LogJobErrorHandlerTest.java
(96%)
rename
{kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/general
=>
ecosystem/error-handler/normal/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/normal}/ThrowJobErrorHandlerTest.java
(94%)
copy {registry-center/provider/zookeeper-curator =>
ecosystem/error-handler/normal}/src/test/resources/logback-test.xml (83%)
delete mode 100644 ecosystem/error-handler/type/pom.xml
rename ecosystem/error-handler/{type => }/wechat/pom.xml (97%)
rename ecosystem/error-handler/{type =>
}/wechat/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/wechat/WechatJobErrorHandler.java
(100%)
rename ecosystem/error-handler/{type =>
}/wechat/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/wechat/WechatJobErrorHandlerPropertiesValidator.java
(100%)
rename ecosystem/error-handler/{type =>
}/wechat/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/wechat/WechatPropertiesConstants.java
(100%)
rename ecosystem/error-handler/{type =>
}/wechat/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
(100%)
rename ecosystem/error-handler/{type =>
}/wechat/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandlerPropertiesValidator
(100%)
rename ecosystem/error-handler/{type =>
}/wechat/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/wechat/WechatJobErrorHandlerPropertiesValidatorTest.java
(100%)
rename ecosystem/error-handler/{type =>
}/wechat/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/wechat/WechatJobErrorHandlerTest.java
(100%)
rename ecosystem/error-handler/{type =>
}/wechat/src/test/java/org/apache/shardingsphere/elasticjob/error/handler/wechat/fixture/WechatInternalController.java
(100%)
rename ecosystem/error-handler/{type =>
}/wechat/src/test/resources/logback-test.xml (100%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
infra}/util/BlockUtils.java (95%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
infra}/util/SensitiveInfoUtils.java (97%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{infra/constant
=> internal/executor}/ExecutionType.java (93%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/{
=> facade}/JobFacade.java (99%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/{
=> facade}/JobJobRuntimeServiceImpl.java (98%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
infra}/util/SensitiveInfoUtilsTest.java (96%)
rename
kernel/src/{main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/general/IgnoreJobErrorHandler.java
=>
test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/fixture/BarJobErrorHandlerFixture.java}
(86%)
rename
kernel/src/{main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/general/ThrowJobErrorHandler.java
=>
test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/error/handler/fixture/FooJobErrorHandlerFixture.java}
(88%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/{
=> facade}/JobFacadeTest.java (98%)
rename kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{api
=> }/listener/DistributeOnceElasticJobListenerTest.java (95%)
rename kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{api
=> }/listener/fixture/ElasticJobListenerCaller.java (92%)
rename kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{api
=> }/listener/fixture/TestDistributeOnceElasticJobListener.java (95%)
rename kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{api
=> }/listener/fixture/TestElasticJobListener.java (96%)
rename kernel/src/{main =>
test}/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
(83%)
