Support Questions
Find answers, ask questions, and share your expertise

Error using Flume to connect to oracle: No Dialect mapping for JDBC type: 101

Error using Flume to connect to oracle: No Dialect mapping for JDBC type: 101

New Contributor

I am receiving the following error while connecting to oracle using flume:

2018-12-07 16:54:58,259 (PollableSourceRunner-SQLSource-sql-source) [ERROR - org.keedio.flume.source.HibernateHelper.executeQuery(HibernateHelper.jav a:124)] Exception thrown, resetting connection. org.hibernate.MappingException: No Dialect mapping for JDBC type: 101 at org.hibernate.dialect.TypeNames.get(TypeNames.java:87) at org.hibernate.dialect.TypeNames.get(TypeNames.java:118) at org.hibernate.dialect.Dialect.getHibernateTypeName(Dialect.java:653) at org.hibernate.loader.custom.JdbcResultMetadata.getHibernateType(JdbcResultMetadata.java:93) at org.hibernate.loader.custom.ScalarResultColumnProcessor.performDiscovery(ScalarResultColumnProcessor.java:62) at org.hibernate.loader.custom.CustomLoader.autoDiscoverTypes(CustomLoader.java:498) at org.hibernate.loader.Loader.getResultSet(Loader.java:2074) at org.hibernate.loader.Loader.executeQueryStatement(Loader.java:1863) at org.hibernate.loader.Loader.executeQueryStatement(Loader.java:1839) at org.hibernate.loader.Loader.doQuery(Loader.java:910) at org.hibernate.loader.Loader.doQueryAndInitializeNonLazyCollections(Loader.java:355) at org.hibernate.loader.Loader.doList(Loader.java:2554) at org.hibernate.loader.Loader.doList(Loader.java:2540) at org.hibernate.loader.Loader.listIgnoreQueryCache(Loader.java:2370) at org.hibernate.loader.Loader.list(Loader.java:2365) at org.hibernate.loader.custom.CustomLoader.list(CustomLoader.java:353) at org.hibernate.internal.SessionImpl.listCustomQuery(SessionImpl.java:1909) at org.hibernate.internal.AbstractSessionImpl.list(AbstractSessionImpl.java:311) at org.hibernate.internal.SQLQueryImpl.list(SQLQueryImpl.java:141) at org.keedio.flume.source.HibernateHelper.executeQuery(HibernateHelper.java:122) at org.keedio.flume.source.SQLSource.process(SQLSource.java:89) at org.apache.flume.source.PollableSourceRunner$PollingRunner.run(PollableSourceRunner.java:133) at java.lang.Thread.run(Thread.java:745)

My conf file is:

agent.channels = ch1

agent.sinks = HDFS

agent.sources = sql-source

agent.channels.ch1.type = memory

agent.channels.ch1.capacity = 1000000

agent.sources.sql-source.channels = ch1

agent.sources.sql-source.type = org.keedio.flume.source.SQLSource

# URL to connect to database

agent.sources.sql-source.hibernate.connection.url = jdbc:oracle:thin:@XX.XX.XX.XX:XXXX:XXXXX

# Database connection properties

agent.sources.sql-source.hibernate.connection.user = XXXXX

agent.sources.sql-source.hibernate.connection.password = XXXXXX

agent.sources.sql-source.table = XXXXXX.XXXXXX

agent.sources.sql-source.columns.to.select = *

#agent.sources.sql-source.status.file.name = sql-source.status

# Increment column properties

agent.sources.sql-source.incremental.column.name = MSRP

# Increment value is from you want to start taking data from tables (0 will import entire table)

agent.sources.sql-source.incremental.value = 0

# Query delay, each configured milisecond the query will be sent

agent.sources.sql-source.run.query.delay=10000

# Status file is used to save last readed row

agent.sources.sql-source.status.file.path = /home/143637

agent.sources.sql-source.status.file.name = sql-source.status

agent.sinks.HDFS.type = HDFS

agent.sinks.HDFS.hdfs.path = hdfs://XX.X.XX.XXX:XXXX/user/143637/TEST_STREAM

agent.sinks.HDFS.fileType = DataStream

agent.sinks.HDFS.channel = ch1

Don't have an account?