About isoardi

isoardi · ‎07-25-2019

Hi, see this form ambari minor upgrade: https://docs.hortonworks.com/HDPDocuments/Ambari-2.7.3.0/bk_ambari-upgrade/content/checkpoint_hdfs.html Do you have hdfs whit HA enabled?

isoardi · ‎07-25-2019

Hi @jessica moore, see this https://github.com/apache/ambari/blob/trunk/ambari-server/docs/api/v1/index.md

isoardi · ‎11-30-2018

Yes, it works. Thanks

isoardi · ‎11-30-2018

Hi all, HDP 2.6.3 with Hive 2. I have enabled the ACID transaction; when run the compaction I have seen max 3 job on YARN queue. I tried to launch manually more than 3 compaction, but they are execute 3 at a time. Is there a parameter to set the max concurrent compaction jobs? Thancks in advance

isoardi · ‎04-24-2018

in your place I would have: convert record to JSON not to CSV use EvaluateJsonPath to set the attribute from the JSON in the contentFile use updateAttribute to transform datetime and user use ReplaceText to replace all contentFile with the altered attribute write the contentFile to FS

isoardi · ‎04-24-2018

in your place I would have: convert record to JSON not to CSV use EvaluateJsonPath to set the attribute from the JSON in the contentFile use updateAttribute to transform datetime and user use ReplaceText to replace all contentFile with the altered attribute write the contentFile to FS

isoardi · ‎04-23-2018

sorry for the mistake, obviously the operation is performed on the attribute, not on the FlowFile. So you must first set the values you need in the attributes and then transform them. Thanks @Matt Clarke

isoardi · ‎04-23-2018

Try to execute tailf /proc/<pid_execution_script>/fd/2 pid_execution_scipt --> on the server where run NiFi you look for the process id, not the pid of NiFi service. Sometimes ExecutionScript ddoes not recivie the termination of the script. I do not know how to solve this 😞

isoardi · ‎04-23-2018

you must change the attribute on which to perform the transformation. I never used the GrokReader, but I believe you have to change ts to in timestamp in the EL string

isoardi · ‎04-23-2018

Hi @Wojtek, I believe the problem is that the format() function works only with numbers. Your timestamp has a '.' (dot) which makes it interpret as a string. To solve the problem I have adopted the following EL un a updateAttribute processor: ${ts:substringBefore('.'):append(${ts:substringAfter('.')}) :toNumber():format('MM/dd/yyyy HH:mm:ss.SSS') } ts attribute contains this value 1518442283.483 the result is 02/12/2018 13:31:23.483 I hope I have been of help

isoardi · ‎12-22-2017

I have a cluster with 7 NiFi nodes. After a node crash, on restart, NiFi could not find the file /usr/hdf/current/nifi/conf/keystore.jks and truststore.jks I have re-created the files with tls-toolkit.sh client -c tp-hostname.domain.com -t passwordPassword -p 10443 In Ambari config the keystore and truststore pasword are empty. When I start the NiFi services Ihave: Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'protocolSocketConfiguration': FactoryBean threw exception on object creation; nested exception is java.io.IOException: Keystore was tampered with, or password was incorrect at org.springframework.beans.factory.support.FactoryBeanRegistrySupport.doGetObjectFromFactoryBean(FactoryBeanRegistrySupport.java:175) at org.springframework.beans.factory.support.FactoryBeanRegistrySupport.getObjectFromFactoryBean(FactoryBeanRegistrySupport.java:103) at org.springframework.beans.factory.support.AbstractBeanFactory.getObjectForBeanInstance(AbstractBeanFactory.java:1585) at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:317) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197) at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveReference(BeanDefinitionValueResolver.java:351) ... 78 common frames omitted Caused by: java.io.IOException: Keystore was tampered with, or password was incorrect at sun.security.provider.JavaKeyStore.engineLoad(JavaKeyStore.java:780) at sun.security.provider.JavaKeyStore$JKS.engineLoad(JavaKeyStore.java:56) at sun.security.provider.KeyStoreDelegator.engineLoad(KeyStoreDelegator.java:224) at sun.security.provider.JavaKeyStore$DualFormatJKS.engineLoad(JavaKeyStore.java:70) at java.security.KeyStore.load(KeyStore.java:1445) at org.apache.nifi.io.socket.SSLContextFactory.<init>(SSLContextFactory.java:65) at org.apache.nifi.cluster.protocol.spring.SocketConfigurationFactoryBean.getObject(SocketConfigurationFactoryBean.java:45) at org.apache.nifi.cluster.protocol.spring.SocketConfigurationFactoryBean.getObject(SocketConfigurationFactoryBean.java:30) at org.springframework.beans.factory.support.FactoryBeanRegistrySupport.doGetObjectFromFactoryBean(FactoryBeanRegistrySupport.java:168) ... 83 common frames omitted Caused by: java.security.UnrecoverableKeyException: Password verification failed at sun.security.provider.JavaKeyStore.engineLoad(JavaKeyStore.java:778) ... 91 common frames omitted In nifi.properties I have: nifi.security.keyPasswd= nifi.security.keystore=/usr/hdf/current/nifi/conf/keystore.jks nifi.security.keystorePasswd= nifi.security.keystoreType=jks nifi.security.needClientAuth=False nifi.security.ocsp.responder.certificate= nifi.security.ocsp.responder.url= nifi.security.truststore=/usr/hdf/current/nifi/conf/truststore.jks nifi.security.truststorePasswd= nifi.security.truststoreType=jks nifi.security.user.authorizer=ranger-provider nifi.security.user.login.identity.provider= nifi.sensitive.props.additional.keys= nifi.sensitive.props.algorithm=PBEWITHMD5AND256BITAES-CBC-OPENSSL nifi.sensitive.props.key=sdlkjdslkjsdlkjdjjd||xyGZZ+R3FO04BxcUHSL5U6+OGqtQQevXbFfecQ nifi.sensitive.props.key.protected=aes/gcm/256 nifi.sensitive.props.provider=BC On other NiFi nodes I have an encrypted password in nifi.properties, but the truststore and the keystore has an empty string as a password. Do you have any idea for this issue? Thanks in advance

isoardi · ‎11-29-2016

Hi guys, I see surfing the internet that the max numbers of files stored in HDFS is equals at Integer.MAX_VALUE of JVM. Any confirmation that the maximum number of files is this (2.147.483.647)?

isoardi · ‎10-17-2016

Hi all, I have HPD 2.4 with Spark 1.6.1 and kerberos enabled. All services (HDFS, Yarn, Zookeeper, Hive and Spark) run correctly. Do you any idea for use the Spark-thrift server via Knox?

isoardi · ‎09-16-2016

hi guys, I have installed HDF 2.0 (only apache NiFi). I have 3 NiFi nodes on my HDP 2.4 cluster and I don't use the embedded zookeeper but the external zookeeper . When I start the NiFi node I see this error in the log file: 2016-09-16 14:00:02,235 WARN [Heartbeat Monitor Thread-1] o.a.n.c.c.node.NodeClusterCoordinator Failed to determine which node is elected active Cluster Coordinator: ZooKeeper reports the address as , but this is not a valid address The configuration that I have changed are: in nifi.properties nifi.web.http.port=9090 nifi.cluster.is.node=true nifi.cluster.node.address=hdpslave01.mydom.it nifi.cluster.node.protocol.port=9191 nifi.zookeeper.connect.string=hdpzookeeper01mydom.it:2181,hdpzookeeper02.mydom.it:2181,hdpzookeeper03mydom.it:2181 in state-management.xml <property name="Connect String">hdpzookeeper01.mydom.it:2181,hdpzookeeper02.mydom.it:2181,hdpzookeeper03.mydom.it:2181</property> Do you have any idea for this issue?

isoardi · ‎06-09-2016

No report by kerberos; sometimes in solr log I see this: Entered Krb5Context.initSecContext with state=STATE_IN_PROCESS >>> EType: sun.security.krb5.internal.crypto.Aes256CtsHmacSha1EType Krb5Context setting peerSeqNumber to: 1040665739 Krb5Context.unwrap: token=[05 04 01 ff 00 0c 00 00 00 00 00 00 3e 07 4c 8b 01 01 00 00 bd af ae ba 1a 96 94 c6 0b a3 b6 e5 ] Krb5Context.unwrap: data=[01 01 00 00 ] Krb5Context.wrap: data=[01 01 00 00 ] Krb5Context.wrap: token=[05 04 00 ff 00 0c 00 00 00 00 00 00 1a 79 57 37 01 01 00 00 ea 2b 94 71 78 d2 0a 34 fa 59 cc 97 ] Found ticket for solr/tst-master1@MYREALM.COM to go to krbtgt/MYREALM.COM@MYREALM.COM expiring on Fri Jun 10 09:00:52 UTC 2016 Entered Krb5Context.initSecContext with state=STATE_NEW Service ticket not found in the subject >>> Credentials acquireServiceCreds: same realm Using builtin default etypes for default_tgs_enctypes default etypes for default_tgs_enctypes: 18 17 16 23 1 3. >>> CksumType: sun.security.krb5.internal.crypto.RsaMd5CksumType >>> EType: sun.security.krb5.internal.crypto.Aes256CtsHmacSha1EType getKDCFromDNS using UDP >>> KrbKdcReq send: kdc=tst-kerb1. UDP:88, timeout=30000, number of retries =3, #bytes=724 >>> KDCCommunication: kdc=tst-kerb1. UDP:88, timeout=30000,Attempt =1, #bytes=724 >>> KrbKdcReq send: #bytes read=729 >>> KdcAccessibility: remove tst-kerb1.:88 >>> EType: sun.security.krb5.internal.crypto.Aes256CtsHmacSha1EType >>> KrbApReq: APOptions are 00100000 00000000 00000000 00000000 >>> EType: sun.security.krb5.internal.crypto.Aes256CtsHmacSha1EType Krb5Context setting mySeqNumber to: 609489532 Created InitSecContextToken: 0000: 01 00 6E 82 02 86 30 82 02 82 A0 03 02 01 05 A1 ..n...0......... ... more

isoardi · ‎06-09-2016

When I lanch a curl api request (with kerberos debag mode on) in solr log I see this: 12793190 [qtp139012968-19] WARN org.apache.hadoop.security.authentication.server.AuthenticationFilter [ ] – Authentication exception: GSSException: No valid credentials provided (Mechanism level: Attempt to obtain new ACCEPT credentials failed!) org.apache.hadoop.security.authentication.client.AuthenticationException: GSSException: No valid credentials provided (Mechanism level: Attempt to obtain new ACCEPT credentials failed!) at org.apache.hadoop.security.authentication.server.KerberosAuthenticationHandler.authenticate(KerberosAuthenticationHandler.java:399) at org.apache.hadoop.security.authentication.server.AuthenticationFilter.doFilter(AuthenticationFilter.java:507) at org.apache.solr.security.KerberosFilter.doFilter(KerberosFilter.java:50) at org.apache.solr.security.KerberosPlugin.doAuthenticate(KerberosPlugin.java:120) at org.apache.solr.servlet.SolrDispatchFilter.authenticateRequest(SolrDispatchFilter.java:261) at org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:203) at org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:196) at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1652) at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:585) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143) at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:577) at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:223) at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1127) at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:515) at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185) at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1061) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:215) at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:110) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97) at org.eclipse.jetty.server.Server.handle(Server.java:497) at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:310) at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:257) at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:540) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:635) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:555) at java.lang.Thread.run(Thread.java:744) Caused by: GSSException: No valid credentials provided (Mechanism level: Attempt to obtain new ACCEPT credentials failed!) at sun.security.jgss.krb5.Krb5AcceptCredential.getInstance(Krb5AcceptCredential.java:81) at sun.security.jgss.krb5.Krb5MechFactory.getCredentialElement(Krb5MechFactory.java:126) at sun.security.jgss.GSSManagerImpl.getCredentialElement(GSSManagerImpl.java:192) at sun.security.jgss.spnego.SpNegoMechFactory.getCredentialElement(SpNegoMechFactory.java:141) at sun.security.jgss.GSSManagerImpl.getCredentialElement(GSSManagerImpl.java:192) at sun.security.jgss.GSSCredentialImpl.add(GSSCredentialImpl.java:406) at sun.security.jgss.GSSCredentialImpl.<init>(GSSCredentialImpl.java:75) at sun.security.jgss.GSSManagerImpl.createCredential(GSSManagerImpl.java:159) at org.apache.hadoop.security.authentication.server.KerberosAuthenticationHandler$2.run(KerberosAuthenticationHandler.java:356) at org.apache.hadoop.security.authentication.server.KerberosAuthenticationHandler$2.run(KerberosAuthenticationHandler.java:348) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:415) at org.apache.hadoop.security.authentication.server.KerberosAuthenticationHandler.authenticate(KerberosAuthenticationHandler.java:348) ... 26 more Caused by: javax.security.auth.login.LoginException: Unable to obtain Princpal Name for authentication at com.sun.security.auth.module.Krb5LoginModule.promptForName(Krb5LoginModule.java:800) at com.sun.security.auth.module.Krb5LoginModule.attemptAuthentication(Krb5LoginModule.java:671) at com.sun.security.auth.module.Krb5LoginModule.login(Krb5LoginModule.java:584) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at javax.security.auth.login.LoginContext.invoke(LoginContext.java:784) at javax.security.auth.login.LoginContext.access$000(LoginContext.java:203) at javax.security.auth.login.LoginContext$5.run(LoginContext.java:721) at javax.security.auth.login.LoginContext$5.run(LoginContext.java:719) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.login.LoginContext.invokeCreatorPriv(LoginContext.java:718) at javax.security.auth.login.LoginContext.login(LoginContext.java:590) at sun.security.jgss.GSSUtil.login(GSSUtil.java:255) at sun.security.jgss.krb5.Krb5Util.getServiceCreds(Krb5Util.java:334) at sun.security.jgss.krb5.Krb5AcceptCredential$1.run(Krb5AcceptCredential.java:76) at sun.security.jgss.krb5.Krb5AcceptCredential$1.run(Krb5AcceptCredential.java:74) at java.security.AccessController.doPrivileged(Native Method) at sun.security.jgss.krb5.Krb5AcceptCredential.getInstance(Krb5AcceptCredential.java:73) ... 38 more

isoardi · ‎06-09-2016

Hi @Eric Walk, I have enabled debug mode for kerberos and I see this in the solr log: Found ticket for solr/tst-master1@MYREAL.COM to go to krbtgt/MYREALM.COM@MYREALM.COM expiring on Fri Jun 10 09:00:52 UTC 2016 Entered Krb5Context.initSecContext with state=STATE_NEW Service ticket not found in the subject >>> Credentials acquireServiceCreds: same realm Using builtin default etypes for default_tgs_enctypes default etypes for default_tgs_enctypes: 18 17 16 16 23 1 3.. >>> CksumType: sun.security.krb5.internal.crypto.RsaMd5CksumType >>> EType: sun.security.krb5.internal.crypto.Aes256CtsHmacSha1EType getKDCFromDNS using UDP >>> KrbKdcReq send: kdc=tst-kerb2. UDP:88, timeout=30000, number of retries =3, #bytes=724 >>> KDCCommunication: kdc=tst-kerb2. UDP:88, timeout=30000,Attempt =1, #bytes=724 >>> KrbKdcReq send: #bytes read=729 >>> KdcAccessibility: remove tst-kerb2.:88 >>> EType: sun.security.krb5.internal.crypto.Aes256CtsHmacSha1EType >>> KrbApReq: APOptions are 00100000 00000000 00000000 00000000 >>> EType: sun.security.krb5.internal.crypto.Aes256CtsHmacSha1EType Krb5Context setting mySeqNumber to: 971277641 Then solr use the correct ticket for comunicate with kerberos, but when I lanch a curl api request it return me this: solr@tst-master1 ~]$ klist Ticket cache: FILE:/tmp/krb5cc_6002 Default principal: HTTP/tst-master1@MYREALM.COM Valid starting Expires Service principal 06/09/16 11:02:39 06/10/16 11:02:39 krbtgt/MYREALM.COM@MYREALM.COM 06/09/16 11:03:12 06/10/16 11:02:39 HTTP/tst-master1@MYREALM.COM [solr@tst-master1 ~]$ curl --negotiate -u : "http://tst-master1:8983/solr/testCollection/select?q=*%3A*&row=0&wt=json" <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/> <title>Error 403 GSSException: No valid credentials provided (Mechanism level: Attempt to obtain new ACCEPT credentials failed!)</title> </head> <body><h2>HTTP ERROR 403</h2> <p>Problem accessing /solr/testCollection/select. Reason: <pre> GSSException: No valid credentials provided (Mechanism level: Attempt to obtain new ACCEPT credentials failed!)</pre></p><hr><i><small>Powered by Jetty://</small></i><hr/> </body> </html> Any ideas?

isoardi · ‎06-08-2016

[solr@tst-master1 ~]$ cat /opt//lucidworks-hdpsearch/solr/bin/jaas.conf Client { com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true keyTab="/etc/security/keytabs/solr.service.keytab" storeKey=true debug=true doNotPrompt=true principal="solr/tst-master1@MYREAL.COM"; };

isoardi · ‎06-08-2016

Hi @Jonas Straub and @Ali Bajwa, I read this article, but if I run any curl query solr returned: WARN org.apache.hadoop.security.authentication.server.AuthenticationFilter [ ] – Authentication exception: GSSException: No valid credentials provided (Mechanism level: Attempt to obtain new ACCEPT credentials failed!) org.apache.hadoop.security.authentication.client.AuthenticationException: GSSException: No valid credentials provided (Mechanism level: Attempt to obtain new ACCEPT credentials failed!) I have set correctly jaas.conf file and I have upload on zookeeper this: /zkcli.sh -zkhost tst-master1:2181,tst-master3:2181,tst-master2:2181 -cmd put /solr/security.json '{"authentication":{"class": "org.apache.solr.security.KerberosPlugin"}}' I have omitted the part related to ranger because it is not used in this cluster. thanks in advance. P.S.: This is my klist output: [solr@tst-master1 ~]$ klist Ticket cache: FILE:/tmp/krb5cc_6002 Default principal: solr/tst-master1@MYREALM.COM Valid starting Expires Service principal 06/08/16 13:27:53 06/09/16 13:27:53 krbtgt/MYREALM.COM@MYREALM.COM 06/08/16 13:28:03 06/09/16 13:27:53 HTTP/tst-master1@MYREALM.COM

isoardi · ‎04-28-2016

It's all ok if you run? hdfs dfsadmin -report

isoardi · ‎04-27-2016

Hi @Phoncy Joseph, cluster1 resolve nn2.cluster2? Can you communicate to nn2.cluster2 on port 8020 and with the datanode on port 50010 from cluster1?

isoardi · ‎04-26-2016

Hi @Petra Zimmer, You can test the repo with wget from your Ambari server node: wget <HDP-Base-URL>/repodata/repomd.xml wget <HDP-UTILS-Base-URL>/repodata/repomd.xml If one of them is wrong, or not accessible then the upgrade will fail.

isoardi · ‎04-26-2016

Ok, in advaced zookeeper.log4j set: log4j.appender.ROLLINGFILE.File=${zookeeper.log.dir}/zookeeper.log ${zookeeper.log.dir} is missing in defaul configuration.

isoardi · ‎04-23-2016

Hi @Bernhard Walter, I tried to change log4j properties of zookeeper from ambari, but the server has not acquired the changes.

isoardi · ‎04-22-2016

Hi, I have HDP 2.4.0 with Ambari 2.2.1. I tried to modify log4j.properti by advancec-zookeeper-log4j but when you restart of zookeeper, the server has not acquired the changes. I saw that in the file zkEnv.sh if [ "x${ZOO_LOG4J_PROP}" = "x" ] then ZOO_LOG4J_PROP="INFO,ROLLINGFILE" fi I tried to set DEBUG but has not changed the logging level

isoardi · ‎04-21-2016

Hi, from shell ambari-server status to see if ambari (the web UI) is running; if it's not running ambari-server start

isoardi · ‎04-21-2016

https://community.hortonworks.com/questions/28395/how-to-load-the-data-from-sql-server-to-hdfs-using.html#comment-28450

isoardi · ‎04-21-2016

Thank you Davide

isoardi · ‎04-21-2016

It is not totally true: with NiFi you can get "aloha.csv" from different source (web, local file, HDFS, DB, twitter, ...), enrich the data (for example you can merge with "byebye.csv") or to modify the data, and save data (to hive in different ways, to hdfs, to local file, ...). If you eant to see the personalityof twitter user, you can not use NiFi to calculate it. For this you can use spark

isoardi · ‎04-21-2016

Hi, I saw that there is HDF certification in cooming soon, when will it be available?

Online	Offline
Last Visited	‎07-28-2020 04:18 PM

Date Registered	‎12-10-2015 08:22 AM
Last Visited	‎07-28-2020 04:18 PM
Total Messages Posted	56
Total Kudos Received	22

Re: is it neccesery to backup the folder - /var/...

Re: Can i get twitter data to HDP, process it and ...

Re: Upgrade Ambari 2.2.0 to 2.2.1.0

Re: is it neccesery to backup the folder - /var/...

Re: how to get the list of all services as display...

Re: how to set the max concurrent compaction numbe...

how to set the max concurrent compaction number

Re: How to convert unix timestamp to datetime in A...

Re: How to convert unix timestamp to datetime in A...

Re: How to convert unix timestamp to datetime in A...

Re: NIFI Executestreamcommand with python script o...

Re: How to convert unix timestamp to datetime in A...

Re: How to convert unix timestamp to datetime in A...

Secured NiFi with empty keystore password does not...

HDFS maximum number of files?

How can I connect to spark-thrift server via Knox ...

Zookeper not send the correct address of the leade...

Re: Use solr with kerberos

Re: Use solr with kerberos

Re: Use solr with kerberos

Re: Use solr with kerberos

Use solr with kerberos

Re: Distcp: .BlockMissingException

Re: Distcp: .BlockMissingException

Re: How to install packages without proxy using yu...

Re: how do I configure log4j.properties for zookee...

Re: how do I configure log4j.properties for zookee...

how do I configure log4j.properties for zookeeper?

Re: Tutorial: Tag based policies with Apache Range...

Re: hive import from sql server?

Re: HDF Certified Stream Developer

Re: Can i get twitter data to HDP, process it and ...

HDF Certified Stream Developer