This is my application config > taskexecutor.threadpool.size=2
taskretry.threadpool.coresize=1
taskretry.threadpool.maxsize=2
fs.uri=hdfs://ip:8020
writer.fs.uri=hdfs://ip:8020
state.store.fs.uri=hdfs://ip:8020writer.output.format=AVRO
writer.staging.dir=${env:GOBBLIN_WORK_DIR}/task-staging
writer.output.dir=${env:GOBBLIN_WORK_DIR}/task-outputdata.publisher.type=org.apache.gobblin.publisher.BaseDataPublisher
data.publisher.final.dir=${env:GOBBLIN_WORK_DIR}/job-output
data.publisher.replace.final.dir=falsejobconf.dir=${env:GOBBLIN_JOB_CONFIG_DIR}
jobconf.fullyQualifiedPath=file://${env:GOBBLIN_JOB_CONFIG_DIR}state.store.dir=${env:GOBBLIN_WORK_DIR}/state-store
task.data.root.dir=${env:GOBBLIN_WORK_DIR}/task
gobblin.runtime.commit.sequence.store.dir=${env:GOBBLIN_WORK_DIR}/commit-sequence-storequalitychecker.row.err.file=${env:GOBBLIN_WORK_DIR}/err
job.lock.dir=${env:GOBBLIN_WORK_DIR}/locks
metrics.log.dir=${env:GOBBLIN_WORK_DIR}/metrics
metrics.enabled=true
admin.server.enabled=true
admin.server.port=9000rest.server.host=localhost
rest.server.port=9090
job.execinfo.server.enabled=false
job.history.store.enabled=false
task.status.reportintervalinms=5000
jobconf.monitor.interval=30000
@vikrambohra this is my job configuration :- job.name=GobblinPushToExternalTest
job.description=Gobblin job for pushing data to S3
data.publisher.final.dir=finaldest
gobblin.dataset.profile.class=gobblin.data.management.copy.CopyableGlobDatasetFinder
gobblin.dataset.pattern=/sagar/*
fs.s3a.impl=org.apache.hadoop.fs.s3a.S3AFileSystem
writer.encrypted.fs.s3a.access.key=key
writer.encrypted.fs.s3a.secret.key=value/3yIJ3lmrpx2
fs.s3a.buffer.dir=/tmp/distcp-buffer-dir
writer.fs.uri=s3a://my-bucket-30aug
gobblin.copy.recursive.update=true
type=hadoopJava
job.class=gobblin.azkaban.AzkabanJobLauncher
extract.namespace=gobblin.copy
source.class=gobblin.data.management.copy.CopySource
converter.classes=gobblin.converter.IdentityConverter
writer.builder.class=gobblin.data.management.copy.writer.FileAwareInputStreamDataWriterBuilder
data.publisher.type=gobblin.data.management.copy.publisher.CopyDataPublisher
distcp.persist.dir=/tmp/distcp-persist-dir
task.maxretries=0
workunit.retry.enabled=false
work.dir=/tmp/
state.store.dir=${work.dir}/state-store
writer.staging.dir=${work.dir}/taskStaging
writer.output.dir=${work.dir}
bin/gobblin cli run distcp /Users/vbohra/gobblin_work_dir/from /Users/vbohra/gobblin_work_dir/to
2020-11-18 13:46:21 CET ERROR [HiveMetaStoreBasedRegister] org.apache.thrift.transport.TSaslTransport - SASL negotiation failure
javax.security.sasl.SaslException: GSS initiate failed [Caused by GSSException: No valid credentials provided (Mechanism level: Failed to find any Kerberos tgt)]
at com.sun.security.sasl.gsskerb.GssKrb5Client.evaluateChallenge(GssKrb5Client.java:211)
at org.apache.thrift.transport.TSaslClientTransport.handleSaslStartMessage(TSaslClientTransport.java:94)
at org.apache.thrift.transport.TSaslTransport.open(TSaslTransport.java:271)
at org.apache.thrift.transport.TSaslClientTransport.open(TSaslClientTransport.java:37)
at org.apache.hadoop.hive.thrift.client.TUGIAssumingTransport$1.run(TUGIAssumingTransport.java:52)
at org.apache.hadoop.hive.thrift.client.TUGIAssumingTransport$1.run(TUGIAssumingTransport.java:49)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1920)
at org.apache.hadoop.hive.thrift.client.TUGIAssumingTransport.open(TUGIAssumingTransport.java:49)
at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.open(HiveMetaStoreClient.java:472)
at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.<init>(HiveMetaStoreClient.java:252)
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:408)
at org.apache.hadoop.hive.metastore.MetaStoreUtils.newInstance(MetaStoreUtils.java:1560)
at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.<init>(RetryingMetaStoreClient.java:67)
at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:82)
at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:73)
at org.apache.gobblin.hive.HiveMetaStoreClientFactory.createMetaStoreClient(HiveMetaStoreClientFactory.java:103)
at org.apache.gobblin.hive.HiveMetaStoreClientFactory.create(HiveMetaStoreClientFactory.java:109)
at org.apache.gobblin.hive.HiveMetaStoreClientFactory.create(HiveMetaStoreClientFactory.java:55)
at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:60)
at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:868)
at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:435)
at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:363)
at org.apache.gobblin.util.AutoReturnableObject.<init>(AutoReturnableObject.java:38)
at org.apache.gobblin.hive.HiveMetastoreClientPool.getClient(HiveMetastoreClientPool.java:135)
at org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister.registerPath(HiveMetaStoreBasedRegister.java:138)
at org.apache.gobblin.hive.HiveRegister$1.call(HiveRegister.java:113)
at org.apache.gobblin.hive.HiveRegister$1.call(HiveRegister.java:97)
at org.apache.gobblin.util.executors.MDCPropagatingCallable.call(MDCPropagatingCallable.java:42)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: GSSException: No valid credentials provided (Mechanism level: Failed to find any Kerberos tgt)
at sun.security.jgss.krb5.Krb5InitCredential.getInstance(Krb5InitCredential.java:147)
at sun.security.jgss.krb5.Krb5MechFactory.getCredentialElement(Krb5MechFactory.java:122)
at sun.security.jgss.krb5.Krb5MechFactory.getMechanismContext(Krb5MechFactory.java:187)
at sun.security.jgss.GSSManagerImpl.getMechanismContext(GSSManagerImpl.java:224)
at sun.security.jgss.GSSContextImpl.initSecContext(GSSConte
Hi i am starting with gobblin on build ( gradlew build -x findbugsMain -x test -x rat -x checkstyleMain ) I get Could not compile build file 'C:\Users\i.g\IdeaProjects\incubator-gobblin\gobblin-restli\gobblin-throttling-service\gobblin-throttling-service-server\build.gradle'.
startup failed:
build file 'C:\Users\i.g\IdeaProjects\incubator-gobblin\gobblin-restli\gobblin-throttling-service\gobblin-throttling-service-server\build.gradle': 1: unexpected token: .. @ line 1, column 1.
../../server.gradle
^
1 error
Please help