This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere-elasticjob.git
from 095643741 Merge pull request #2345 from terrymanu/dev
new 21faf7c48 Refactor package of kernel.internal
new a8ba44892 Refactor ElasticJobTracingConfiguration
new 4aa80b5b9 Merge pull request #2346 from terrymanu/dev
The 2408 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:
.../handler/dingtalk/DingtalkJobErrorHandler.java | 2 +-
.../DingtalkJobErrorHandlerPropertiesValidator.java | 2 +-
...job.kernel.executor.error.handler.JobErrorHandler} | 0
....error.handler.JobErrorHandlerPropertiesValidator} | 0
...ingtalkJobErrorHandlerPropertiesValidatorTest.java | 2 +-
.../handler/dingtalk/DingtalkJobErrorHandlerTest.java | 2 +-
.../error/handler/email/EmailJobErrorHandler.java | 2 +-
.../EmailJobErrorHandlerPropertiesValidator.java | 2 +-
...job.kernel.executor.error.handler.JobErrorHandler} | 0
....error.handler.JobErrorHandlerPropertiesValidator} | 0
.../EmailJobErrorHandlerPropertiesValidatorTest.java | 2 +-
.../error/handler/email/EmailJobErrorHandlerTest.java | 2 +-
.../error/handler/normal/IgnoreJobErrorHandler.java | 2 +-
.../error/handler/normal/LogJobErrorHandler.java | 2 +-
.../error/handler/normal/ThrowJobErrorHandler.java | 2 +-
...job.kernel.executor.error.handler.JobErrorHandler} | 0
.../handler/normal/IgnoreJobErrorHandlerTest.java | 2 +-
.../error/handler/normal/LogJobErrorHandlerTest.java | 2 +-
.../handler/normal/ThrowJobErrorHandlerTest.java | 2 +-
.../error/handler/wechat/WechatJobErrorHandler.java | 2 +-
.../WechatJobErrorHandlerPropertiesValidator.java | 2 +-
...job.kernel.executor.error.handler.JobErrorHandler} | 0
....error.handler.JobErrorHandlerPropertiesValidator} | 0
.../WechatJobErrorHandlerPropertiesValidatorTest.java | 2 +-
.../handler/wechat/WechatJobErrorHandlerTest.java | 2 +-
.../rdb/datasource/DataSourceConfiguration.java | 2 +-
.../datasource/DataSourceTracingStorageConverter.java | 6 +++---
.../tracing/rdb/listener/RDBTracingListener.java | 6 +++---
.../rdb/listener/RDBTracingListenerConfiguration.java | 6 +++---
.../tracing/rdb/storage/RDBJobEventStorage.java | 10 +++++-----
.../tracing/rdb/yaml/YamlDataSourceConfiguration.java | 4 ++--
.../yaml/YamlDataSourceConfigurationConverter.java | 4 ++--
...nel.tracing.listener.TracingListenerConfiguration} | 0
...ob.kernel.tracing.storage.TracingStorageConverter} | 0
.../DataSourceTracingStorageConverterTest.java | 6 +++---
.../listener/RDBTracingListenerConfigurationTest.java | 2 +-
.../tracing/rdb/listener/RDBTracingListenerTest.java | 12 ++++++------
.../tracing/rdb/storage/RDBJobEventStorageTest.java | 8 ++++----
.../YamlDataSourceConfigurationConverterTest.java | 2 +-
.../shardingsphere/elasticjob/example/JavaMain.java | 2 +-
.../{internal => }/executor/ElasticJobExecutor.java | 18 +++++++++---------
.../kernel/{internal => }/executor/ExecutionType.java | 2 +-
.../executor/error/handler/JobErrorHandler.java | 2 +-
.../handler/JobErrorHandlerPropertiesValidator.java | 2 +-
.../error/handler/JobErrorHandlerReloader.java | 2 +-
.../{internal => }/executor/facade/JobFacade.java | 12 ++++++------
.../executor/facade/JobJobRuntimeServiceImpl.java | 2 +-
.../executor/item/JobItemExecutorFactory.java | 2 +-
.../threadpool/ElasticJobExecutorService.java | 2 +-
.../executor/threadpool/ExecutorServiceReloader.java | 2 +-
.../threadpool/JobExecutorThreadPoolSizeProvider.java | 2 +-
.../CPUUsageJobExecutorThreadPoolSizeProvider.java | 4 ++--
...SingleThreadJobExecutorThreadPoolSizeProvider.java | 4 ++--
.../kernel/internal/context/TaskContext.java | 2 +-
.../kernel/internal/schedule/JobScheduler.java | 8 ++++----
.../elasticjob/kernel/internal/schedule/LiteJob.java | 2 +-
.../{internal => }/tracing/JobTracingEventBus.java | 10 +++++-----
.../tracing/api/TracingConfiguration.java | 6 +++---
.../tracing/api/TracingStorageConfiguration.java | 2 +-
.../kernel/{internal => }/tracing/event/JobEvent.java | 2 +-
.../tracing/event/JobExecutionEvent.java | 2 +-
.../tracing/event/JobStatusTraceEvent.java | 4 ++--
.../exception/TracingConfigurationException.java | 2 +-
.../TracingStorageConverterNotFoundException.java | 4 ++--
.../exception/TracingStorageUnavailableException.java | 2 +-
.../tracing/exception/WrapException.java | 2 +-
.../tracing/listener/TracingListener.java | 6 +++---
.../listener/TracingListenerConfiguration.java | 4 ++--
.../tracing/storage/TracingStorageConverter.java | 4 ++--
.../storage/TracingStorageConverterFactory.java | 2 +-
.../tracing/yaml/YamlTracingConfiguration.java | 6 +++---
.../yaml/YamlTracingConfigurationConverter.java | 6 +++---
.../tracing/yaml/YamlTracingStorageConfiguration.java | 6 +++---
...cutor.threadpool.JobExecutorThreadPoolSizeProvider | 3 ++-
...ernel.infra.yaml.config.YamlConfigurationConverter | 2 +-
...cutor.threadpool.JobExecutorThreadPoolSizeProvider | 19 -------------------
.../executor/ElasticJobExecutorTest.java | 12 ++++++------
.../error/handler/JobErrorHandlerReloaderTest.java | 6 +++---
.../handler/fixture/BarJobErrorHandlerFixture.java | 4 ++--
.../handler/fixture/FooJobErrorHandlerFixture.java | 4 ++--
.../{internal => }/executor/facade/JobFacadeTest.java | 4 ++--
.../executor/item/JobItemExecutorFactoryTest.java | 6 +++---
.../threadpool/ElasticJobExecutorServiceTest.java | 2 +-
.../threadpool/ExecutorServiceReloaderTest.java | 2 +-
...CPUUsageJobExecutorThreadPoolSizeProviderTest.java | 4 ++--
...leThreadJobExecutorThreadPoolSizeProviderTest.java | 4 ++--
.../kernel/internal/context/TaskContextTest.java | 2 +-
.../kernel/internal/context/fixture/TaskNode.java | 2 +-
.../kernel/internal/storage/JobNodeStorageTest.java | 2 +-
.../tracing/JobTracingEventBusTest.java | 12 ++++++------
.../tracing/event/JobExecutionEventTest.java | 2 +-
.../tracing/fixture/JobEventCaller.java | 2 +-
.../tracing/fixture/JobEventCallerConfiguration.java | 4 ++--
.../tracing/fixture/JobEventCallerConverter.java | 6 +++---
.../fixture/TestTracingFailureConfiguration.java | 10 +++++-----
.../tracing/fixture/TestTracingListener.java | 8 ++++----
.../fixture/TestTracingListenerConfiguration.java | 6 +++---
.../storage/TracingStorageConverterFactoryTest.java | 4 ++--
.../tracing/yaml/YamlJobEventCallerConfiguration.java | 8 ++++----
.../YamlJobEventCallerConfigurationConverter.java | 8 ++++----
.../yaml/YamlTracingConfigurationConverterTest.java | 6 +++---
...cjob.kernel.executor.error.handler.JobErrorHandler | 3 ++-
...ernel.infra.yaml.config.YamlConfigurationConverter | 2 +-
...el.internal.executor.error.handler.JobErrorHandler | 19 -------------------
...rnal.tracing.listener.TracingListenerConfiguration | 19 -------------------
...l.internal.tracing.storage.TracingStorageConverter | 18 ------------------
...rnel.tracing.listener.TracingListenerConfiguration | 3 ++-
...job.kernel.tracing.storage.TracingStorageConverter | 3 +--
.../boot/job/ElasticJobBootstrapConfiguration.java | 2 +-
.../boot/tracing/ElasticJobTracingConfiguration.java | 11 +++--------
.../spring/boot/job/ElasticJobSpringBootTest.java | 2 +-
.../spring/boot/tracing/TracingConfigurationTest.java | 2 +-
.../tracing/parser/TracingBeanDefinitionParser.java | 2 +-
113 files changed, 203 insertions(+), 281 deletions(-)
rename
ecosystem/error-handler/dingtalk/src/main/resources/META-INF/services/{org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
=>
org.apache.shardingsphere.elasticjob.kernel.executor.error.handler.JobErrorHandler}
(100%)
rename
ecosystem/error-handler/dingtalk/src/main/resources/META-INF/services/{org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandlerPropertiesValidator
=>
org.apache.shardingsphere.elasticjob.kernel.executor.error.handler.JobErrorHandlerPropertiesValidator}
(100%)
rename
ecosystem/error-handler/email/src/main/resources/META-INF/services/{org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
=>
org.apache.shardingsphere.elasticjob.kernel.executor.error.handler.JobErrorHandler}
(100%)
copy
ecosystem/error-handler/email/src/main/resources/META-INF/services/{org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandlerPropertiesValidator
=>
org.apache.shardingsphere.elasticjob.kernel.executor.error.handler.JobErrorHandlerPropertiesValidator}
(100%)
rename
ecosystem/error-handler/normal/src/main/resources/META-INF/services/{org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
=>
org.apache.shardingsphere.elasticjob.kernel.executor.error.handler.JobErrorHandler}
(100%)
copy
ecosystem/error-handler/wechat/src/main/resources/META-INF/services/{org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
=>
org.apache.shardingsphere.elasticjob.kernel.executor.error.handler.JobErrorHandler}
(100%)
rename
ecosystem/error-handler/wechat/src/main/resources/META-INF/services/{org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandlerPropertiesValidator
=>
org.apache.shardingsphere.elasticjob.kernel.executor.error.handler.JobErrorHandlerPropertiesValidator}
(100%)
rename
ecosystem/tracing/rdb/src/main/resources/META-INF/services/{org.apache.shardingsphere.elasticjob.kernel.internal.tracing.listener.TracingListenerConfiguration
=>
org.apache.shardingsphere.elasticjob.kernel.tracing.listener.TracingListenerConfiguration}
(100%)
rename
ecosystem/tracing/rdb/src/main/resources/META-INF/services/{org.apache.shardingsphere.elasticjob.kernel.internal.tracing.storage.TracingStorageConverter
=>
org.apache.shardingsphere.elasticjob.kernel.tracing.storage.TracingStorageConverter}
(100%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/ElasticJobExecutor.java (91%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/ExecutionType.java (93%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/error/handler/JobErrorHandler.java (93%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/error/handler/JobErrorHandlerPropertiesValidator.java (93%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/error/handler/JobErrorHandlerReloader.java (95%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/facade/JobFacade.java (94%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/facade/JobJobRuntimeServiceImpl.java (94%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/item/JobItemExecutorFactory.java (96%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/threadpool/ElasticJobExecutorService.java (96%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/threadpool/ExecutorServiceReloader.java (96%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/threadpool/JobExecutorThreadPoolSizeProvider.java (93%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/threadpool/type/CPUUsageJobExecutorThreadPoolSizeProvider.java (86%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/threadpool/type/SingleThreadJobExecutorThreadPoolSizeProvider.java
(84%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/JobTracingEventBus.java (88%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/api/TracingConfiguration.java (84%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/api/TracingStorageConfiguration.java (93%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/event/JobEvent.java (92%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/event/JobExecutionEvent.java (97%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/event/JobStatusTraceEvent.java (91%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/exception/TracingConfigurationException.java (93%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/exception/TracingStorageConverterNotFoundException.java (87%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/exception/TracingStorageUnavailableException.java (93%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/exception/WrapException.java (92%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/listener/TracingListener.java (84%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/listener/TracingListenerConfiguration.java (88%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/storage/TracingStorageConverter.java (88%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/storage/TracingStorageConverterFactory.java (95%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/yaml/YamlTracingConfiguration.java (83%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/yaml/YamlTracingConfigurationConverter.java (88%)
rename
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/yaml/YamlTracingStorageConfiguration.java (77%)
copy
ecosystem/error-handler/wechat/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
=>
kernel/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.executor.threadpool.JobExecutorThreadPoolSizeProvider
(77%)
delete mode 100644
kernel/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.threadpool.JobExecutorThreadPoolSizeProvider
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/ElasticJobExecutorTest.java (98%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/error/handler/JobErrorHandlerReloaderTest.java (92%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/error/handler/fixture/BarJobErrorHandlerFixture.java (84%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/error/handler/fixture/FooJobErrorHandlerFixture.java (86%)
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/{internal =>
}/executor/item/JobItemExecutorFactoryTest.java (96%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/threadpool/ElasticJobExecutorServiceTest.java (97%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/threadpool/ExecutorServiceReloaderTest.java (97%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/threadpool/type/CPUUsageJobExecutorThreadPoolSizeProviderTest.java
(86%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/executor/threadpool/type/SingleThreadJobExecutorThreadPoolSizeProviderTest.java
(86%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/JobTracingEventBusTest.java (84%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/event/JobExecutionEventTest.java (97%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/fixture/JobEventCaller.java (92%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/fixture/JobEventCallerConfiguration.java (87%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/fixture/JobEventCallerConverter.java (82%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/fixture/TestTracingFailureConfiguration.java (73%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/fixture/TestTracingListener.java (80%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/fixture/TestTracingListenerConfiguration.java (80%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/storage/TracingStorageConverterFactoryTest.java (89%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/yaml/YamlJobEventCallerConfiguration.java (77%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/yaml/YamlJobEventCallerConfigurationConverter.java (81%)
rename
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/{internal =>
}/tracing/yaml/YamlTracingConfigurationConverterTest.java (88%)
rename
ecosystem/error-handler/wechat/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
=>
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.executor.error.handler.JobErrorHandler
(79%)
delete mode 100644
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler
delete mode 100644
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.tracing.listener.TracingListenerConfiguration
delete mode 100644
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.tracing.storage.TracingStorageConverter
rename
ecosystem/error-handler/email/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandlerPropertiesValidator
=>
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.tracing.listener.TracingListenerConfiguration
(80%)
copy examples/elasticjob-example-java/src/main/resources/script/demo.sh =>
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.tracing.storage.TracingStorageConverter
(90%)
