[
https://issues.apache.org/jira/browse/NIFI-10883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823618#comment-17823618
]
Peter Turcsanyi commented on NIFI-10883:
----------------------------------------
[SNOW-917458|https://github.com/snowflakedb/snowflake-jdbc/issues/1512] has
been solved in snowflake-jdbc:3.14.4 and NiFi 2.0 will use the fixed version
(NIFI-12497).
If SnowflakeComputingConnectionPool is used with ExecuteSQL[Record] (and also
in other cases when InaccessibleObjectException occurs), then the following
entry needs to be added in bootstrap.conf:
{code:java}
java.arg.add-opens.java.nio=--add-opens=java.base/java.nio=ALL-UNNAMED
{code}
As nifi-snowflake nars are not part of the default distribution bundle of NiFi,
bootstrap.conf does not contain the setting by default. It needs to be added on
demand.
> SnowflakeComputingConnectionPool fails on Java 21
> -------------------------------------------------
>
> Key: NIFI-10883
> URL: https://issues.apache.org/jira/browse/NIFI-10883
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Reporter: Peter Turcsanyi
> Assignee: Peter Turcsanyi
> Priority: Major
>
> Stack trace:
> {code:java}
> 2022-11-28 12:03:05,585 ERROR [Timer-Driven Process Thread-1]
> o.a.n.p.standard.PutDatabaseRecord
> PutDatabaseRecord[id=c8f95698-77b8-379e-1a39-f4f9fa48bd91] Failed to put
> Records to database for
> StandardFlowFileRecord[uuid=41f457f5-3d38-426c-98e3-63ec75b57548,claim=StandardContentClaim
> [resourceClaim=StandardResourceClaim[id=1669633380959-1, container=default,
> section=1], offset=0,
> length=25],offset=0,name=41f457f5-3d38-426c-98e3-63ec75b57548,size=25].
> Routing to failure.
> org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException:
> Cannot create PoolableConnectionFactory (isValid() returned false)
> at
> org.apache.nifi.dbcp.AbstractDBCPConnectionPool.getConnection(AbstractDBCPConnectionPool.java:573)
> at
> org.apache.nifi.dbcp.AbstractDBCPConnectionPool.getConnection(AbstractDBCPConnectionPool.java:550)
> at org.apache.nifi.dbcp.DBCPService.getConnection(DBCPService.java:55)
> at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
> at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.base/java.lang.reflect.Method.invoke(Method.java:568)
> at
> org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:254)
> at
> org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:105)
> at jdk.proxy12/jdk.proxy12.$Proxy88.getConnection(Unknown Source)
> at
> org.apache.nifi.processors.standard.PutDatabaseRecord.onTrigger(PutDatabaseRecord.java:487)
> at
> org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
> at
> org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1356)
> at
> org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:246)
> at
> org.apache.nifi.controller.scheduling.AbstractTimeBasedSchedulingAgent.lambda$doScheduleOnce$0(AbstractTimeBasedSchedulingAgent.java:59)
> at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
> at
> java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
> at
> java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
> at
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
> at java.base/java.lang.Thread.run(Thread.java:833)
> Caused by: java.sql.SQLException: Cannot create PoolableConnectionFactory
> (isValid() returned false)
> at
> org.apache.commons.dbcp2.BasicDataSource.createPoolableConnectionFactory(BasicDataSource.java:653)
> at
> org.apache.commons.dbcp2.BasicDataSource.createDataSource(BasicDataSource.java:531)
> at
> org.apache.commons.dbcp2.BasicDataSource.getConnection(BasicDataSource.java:731)
> at
> org.apache.nifi.dbcp.AbstractDBCPConnectionPool.getConnection(AbstractDBCPConnectionPool.java:560)
> ... 21 common frames omitted
> Caused by: java.sql.SQLException: isValid() returned false
> at
> org.apache.commons.dbcp2.PoolableConnection.validate(PoolableConnection.java:335)
> at
> org.apache.commons.dbcp2.PoolableConnectionFactory.validateConnection(PoolableConnectionFactory.java:653)
> at
> org.apache.commons.dbcp2.BasicDataSource.validateConnectionFactory(BasicDataSource.java:109)
> at
> org.apache.commons.dbcp2.BasicDataSource.createPoolableConnectionFactory(BasicDataSource.java:649)
> ... 24 common frames omitted
> {code}
> Environment:
> - compiled with 1.8.0_312-b07 (Temurin)
> -- run on 1.8.0_312-b07 (Temurin) => no error
> -- run on Temurin-11.0.17+8 => no error
> -- run on Temurin-17.0.5+8 => failure
> - compiled with Temurin-17.0.5+8
> -- run on Temurin-17.0.5+8 => failure
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
