Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-967

Segmentation fault on Decoderbufs/PostgreSQL10

    XMLWordPrintable

Details

    • Bug
    • Resolution: Not a Bug
    • Critical
    • None
    • 0.8.3.Final
    • postgres-decoderbufs
    • None
    • Hide

      I just create a connector in Kafka with description above, and then in Postgres database side, I create a table and insert a row.

      Show
      I just create a connector in Kafka with description above, and then in Postgres database side, I create a table and insert a row.

    Description

      After insert on postgres database, connector stopped with this error:

      {
        "name": "bella_ciao-connector",
        "connector": {
          "state": "RUNNING",
          "worker_id": "127.0.0.1:8083"
        },
        "tasks": [
          {
            "state": "FAILED",
            "trace": "org.apache.kafka.connect.errors.ConnectException: An exception ocurred in the change event producer. This connector will be stopped.\n\tat io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:168)\n\tat io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:149)\n\tat io.debezium.connector.postgresql.PostgresConnectorTask.poll(PostgresConnectorTask.java:146)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:244)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:220)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\nCaused by: org.postgresql.util.PSQLException: Database connection failed when reading from copy\n\tat org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:964)\n\tat org.postgresql.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:41)\n\tat org.postgresql.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:145)\n\tat org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:114)\n\tat org.postgresql.core.v3.replication.V3PGReplicationStream.read(V3PGReplicationStream.java:60)\n\tat io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.read(PostgresReplicationConnection.java:198)\n\tat io.debezium.connector.postgresql.RecordsStreamProducer.streamChanges(RecordsStreamProducer.java:128)\n\tat io.debezium.connector.postgresql.RecordsStreamProducer.lambda$start$1(RecordsStreamProducer.java:114)\n\t... 5 more\nCaused by: java.net.SocketException: Connection reset\n\tat java.net.SocketInputStream.read(SocketInputStream.java:210)\n\tat java.net.SocketInputStream.read(SocketInputStream.java:141)\n\tat org.postgresql.core.VisibleBufferedInputStream.readMore(VisibleBufferedInputStream.java:140)\n\tat org.postgresql.core.VisibleBufferedInputStream.ensureBytes(VisibleBufferedInputStream.java:109)\n\tat org.postgresql.core.VisibleBufferedInputStream.read(VisibleBufferedInputStream.java:67)\n\tat org.postgresql.core.PGStream.receiveChar(PGStream.java:282)\n\tat org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1006)\n\tat org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:962)\n\t... 12 more\n",
            "id": 0,
            "worker_id": "127.0.0.1:8083"
          }
        ],
        "type": "source"
      }
      

      After this insert in database, I got this error on postgres log:

      2018-11-07 08:21:51.278 -03 [3176]: [1-1] user=[unknown],db=[unknown],app=[unknown],client=10.111.19.82 LOG:  connection received: host=10.111.19.82 port=33660
      2018-11-07 08:21:51.279 -03 [3176]: [2-1] user=italia_login,db=bella_ciao,app=[unknown],client=10.111.19.82 LOG:  connection authorized: user=italia_login database=bella_ciao
      2018-11-07 08:21:51.360 -03 [3176]: [3-1] user=italia_login,db=bella_ciao,app=PostgreSQL JDBC Driver,client=10.111.19.82 LOG:  disconnection: session time: 0:00:00.082 user=italia_login database=bella_ciao host=10.111.19.82 port=33660
      2018-11-07 08:21:51.365 -03 [3175]: [3-1] user=italia_login,db=bella_ciao,app=PostgreSQL JDBC Driver,client=10.111.19.82 LOG:  starting logical decoding for slot "debezium"
      2018-11-07 08:21:51.365 -03 [3175]: [4-1] user=italia_login,db=bella_ciao,app=PostgreSQL JDBC Driver,client=10.111.19.82 DETAIL:  streaming transactions committing after 0/3000A98, reading WAL from 0/3000A60
      2018-11-07 08:21:51.365 -03 [3175]: [5-1] user=italia_login,db=bella_ciao,app=PostgreSQL JDBC Driver,client=10.111.19.82 LOG:  logical decoding found consistent point at 0/3000A60
      2018-11-07 08:21:51.365 -03 [3175]: [6-1] user=italia_login,db=bella_ciao,app=PostgreSQL JDBC Driver,client=10.111.19.82 DETAIL:  There are no running transactions.
      2018-11-07 08:21:51.377 -03 [3177]: [1-1] user=[unknown],db=[unknown],app=[unknown],client=10.111.19.82 LOG:  connection received: host=10.111.19.82 port=33662
      2018-11-07 08:21:51.379 -03 [3177]: [2-1] user=italia_login,db=bella_ciao,app=[unknown],client=10.111.19.82 LOG:  connection authorized: user=italia_login database=bella_ciao
      2018-11-07 08:21:51.430 -03 [3177]: [3-1] user=italia_login,db=bella_ciao,app=PostgreSQL JDBC Driver,client=10.111.19.82 LOG:  disconnection: session time: 0:00:00.052 user=italia_login database=bella_ciao host=10.111.19.82 port=33662
      2018-11-07 08:22:17.305 -03 [3224]: [1-1] user=[unknown],db=[unknown],app=[unknown],client=[local] LOG:  connection received: host=[local]
      2018-11-07 08:22:17.306 -03 [3224]: [2-1] user=postgres,db=postgres,app=[unknown],client=[local] LOG:  connection authorized: user=postgres database=postgres
      2018-11-07 08:22:20.229 -03 [3225]: [1-1] user=[unknown],db=[unknown],app=[unknown],client=[local] LOG:  connection received: host=[local]
      2018-11-07 08:22:20.230 -03 [3225]: [2-1] user=postgres,db=bella_ciao,app=[unknown],client=[local] LOG:  connection authorized: user=postgres database=bella_ciao
      2018-11-07 08:22:20.231 -03 [3224]: [3-1] user=postgres,db=postgres,app=psql,client=[local] LOG:  disconnection: session time: 0:00:02.925 user=postgres database=postgres host=[local]
      2018-11-07 08:22:33.268 -03 [2967]: [3-1] user=,db=,app=,client= LOG:  checkpoint starting: time
      2018-11-07 08:22:49.201 -03 [2963]: [8-1] user=,db=,app=,client= LOG:  server process (PID 3175) was terminated by signal 11: Segmentation fault
      2018-11-07 08:22:49.201 -03 [2963]: [9-1] user=,db=,app=,client= LOG:  terminating any other active server processes
      2018-11-07 08:22:49.201 -03 [3225]: [3-1] user=postgres,db=bella_ciao,app=psql,client=[local] WARNING:  terminating connection because of crash of another server process
      2018-11-07 08:22:49.201 -03 [3225]: [4-1] user=postgres,db=bella_ciao,app=psql,client=[local] DETAIL:  The postmaster has commanded this server process to roll back the current transaction and exit, because another server process exited abnormally and possibly corrupted shared memory.
      2018-11-07 08:22:49.201 -03 [3225]: [5-1] user=postgres,db=bella_ciao,app=psql,client=[local] HINT:  In a moment you should be able to reconnect to the database and repeat your command.
      2018-11-07 08:22:49.204 -03 [2970]: [1-1] user=,db=,app=,client= WARNING:  terminating connection because of crash of another server process
      2018-11-07 08:22:49.204 -03 [2970]: [2-1] user=,db=,app=,client= DETAIL:  The postmaster has commanded this server process to roll back the current transaction and exit, because another server process exited abnormally and possibly corrupted shared memory.
      2018-11-07 08:22:49.204 -03 [2970]: [3-1] user=,db=,app=,client= HINT:  In a moment you should be able to reconnect to the database and repeat your command.
      2018-11-07 08:22:49.206 -03 [2963]: [10-1] user=,db=,app=,client= LOG:  archiver process (PID 2971) exited with exit code 1
      2018-11-07 08:22:49.736 -03 [2963]: [11-1] user=,db=,app=,client= LOG:  all server processes terminated; reinitializing
      2018-11-07 08:22:49.947 -03 [3258]: [1-1] user=,db=,app=,client= LOG:  database system was interrupted; last known up at 2018-11-07 08:17:33 -03
      2018-11-07 08:22:50.073 -03 [3258]: [2-1] user=,db=,app=,client= LOG:  database system was not properly shut down; automatic recovery in progress
      2018-11-07 08:22:50.075 -03 [3258]: [3-1] user=,db=,app=,client= LOG:  redo starts at 0/40000D0
      2018-11-07 08:22:50.076 -03 [3258]: [4-1] user=,db=,app=,client= LOG:  invalid record length at 0/40003E0: wanted 24, got 0
      2018-11-07 08:22:50.076 -03 [3258]: [5-1] user=,db=,app=,client= LOG:  redo done at 0/40003A8
      2018-11-07 08:22:50.076 -03 [3258]: [6-1] user=,db=,app=,client= LOG:  last completed transaction was at log time 2018-11-07 08:22:32.995685-03
      2018-11-07 08:22:50.080 -03 [3258]: [7-1] user=,db=,app=,client= LOG:  checkpoint starting: end-of-recovery immediate
      2018-11-07 08:22:50.094 -03 [3258]: [8-1] user=,db=,app=,client= LOG:  checkpoint complete: wrote 2 buffers (0.0%); 0 WAL file(s) added, 0 removed, 0 recycled; write=0.004 s, sync=0.002 s, total=0.015 s; sync files=2, longest=0.002 s, average=0.001 s; distance=0 kB, estimate=0 kB
      

      Attachments

        Activity

          People

            jpechane Jiri Pechanec
            psingaretti Paulo Singaretti (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: