Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

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

Open
a-alhazmi opened this issue Jul 5, 2023 · 0 comments
Open

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

a-alhazmi opened this issue Jul 5, 2023 · 0 comments

Comments

@a-alhazmi
Copy link

a-alhazmi commented Jul 5, 2023 •
edited
Loading

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?
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@a-alhazmi