search

RMLio / RMLStreamer

The RMLStreamer executes RML rules to generate high quality Linked Data from multiple originally (semi-)structured data sources in a streaming way.
http://rml.io/
MIT License
48 stars 18 forks source link

PSQLException: FATAL: sorry, too many clients already, when run the standalone version 2.5.0 #49

Open a-alhazmi opened 1 year ago

a-alhazmi commented 1 year ago

Hello,

I am trying to install the RMLStreamer on Mac. I downloaded the latest standalone version from here.

However, when I tried to run it with the attached mapping file, I got this error: mapping.rml.txt Note: the mapping file extension is changed to txt to be able to upload it on GitHub.

`15:16:48,724 INFO io.rml.framework.Main$ - Mapping file: /path/to/mapping/file/mapping.rml.ttl Job name: RMLStreamer Base IRI: / Parallelise over local task slots: true Maximum parallelism: None Post processor: None Checkpoint interval: / Auto Watermark interval: 50 Output method: File Output file: /path/to/output/file/RMLStreamerOutput/output.ttl Kafka broker list: / Kafka topic: / Kafka topic partition id: / Output TCP socket: / Function description locations: None Discard output: false Number of standard stream triple maps: 0 Total extracted std triple maps: 0 Number of standard stream triple maps: 280

Total extracted std triple maps: 280 15:16:49,283 INFO io.rml.framework.Main$ - Datastream Job found. WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by org.apache.flink.api.java.ClosureCleaner (file:/path/to/jar/file/RMLStreamer/RMLStreamer-v2.5.0-standalone.jar) to field java.lang.String.value WARNING: Please consider reporting this to the maintainers of org.apache.flink.api.java.ClosureCleaner WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release 15:16:49,343 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,351 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,353 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,355 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,356 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,359 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,361 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,363 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,364 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,366 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,367 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,368 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,370 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,371 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,372 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,373 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,374 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,375 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,376 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,378 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,379 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,380 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,381 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,383 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,384 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,385 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,386 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,390 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,391 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,392 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,393 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,395 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,396 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,397 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,398 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,399 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,400 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,401 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,401 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,402 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,403 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,404 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,405 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,406 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,407 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,408 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,409 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,410 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,411 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,411 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,412 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,413 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,414 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,415 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,416 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,417 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,418 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,418 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,419 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,420 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,421 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,423 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,423 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,424 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,425 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,426 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,427 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,428 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,429 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,429 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,430 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,431 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,431 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,432 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,433 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,436 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,437 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,438 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,438 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,439 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,440 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,440 INFO io.rml.framework.Main$ - 3 Triple Maps are found. 15:16:49,441 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,442 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,443 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,443 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,444 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,445 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,445 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,446 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,447 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,447 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,448 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,449 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,449 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,450 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,451 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,454 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,455 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,455 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,456 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,456 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,457 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,458 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,458 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,459 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,460 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,460 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,461 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,461 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,462 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,463 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,463 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,464 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,465 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,466 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,467 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,468 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,468 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,469 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,469 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,470 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,470 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,471 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,471 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,472 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,473 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,473 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,474 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,475 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,475 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,476 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,476 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,477 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,477 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,478 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,479 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,479 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,480 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,480 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,481 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,481 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,482 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,482 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,483 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,483 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,484 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,484 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,485 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,486 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,486 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,487 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,487 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,488 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,488 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,489 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,489 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,490 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,491 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,491 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,492 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,492 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,493 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,494 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,494 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,495 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,496 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,497 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,497 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,498 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,499 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,499 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,500 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,500 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,501 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,501 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,502 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,502 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,503 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,503 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,504 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,504 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,505 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,505 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,506 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,506 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,507 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,507 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,508 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,508 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,509 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,509 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,510 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,510 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,511 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,511 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,512 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,512 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,513 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,513 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,514 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,514 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,515 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,516 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,516 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,517 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,517 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,518 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,518 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,518 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,519 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,520 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,520 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,521 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,521 INFO io.rml.framework.Main$ - 2 Triple Maps are found. 15:16:49,522 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,522 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,523 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,524 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,524 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,525 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,525 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,526 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,526 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,529 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,529 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:49,530 INFO io.rml.framework.Main$ - 1 Triple Maps are found. 15:16:52,063 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log file environment variable 'log.file' is not set. 15:16:52,063 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'web.log.path'. org.postgresql.util.PSQLException: FATAL: sorry, too many clients already at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:659) at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:180) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49) at org.postgresql.jdbc.PgConnection.(PgConnection.java:247) at org.postgresql.Driver.makeConnection(Driver.java:434) at org.postgresql.Driver.connect(Driver.java:291) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:228) at be.ugent.idlab.knows.dataio.access.RDBAccess.getInputStream(RDBAccess.java:129) at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.open(CSVSourceIterator.java:29) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:17) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) org.postgresql.util.PSQLException: FATAL: sorry, too many clients already at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:659) at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:180) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49) at org.postgresql.jdbc.PgConnection.(PgConnection.java:247) at org.postgresql.Driver.makeConnection(Driver.java:434) at org.postgresql.Driver.connect(Driver.java:291) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:228) at be.ugent.idlab.knows.dataio.access.RDBAccess.getInputStream(RDBAccess.java:129) at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.open(CSVSourceIterator.java:29) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:17) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) org.postgresql.util.PSQLException: FATAL: sorry, too many clients already at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:659) at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:180) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49) at org.postgresql.jdbc.PgConnection.(PgConnection.java:247) at org.postgresql.Driver.makeConnection(Driver.java:434) at org.postgresql.Driver.connect(Driver.java:291) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:228) at be.ugent.idlab.knows.dataio.access.RDBAccess.getInputStream(RDBAccess.java:129) at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.open(CSVSourceIterator.java:29) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:17) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) org.postgresql.util.PSQLException: FATAL: sorry, too many clients already at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:659) at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:180) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49) at org.postgresql.jdbc.PgConnection.(PgConnection.java:247) at org.postgresql.Driver.makeConnection(Driver.java:434) at org.postgresql.Driver.connect(Driver.java:291) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:228) at be.ugent.idlab.knows.dataio.access.RDBAccess.getInputStream(RDBAccess.java:129) at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.open(CSVSourceIterator.java:29) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:17) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) org.postgresql.util.PSQLException: FATAL: sorry, too many clients already at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:659) at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:180) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49) at org.postgresql.jdbc.PgConnection.(PgConnection.java:247) at org.postgresql.Driver.makeConnection(Driver.java:434) 15:16:53,809 WARN org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (1/1)#0 (bb86c03b22eb55f55fb3576dff29e3fe) switched from RUNNING to FAILED with failure cause: java.lang.NullPointerException at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.hasNext(CSVSourceIterator.java:68) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:18) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) at org.postgresql.Driver.connect(Driver.java:291) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:228) at be.ugent.idlab.knows.dataio.access.RDBAccess.getInputStream(RDBAccess.java:129) at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.open(CSVSourceIterator.java:29) 15:16:53,949 WARN org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (1/1)#0 (c9adbfc79434f5f636071baee7c476d2) switched from RUNNING to FAILED with failure cause: java.lang.NullPointerException at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.hasNext(CSVSourceIterator.java:68) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:18) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323)

at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:17)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323)

org.postgresql.util.PSQLException: FATAL: sorry, too many clients already at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:659) at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:180) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235) 15:16:54,068 WARN org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (1/1)#0 (3556932c1e4aeb3461736ca2b76177f1) switched from RUNNING to FAILED with failure cause: java.lang.NullPointerException at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.hasNext(CSVSourceIterator.java:68) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:18) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323)

at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49)
at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:247)
at org.postgresql.Driver.makeConnection(Driver.java:434)
at org.postgresql.Driver.connect(Driver.java:291)
at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677)
at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:228)
at be.ugent.idlab.knows.dataio.access.RDBAccess.getInputStream(RDBAccess.java:129)
at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.open(CSVSourceIterator.java:29)
at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:17)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323)

org.postgresql.util.PSQLException: FATAL: sorry, too many clients already at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:659) at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:180) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49) at org.postgresql.jdbc.PgConnection.(PgConnection.java:247) at org.postgresql.Driver.makeConnection(Driver.java:434) at org.postgresql.Driver.connect(Driver.java:291) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:228) at be.ugent.idlab.knows.dataio.access.RDBAccess.getInputStream(RDBAccess.java:129) at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.open(CSVSourceIterator.java:29) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:17) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) org.postgresql.util.PSQLException: FATAL: sorry, too many clients already at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:659) at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:180) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49) at org.postgresql.jdbc.PgConnection.(PgConnection.java:247) at org.postgresql.Driver.makeConnection(Driver.java:434) at org.postgresql.Driver.connect(Driver.java:291) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:228) at be.ugent.idlab.knows.dataio.access.RDBAccess.getInputStream(RDBAccess.java:129) at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.open(CSVSourceIterator.java:29) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:17) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) org.postgresql.util.PSQLException: FATAL: sorry, too many clients already at org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:659) at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:180) at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:235) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:49) at org.postgresql.jdbc.PgConnection.(PgConnection.java:247) at org.postgresql.Driver.makeConnection(Driver.java:434) at org.postgresql.Driver.connect(Driver.java:291) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:677) at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:228) at be.ugent.idlab.knows.dataio.access.RDBAccess.getInputStream(RDBAccess.java:129) at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.open(CSVSourceIterator.java:29) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:17) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) 15:16:54,447 WARN org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (1/1)#0 (ecada4bd50f61164c11ff6d4cfe46072) switched from RUNNING to FAILED with failure cause: java.lang.NullPointerException at be.ugent.idlab.knows.dataio.iterators.CSVSourceIterator.hasNext(CSVSourceIterator.java:68) at io.rml.framework.flink.source.functions.RDBSourceFunction.run(RDBSourceFunction.scala:18) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) `

Could you please assist me to solve this issue?