Cloudera Community
roshanbi
user rank
Contributor
My Accepted Solutions
Show All

Kafka checkpoint

by Contributor in Support Questions
‎06-28-2022 05:32 PM
‎06-28-2022 05:32 PM
Hello Team,   we are doing CDC by pushing data to Kafka and another pipeline will be reading data from Kafka. Whenever we restart the second pipeline (read from Kafka to Kudu), I notice there are thousands of records coming.   I would like to know how Kafka keeps the checkpoints? Is there any setting to change it?   Thanks, Roshan ... View more
Labels:

update with alias not working

by Contributor in Support Questions
‎05-18-2022 01:11 AM
‎05-18-2022 01:11 AM
Hello Team,   could you please advise how update with table alias works? update cbs_cubes.TB_JDV_CBS_NEW set a.SUB_SERVICE_CODE_V=b.SUB_SERVICE_CODE_V from cbs_cubes.update1_sub_service_code b where a.SUB_SERVICE_CODE_V=b.SUB_SERVICE_CODE_V   [Cloudera][ImpalaJDBCDriver](500051) ERROR processing query/statement. Error Code: 0, SQL state: TStatus(statusCode:ERROR_STATUS, sqlState:HY000, errorMessage:AnalysisException: 'cbs_cubes.TB_JDV_CBS_NEW' is not a valid table alias or reference. ), Query: update cbs_cubes.TB_JDV_CBS_NEW set a.SUB_SERVICE_CODE_V=b.SUB_SERVICE_CODE_V from cbs_cubes.update1_sub_service_code b where a.SUB_SERVICE_CODE_V=b.SUB_SERVICE_CODE_V.   Thanks, Roshan ... View more
Labels:

Re: kudu connection

by Contributor in Support Questions
‎04-25-2022 12:54 AM
‎04-25-2022 12:54 AM
Thanks Jason. We upgraded Cloudera and issue is resolved. ... View more

conduktor connection error

by Contributor in Support Questions
‎04-25-2022 12:52 AM
‎04-25-2022 12:52 AM
Hello Team,   can you please advise why connection to Kafka fails? Is the issue with keytab? Keytab is working fine on Linux machine. sasl.jaas.config= com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true keyTab="D:\services.kerberos.keytab" principal="services/rb-hadoop-06.mtg.local@INNOV.LOCAL";   org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:540) at org.apache.kafka.clients.admin.Admin.create(Admin.java:134) at io.conduktor.kafka.plugins.PluginsAwareKafkaAdmin$.$anonfun$create$2(PluginsAwareKafkaAdmin.scala:17) at io.conduktor.plugins.PluginsResources$$anon$1.executeWithPlugins(PluginsResources.scala:74) at io.conduktor.kafka.plugins.PluginsAwareKafkaAdmin$.$anonfun$create$1(PluginsAwareKafkaAdmin.scala:17) at scala.util.Try$.apply(Try.scala:210) at io.conduktor.kafka.plugins.PluginsAwareKafkaAdmin$.create(PluginsAwareKafkaAdmin.scala:17) at io.conduktor.kafka.plugins.PluginsAwareKafkaAdmin.create(PluginsAwareKafkaAdmin.scala) at io.conduktor.kafka.KafkaClientMaker.makeAdminClient(KafkaClientMaker.kt:103) at io.conduktor.kafka.KafkaClientMaker.checkConnectivity(KafkaClientMaker.kt:79) at io.conduktor.views.clusterconfiguration.KafkaCluster$kafkaClusterConfigTab$1$2$1$11$1$2$1$1.invokeSuspend(KafkaCluster.kt:334) at io.conduktor.views.clusterconfiguration.KafkaCluster$kafkaClusterConfigTab$1$2$1$11$1$2$1$1.invoke(KafkaCluster.kt) at io.conduktor.views.clusterconfiguration.KafkaCluster$kafkaClusterConfigTab$1$2$1$11$1$2$1$1.invoke(KafkaCluster.kt) at io.conduktor.JavaFxExtensionsKt$launchWithProgressCancelable$job$1.invokeSuspend(JavaFxExtensions.kt:353) at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106) at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:571) at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:750) at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:678) at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:665) Caused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: null (68) at org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:184) at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:192) at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:81) at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:105) at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:513) ... 19 more Caused by: javax.security.auth.login.LoginException: null (68) at jdk.security.auth/com.sun.security.auth.module.Krb5LoginModule.attemptAuthentication(Unknown Source) at jdk.security.auth/com.sun.security.auth.module.Krb5LoginModule.login(Unknown Source) at java.base/javax.security.auth.login.LoginContext.invoke(Unknown Source) at java.base/javax.security.auth.login.LoginContext$4.run(Unknown Source) at java.base/javax.security.auth.login.LoginContext$4.run(Unknown Source) at java.base/java.security.AccessController.doPrivileged(Unknown Source) at java.base/javax.security.auth.login.LoginContext.invokePriv(Unknown Source) at java.base/javax.security.auth.login.LoginContext.login(Unknown Source) at org.apache.kafka.common.security.authenticator.AbstractLogin.login(AbstractLogin.java:60) at org.apache.kafka.common.security.kerberos.KerberosLogin.login(KerberosLogin.java:103) at org.apache.kafka.common.security.authenticator.LoginManager.<init>(LoginManager.java:62) at org.apache.kafka.common.security.authenticator.LoginManager.acquireLoginManager(LoginManager.java:105) at org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:170) ... 23 more Caused by: KrbException: null (68) at java.security.jgss/sun.security.krb5.KrbAsRep.<init>(Unknown Source) at java.security.jgss/sun.security.krb5.KrbAsReqBuilder.send(Unknown Source) at java.security.jgss/sun.security.krb5.KrbAsReqBuilder.action(Unknown Source) ... 36 more Caused by: KrbException: Identifier doesn't match expected value (906) at java.security.jgss/sun.security.krb5.internal.KDCRep.init(Unknown Source) at java.security.jgss/sun.security.krb5.internal.ASRep.init(Unknown Source) at java.security.jgss/sun.security.krb5.internal.ASRep.<init>(Unknown Source) ... 39 more ... View more
Labels:

kudu connection

by Contributor in Support Questions
‎03-28-2022 08:16 AM
‎03-28-2022 08:16 AM
Dear Team,   kindly advise on why connection from our CDC tools to Kudu is not working? What does KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0) mean?   at java.lang.Thread.run(Thread.java:750) com.webaction.common.exc.ConnectionException: Couldn't establish connection with Kudu ( RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051 ) at com.striim.proc.Connection.KuduWriterConnection.connect(KuduWriterConnection.java:83) at com.striim.proc.Connection.KuduWriterConnection.<init>(KuduWriterConnection.java:44) at com.striim.proc.Connection.KuduWriterConnection.getConnection(KuduWriterConnection.java:100) at com.striim.proc.KuduWriter.initializeKuduClient(KuduWriter.java:224) at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:132) at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78) at com.webaction.runtime.components.Target.start(Target.java:377) at com.webaction.runtime.components.Flow.start(Flow.java:431) at com.webaction.runtime.components.Flow.start(Flow.java:375) at com.webaction.runtime.components.Flow.start(Flow.java:335) at com.webaction.runtime.components.Flow$2.run(Flow.java:1612) at java.lang.Thread.run(Thread.java:750) com.webaction.common.exc.ConnectionException: Couldn't establish connection with Kudu ( RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051 ) at com.striim.proc.Connection.KuduWriterConnection.connect(KuduWriterConnection.java:83) at com.striim.proc.Connection.KuduWriterConnection.<init>(KuduWriterConnection.java:44) at com.striim.proc.Connection.KuduWriterConnection.getConnection(KuduWriterConnection.java:100) at com.striim.proc.KuduWriter.initializeKuduClient(KuduWriter.java:224) at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:132) at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78) at com.webaction.runtime.components.Target.start(Target.java:377) at com.webaction.runtime.components.Flow.start(Flow.java:431) at com.webaction.runtime.components.Flow.start(Flow.java:375) at com.webaction.runtime.components.Flow.start(Flow.java:335) at com.webaction.runtime.components.Flow$2.run(Flow.java:1612) at java.lang.Thread.run(Thread.java:750) com.striim.proc.exception.KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0) at com.striim.proc.CheckPoint.CheckpointTableImpl.checkForCheckpointTable(CheckpointTableImpl.java:133) at com.striim.proc.CheckPoint.CheckpointTableImpl.<init>(CheckpointTableImpl.java:44) at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:152) at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78) at com.webaction.runtime.components.Target.start(Target.java:377) at com.webaction.runtime.components.Flow.start(Flow.java:431) at com.webaction.runtime.components.Flow.start(Flow.java:375) at com.webaction.runtime.components.Flow.start(Flow.java:335) at com.webaction.runtime.components.Flow$2.run(Flow.java:1612) at java.lang.Thread.run(Thread.java:750) Command RESUME failed so application CDC.CDC_CBS_CUST_CBS_NP is put in HALTED state com.striim.proc.exception.KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0) at com.striim.proc.CheckPoint.CheckpointTableImpl.checkForCheckpointTable(CheckpointTableImpl.java:133) at com.striim.proc.CheckPoint.CheckpointTableImpl.<init>(CheckpointTableImpl.java:44) at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:152) at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78) at com.webaction.runtime.components.Target.start(Target.java:377) at com.webaction.runtime.components.Flow.start(Flow.java:431) at com.webaction.runtime.components.Flow.start(Flow.java:375) at com.webaction.runtime.components.Flow.start(Flow.java:335) at com.webaction.runtime.components.Flow$2.run(Flow.java:1612) at java.lang.Thread.run(Thread.java:750) com.striim.proc.exception.KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0) at com.striim.proc.CheckPoint.CheckpointTableImpl.checkForCheckpointTable(CheckpointTableImpl.java:133) at com.striim.proc.CheckPoint.CheckpointTableImpl.<init>(CheckpointTableImpl.java:44) at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:152) at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78) at com.webaction.runtime.components.Target.start(Target.java:377) at com.webaction.runtime.components.Flow.start(Flow.java:431) at com.webaction.runtime.components.Flow.start(Flow.java:375) at com.webaction.runtime.components.Flow.start(Flow.java:335) at com.webaction.runtime.components.Flow$2.run(Flow.java:1612)   Thanks, Roshan ... View more

kafka json slow

by Contributor in Support Questions
‎10-20-2021 07:21 AM
‎10-20-2021 07:21 AM
Hello Team,   we are having some performance issue when sending data to Kafka using JSON as format. Performs is very slow.   Performance is faster when using DSV parser.   How can we fine tune JSON formatter?   Regards, Roshan ... View more
Labels:

varchar kudu

by Contributor in Support Questions
‎09-14-2021 03:38 AM
‎09-14-2021 03:38 AM
Dear Team,   can you please advise why varchar is not acceptable when replicating from Oracle to Kudu though I can create table with varchar on Kudu?   Error from our CDC tool. Error while writing batch on table impala::cbs.cb_ad_x Reason account_type_v isn't [Type: string], it's varchar. Cause: account_type_v isn't [Type: string], it's varchar   CREATE TABLE cbs.cb_address_xm ( addressid varchar(65535) , account_link_code_n BIGINT , account_type_v varchar(65535) , address_type_n INT , account_type varchar(65535) , address_format varchar(65535) , address_type INT , building varchar(65535) , city varchar(65535) , city_desc varchar(65535) , country varchar(65535) , country_desc varchar(65535) , district varchar(65535) , district_desc varchar(65535) , floor varchar(65535) , landmark varchar(65535) , postal_code varchar(65535) , po_code varchar(65535) , street varchar(65535) , street_desc varchar(65535) , sub_locality_code varchar(65535) , sub_locality_desc varchar(65535) , op_insert_date TIMESTAMP , op_update_date TIMESTAMP , state_desc varchar(65535) , PRIMARY KEY (addressid) ) PARTITION BY HASH (addressid) PARTITIONS 16 STORED AS KUDU ;   Regards,   Roshan ... View more
Labels:

spark sql to Kudu

by Contributor in Support Questions
‎08-12-2021 10:45 PM
‎08-12-2021 10:45 PM
Hello Team,   I have the following file to load on Kudu. 1829;BN=0;UNIT=VOLUME_ALL;IN=0;TC=0;TCC=0;CT=;FU=1000001;CU=54274;FB=61701;FL=ugw9811_3828500385_360_27153 0=5126742111750858;U=23059268534;SI=6;SG=1;SR=7;SN=BROWSING;SC=BROWSING;BS=60342256;BR=2581143;TU=2021-04-27 14:02:47;TF=2021-04-27 00:00:00;TA=2021-04-27 14:02:47;TB=2021-04-27 00:00:00;TE=2021-04-27 14:02:47;TS=1619517767;D=16292;R=151;E=0;UDR_cu=0;UDR_fb=BROWSING;DCM=0;UP=Prepaid;ST=BROWSING;MSISDN=23059268534;APN=orange;SGSN=196.192.13.113;GGSN=196.192.13.113;IMSI=617010014925066;BU1=23292;BN=0;UNIT=VOLUME_ALL;IN=0;TC=0;TCC=62923399;CT=;FU=1000000;CU=3586;FB=61701;FL=ugw9811_3828490275_312_8799 0=5126752111750858;U=23059268534;SI=6;SG=1;SR=7;SN=BROWSING;SC=BROWSING;BS=0;BR=0;TU=2021-04-27 14:02:47;TF=2021-04-27 00:00:00;TA=2021-04-27 14:02:47;TB=2021-04-27 00:00:00;TE=2021-04-27 14:02:47;TS=1619517767;D=16292;R=151;E=0;UDR_cu=0;UDR_fb=BROWSING;DCM=0;UP=Prepaid;ST=BROWSING;MSISDN=23059268534;APN=orange;SGSN=196.192.13.113;GGSN=196.192.13.113;IMSI=617010014925066;BU1=21829;BN=0;UNIT=VOLUME_ALL;IN=0;TC=0;TCC=0;CT=;FU=1000001;CU=3586;FB=61701;FL=ugw9811_3828490275_312_8799   How can I proceed using Spark SQL?   Table structure on Kudu: CREATE EXTERNAL TABLE cdr.mobile_datadbs (   id BIGINT NOT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   msisdn STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   serviceid INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   servicegroup INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   servicerev INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   servicename STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   serviceclass STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   downlink INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   uplink INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   storedtime TIMESTAMP NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   firstaccesstime TIMESTAMP NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   lastaccesstime TIMESTAMP NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   servicebegintime TIMESTAMP NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   sessionendtime TIMESTAMP NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   cdrcreatedtime BIGINT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   duration BIGINT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   hitsperreq BIGINT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   errors1 BIGINT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   udrcu INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   udrfb STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   status1 STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   userprofile STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   servicetype STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   subsmsisdn STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   apn STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   sgsnaddress STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   ggsnaddress STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   imsi STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   bonusunit STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   bn INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   unit STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   instatus INT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   totalcost BIGINT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   totalcharge BIGINT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   terminationcause BIGINT NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   firstrequestedurl STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   cellidinfo STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   idpname STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   failureslist STRING NULL ENCODING AUTO_ENCODING COMPRESSION DEFAULT_COMPRESSION,   PRIMARY KEY (id) ) PARTITION BY HASH (id) PARTITIONS 16 STORED AS KUDU TBLPROPERTIES ('external.table.purge'='TRUE', 'kudu.master_addresses'='rb-hadoop-03.mtg.local,rb-hadoop-04.mtg.local,rb-hadoop-05.mtg.local')   Thanks,   Roshan   ... View more

Re: sql functions

by Contributor in Support Questions
‎08-12-2021 09:48 PM
‎08-12-2021 09:48 PM
Hi,   yes I would like to re-use your Oracle functions and use Zeppelin as your notebook. we are using impala as SQL engine. How do I translate that SQL function to Oracle dialect?     Regards, Roshan ... View more

convert oracle sql to kudu sql

by Contributor in Support Questions
‎08-10-2021 05:16 AM
‎08-10-2021 05:16 AM
Hello Team,   can you please  advise why Kudu returns 0 rows? count  of base table is same. Oracle - returns 21000 rows: select BankOrgProfile.* from AR.HZ_ORGANIZATION_PROFILES BankOrgProfile where SYSDATE between TRUNC(BankOrgProfile.effective_start_date) and NVL(TRUNC(BankOrgProfile.effective_end_date), SYSDATE+1) ;   Kudu (Impala) - returns 0 rows: select BankOrgProfile.* from oracle_financial.HZ_ORGANIZATION_PROFILES BankOrgProfile where current_date() between cast(BankOrgProfile.effective_end_date as date) and nvl(cast(BankOrgProfile.effective_end_date as date), adddate(current_date(),1)) ;   Thanks,   Roshan ... View more
Labels:
Contact Me
Online
Offline
Last Visited
‎07-11-2022 05:29 AM
Community Statistics
Member Since ‎09-19-2020 08:57 AM
Last Visited ‎07-11-2022 05:29 AM
Posts 46
Kudos received 1