allnode-github opened a new issue #12264:
URL: https://github.com/apache/pulsar/issues/12264
一：
Caused by: org.postgresql.util.PSQLException: 错误: null value in column "id"
of relation "pulsar_postgres_jdbc_sink" violates not-null constraint
详细：失败, 行包含(null, null).
... 14 more
00:00:08.430 [pool-6-thread-1] ERROR
org.apache.pulsar.io.jdbc.JdbcAbstractSink - Update count 1 not match total
number of records 2
00:00:24.373 [pulsar-timer-6-1] INFO
org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl -
[pulsar-postgres-jdbc-sink-topic] [public/default/pulsar-postgres-jdbc-sink]
[a87a1] Prefetched messages: 0 --- Consume throughput received: 1.00 msgs/s ---
0.00 Mbit/s --- Ack sent rate: 0.00 ack/s --- Failed messages: 0 --- batch
messages: 0 ---Failed acks: 0
00:00:25.424 [pool-6-thread-1] ERROR
org.apache.pulsar.io.jdbc.JdbcAbstractSink - Got exception
org.postgresql.util.PSQLException: 错误: 当前事务被终止, 事务块结束之前的查询被忽略
at
org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2533)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2268)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:313)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:448)
~[postgresql-42.2.12.jar:42.2.12]
at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:369)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:159)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.execute(PgPreparedStatement.java:148)
~[postgresql-42.2.12.jar:42.2.12]
at
org.apache.pulsar.io.jdbc.JdbcAbstractSink.flush(JdbcAbstractSink.java:203)
~[pulsar-io-jdbc-core-2.8.1.jar:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
[?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: org.postgresql.util.PSQLException: 错误: null value in column "id"
of relation "pulsar_postgres_jdbc_sink" violates not-null constraint
详细：失败, 行包含(null, null).
... 14 more
00:00:28.424 [pool-6-thread-1] ERROR
org.apache.pulsar.io.jdbc.JdbcAbstractSink - Got exception
org.postgresql.util.PSQLException: 错误: 当前事务被终止, 事务块结束之前的查询被忽略
at
org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2533)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2268)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:313)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:448)
~[postgresql-42.2.12.jar:42.2.12]
at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:369)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:159)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.execute(PgPreparedStatement.java:148)
~[postgresql-42.2.12.jar:42.2.12]
at
org.apache.pulsar.io.jdbc.JdbcAbstractSink.flush(JdbcAbstractSink.java:203)
~[pulsar-io-jdbc-core-2.8.1.jar:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
[?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: org.postgresql.util.PSQLException: 错误: null value in column "id"
of relation "pulsar_postgres_jdbc_sink" violates not-null constraint
详细：失败, 行包含(null, null).
... 14 more
00:00:29.424 [pool-6-thread-1] ERROR
org.apache.pulsar.io.jdbc.JdbcAbstractSink - Got exception
org.postgresql.util.PSQLException: 错误: 当前事务被终止, 事务块结束之前的查询被忽略
at
org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2533)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2268)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:313)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:448)
~[postgresql-42.2.12.jar:42.2.12]
at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:369)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:159)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.execute(PgPreparedStatement.java:148)
~[postgresql-42.2.12.jar:42.2.12]
at
org.apache.pulsar.io.jdbc.JdbcAbstractSink.flush(JdbcAbstractSink.java:203)
~[pulsar-io-jdbc-core-2.8.1.jar:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
[?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: org.postgresql.util.PSQLException: 错误: null value in column "id"
of relation "pulsar_postgres_jdbc_sink" violates not-null constraint
详细：失败, 行包含(null, null).
... 14 more
00:00:29.924 [pool-6-thread-1] ERROR
org.apache.pulsar.io.jdbc.JdbcAbstractSink - Got exception
org.postgresql.util.PSQLException: 错误: 当前事务被终止, 事务块结束之前的查询被忽略
at
org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2533)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2268)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:313)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:448)
~[postgresql-42.2.12.jar:42.2.12]
at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:369)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:159)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.execute(PgPreparedStatement.java:148)
~[postgresql-42.2.12.jar:42.2.12]
at
org.apache.pulsar.io.jdbc.JdbcAbstractSink.flush(JdbcAbstractSink.java:203)
~[pulsar-io-jdbc-core-2.8.1.jar:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
[?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: org.postgresql.util.PSQLException: 错误: null value in column "id"
of relation "pulsar_postgres_jdbc_sink" violates not-null constraint
详细：失败, 行包含(null, null).
... 14 more
00:00:30.924 [pool-6-thread-1] ERROR
org.apache.pulsar.io.jdbc.JdbcAbstractSink - Got exception
org.postgresql.util.PSQLException: 错误: 当前事务被终止, 事务块结束之前的查询被忽略
at
org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2533)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2268)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:313)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:448)
~[postgresql-42.2.12.jar:42.2.12]
at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:369)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:159)
~[postgresql-42.2.12.jar:42.2.12]
at
org.postgresql.jdbc.PgPreparedStatement.execute(PgPreparedStatement.java:148)
~[postgresql-42.2.12.jar:42.2.12]
at
org.apache.pulsar.io.jdbc.JdbcAbstractSink.flush(JdbcAbstractSink.java:203)
~[pulsar-io-jdbc-core-2.8.1.jar:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
[?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: org.postgresql.util.PSQLException: 错误: null value in column "id"
of relation "pulsar_postgres_jdbc_sink" violates not-null constraint
详细：失败, 行包含(null, null).
... 14 more
00:00:48.424 [pool-6-thread-1] ERROR
org.apache.pulsar.io.jdbc.JdbcAbstractSink - Got exception
org.postgresql.util.PSQLException: 错误: 当前事务被终止, 事务块结束之前的查询被忽略
at
org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2533)
~[postgresql-42.2.12.jar:42.2.12]
二： {"id":1,"name":"adsasda"},The tested client publications and
subscriptions are also normal.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
