Repository: incubator-griffin Updated Branches: refs/heads/master 11ff412a5 -> 3922a90a8
fix license header Author: William Guo <[email protected]> Closes #404 from guoyuepeng/fix_service_header. Project: http://git-wip-us.apache.org/repos/asf/incubator-griffin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-griffin/commit/3922a90a Tree: http://git-wip-us.apache.org/repos/asf/incubator-griffin/tree/3922a90a Diff: http://git-wip-us.apache.org/repos/asf/incubator-griffin/diff/3922a90a Branch: refs/heads/master Commit: 3922a90a8aecfda84dbb5872fa7b844558c2075f Parents: 11ff412 Author: William Guo <[email protected]> Authored: Thu Aug 30 15:54:03 2018 +0800 Committer: William Guo <[email protected]> Committed: Thu Aug 30 15:54:03 2018 +0800 ---------------------------------------------------------------------- .../griffin/core/job/BatchJobOperatorImpl.java | 19 +++++ .../apache/griffin/core/job/entity/JobType.java | 19 +++++ .../griffin/core/job/repo/StreamingJobRepo.java | 19 +++++ .../resources/application-docker.properties | 76 ++++++++++++++++++++ .../core/job/FileExistPredicatorTest.java | 18 +++++ .../core/job/entity/JobScheduleTest.java | 18 +++++ 6 files changed, 169 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java ---------------------------------------------------------------------- diff --git a/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java b/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java index 5b2f816..0210822 100644 --- a/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java +++ b/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java @@ -1,3 +1,22 @@ +/* +Licensed to the Apache Software Foundation (ASF) under one +or more contributor license agreements. See the NOTICE file +distributed with this work for additional information +regarding copyright ownership. The ASF licenses this file +to you under the Apache License, Version 2.0 (the +"License"); you may not use this file except in compliance +with the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, +software distributed under the License is distributed on an +"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +KIND, either express or implied. See the License for the +specific language governing permissions and limitations +under the License. +*/ + package org.apache.griffin.core.job; import static org.apache.griffin.core.exception.GriffinExceptionMessage.INVALID_CONNECTOR_NAME; http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java ---------------------------------------------------------------------- diff --git a/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java b/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java index aa73c65..c76b0ee 100644 --- a/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java +++ b/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java @@ -1,3 +1,22 @@ +/* +Licensed to the Apache Software Foundation (ASF) under one +or more contributor license agreements. See the NOTICE file +distributed with this work for additional information +regarding copyright ownership. The ASF licenses this file +to you under the Apache License, Version 2.0 (the +"License"); you may not use this file except in compliance +with the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, +software distributed under the License is distributed on an +"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +KIND, either express or implied. See the License for the +specific language governing permissions and limitations +under the License. +*/ + package org.apache.griffin.core.job.entity; public enum JobType { http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java ---------------------------------------------------------------------- diff --git a/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java b/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java index a6b198b..866eed2 100644 --- a/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java +++ b/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java @@ -1,3 +1,22 @@ +/* +Licensed to the Apache Software Foundation (ASF) under one +or more contributor license agreements. See the NOTICE file +distributed with this work for additional information +regarding copyright ownership. The ASF licenses this file +to you under the Apache License, Version 2.0 (the +"License"); you may not use this file except in compliance +with the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, +software distributed under the License is distributed on an +"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +KIND, either express or implied. See the License for the +specific language governing permissions and limitations +under the License. +*/ + package org.apache.griffin.core.job.repo; import org.apache.griffin.core.job.entity.StreamingJob; http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/main/resources/application-docker.properties ---------------------------------------------------------------------- diff --git a/service/src/main/resources/application-docker.properties b/service/src/main/resources/application-docker.properties new file mode 100644 index 0000000..06e21b7 --- /dev/null +++ b/service/src/main/resources/application-docker.properties @@ -0,0 +1,76 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +# + +spring.datasource.url = jdbc:postgresql://10.148.215.23:35432/quartz?autoReconnect=true&useSSL=false +spring.datasource.username = griffin +spring.datasource.password = 123456 +spring.jpa.generate-ddl=true + +spring.datasource.driver-class-name = org.postgresql.Driver + +spring.jpa.show-sql = true + +# Hive metastore +hive.metastore.uris = thrift://10.148.215.23:39083 +hive.metastore.dbname = default +hive.hmshandler.retry.attempts = 15 +hive.hmshandler.retry.interval = 2000ms +# Hive cache time +cache.evict.hive.fixedRate.in.milliseconds = 900000 + +# Kafka schema registry +kafka.schema.registry.url = http://localhost:8081 + +# Update job instance state at regular intervals +jobInstance.fixedDelay.in.milliseconds = 60000 +# Expired time of job instance which is 7 days that is 604800000 milliseconds.Time unit only supports milliseconds +jobInstance.expired.milliseconds = 604800000 + +# schedule predicate job every 5 minutes and repeat 12 times at most +#interval time unit s:second m:minute h:hour d:day,only support these four units +predicate.job.interval = 5m +predicate.job.repeat.count = 12 + +# external properties directory location +external.config.location = + +# external BATCH or STREAMING env +external.env.location = + +# login strategy ("default" or "ldap") +login.strategy = default + +# ldap +ldap.url = ldap://hostname:port +ldap.email = @example.com +ldap.searchBase = DC=org,DC=example +ldap.searchPattern = (sAMAccountName={0}) + +# elasticsearch +elasticsearch.host = 10.148.215.23 +elasticsearch.port = 39200 +elasticsearch.scheme = http +# elasticsearch.user = user +# elasticsearch.password = password + +# livy +livy.uri=http://10.148.215.23:38998/batches + +# yarn url +yarn.uri=http://10.148.215.23:38088 http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java ---------------------------------------------------------------------- diff --git a/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java b/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java index af981e3..44adc6c 100644 --- a/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java +++ b/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java @@ -1,3 +1,21 @@ +/* +Licensed to the Apache Software Foundation (ASF) under one +or more contributor license agreements. See the NOTICE file +distributed with this work for additional information +regarding copyright ownership. The ASF licenses this file +to you under the Apache License, Version 2.0 (the +"License"); you may not use this file except in compliance +with the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, +software distributed under the License is distributed on an +"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +KIND, either express or implied. See the License for the +specific language governing permissions and limitations +under the License. +*/ package org.apache.griffin.core.job; import static org.junit.Assert.assertFalse; http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java ---------------------------------------------------------------------- diff --git a/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java b/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java index d90c405..2ac93b5 100644 --- a/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java +++ b/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java @@ -1,3 +1,21 @@ +/* +Licensed to the Apache Software Foundation (ASF) under one +or more contributor license agreements. See the NOTICE file +distributed with this work for additional information +regarding copyright ownership. The ASF licenses this file +to you under the Apache License, Version 2.0 (the +"License"); you may not use this file except in compliance +with the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, +software distributed under the License is distributed on an +"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +KIND, either express or implied. See the License for the +specific language governing permissions and limitations +under the License. +*/ package org.apache.griffin.core.job.entity;
