Cloudera Community
mandychen
user rank
Explorer

Re: [NIFI] Cannot create PoolableConnectionFactory...

by Explorer in Support Questions
‎09-27-2023 05:25 PM
‎09-27-2023 05:25 PM
Hi @Mohamed_M  I use Nifi v1.20.0 can solve the error. Don't use the latest version. You can try it. ... View more

Re: Can Nifi insert data into uppercase table in p...

by Explorer in Support Questions
‎07-30-2023 04:45 PM
‎07-30-2023 04:45 PM
I see, it work! Thanks for your information ... View more

Can Nifi insert data into uppercase table in postg...

by Explorer in Support Questions
‎07-25-2023 08:09 PM
‎07-25-2023 08:09 PM
Hi Team, I create a dataflow try to insert data into uppercase table in postgesql. But it does not work. Appreciate any help on this issue, I am new to Nifi.     Here are my setting for QueryDatabaseTable and PutDatabaseRecord       The error message show org.apache.nifi.processors.standard.db.TableNotFoundException: Table "ACPMA" not found, ensure the Catalog, Schema, and/or Table Names match those in the database exactly     Here is a uppercase table ACPMA in postgesql.   ... View more
Labels:

Apache Airflow can not connect to mssql 2008

by Explorer in Support Questions
‎07-19-2023 01:49 AM
‎07-19-2023 01:49 AM
Hi team, I update airflow to v2.6.3, and find I can't connect to mssql 2008 by using JDBC. Following are my setting： Docker Desktop：v4.19.0 airflow：v2.6.3 JAVA：openjdk-11-jdk JDBC Driver：jtds-1.3.1.jar Connection URL：jdbc:jtds:sqlserver://xxx.xxx.xx.xx:1433/xxxx Driver Path：/usr/local/airflow/jars/jtds-1.3.1.jar Driver Class：net.sourceforge.jtds.jdbc.Driver   The connection was failed.     I wonder why the message show the connection string as below：       jdbc://jdbc:jtds:sqlserver:     why not only     jdbc:jtds:sqlserver:     Any help will be appreciated, thanks!       ... View more
Labels:

[NIFI] Cannot create PoolableConnectionFactory (Th...

by Explorer in Support Questions
‎07-18-2023 05:43 PM
‎07-18-2023 05:43 PM
Hi Team, I am a newbie for nifi. I am trying to connect mssql 2008 by using DBCPConnectionPool. The following are my setting：   Docker Desktop：v4.19.0 Nifi：v1.22.0 JDBC Driver：jtds-1.3.1.jar JDBC Driver location：/opt/nifi/nifi-current/lib/jtds-1.3.1.jar   DBCPConnectionPool Configure Controller Service：   Database Connection URL：jdbc:jtds:sqlserver://xxx.xxx.xx.xx:1433/xxxxx Database Driver Class Name：net.sourceforge.jtds.jdbc.Driver Database Driver Location(s)：/opt/nifi/nifi-current/lib/jtds-1.3.1.jar Database User：xxx Password：xxx Validation query：Select 1 as test   And I try to Verify Controller Service Configuration get the message bellow：   org.apache.nifi.dbcp.DBCPConnectionPool DBCPConnectionPool[id=67dc5ad3-0189-1000-09ac-b19f6c25590c] Failed to establish Database Connection org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Cannot create PoolableConnectionFactory (Network error IOException: Connection timed out (Connection timed out)) at org.apache.nifi.dbcp.AbstractDBCPConnectionPool.getConnection(AbstractDBCPConnectionPool.java:245) at org.apache.nifi.dbcp.AbstractDBCPConnectionPool.verify(AbstractDBCPConnectionPool.java:89) at org.apache.nifi.controller.service.StandardControllerServiceNode.verifyConfiguration(StandardControllerServiceNode.java:493) at org.apache.nifi.web.dao.impl.StandardControllerServiceDAO.verifyConfiguration(StandardControllerServiceDAO.java:424) at org.apache.nifi.web.dao.impl.StandardControllerServiceDAO$$FastClassBySpringCGLIB$$6b77954.invoke(<generated>) at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) at org.apache.nifi.web.dao.impl.StandardControllerServiceDAO$$EnhancerBySpringCGLIB$$1a2edf4e.verifyConfiguration(<generated>) at org.apache.nifi.web.StandardNiFiServiceFacade.performControllerServiceConfigVerification(StandardNiFiServiceFacade.java:2934) at org.apache.nifi.web.StandardNiFiServiceFacade$$FastClassBySpringCGLIB$$358780e0.invoke(<generated>) at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) at org.apache.nifi.web.StandardNiFiServiceFacade$$EnhancerBySpringCGLIB$$72e216a8.performControllerServiceConfigVerification(<generated>) at org.apache.nifi.web.api.ControllerServiceResource.lambda$performAsyncConfigVerification$28(ControllerServiceResource.java:1110) at org.apache.nifi.web.api.concurrent.AsyncRequestManager$2.run(AsyncRequestManager.java:117) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) at java.base/java.util.concurrent.FutureTask.run(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source)       Help on this would be appreciated.   ... View more
Labels:
Contact Me
Online
Offline
Last Visited
‎10-10-2023 08:01 PM
Community Statistics
Member Since ‎07-18-2023 05:07 PM
Last Visited ‎10-10-2023 08:01 PM
Posts 5