小编ras*_*jay的帖子

由于SocketException,RabbitMQ新连接被拒绝

在尝试创建与另一台服务器上运行的rabbitmq的新连接时,我收到以下错误:

java.io.IOException
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106)
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124)
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:406)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:516)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533)


Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; reason: java.net.SocketException: Connection reset


at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343)
at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:216)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)



Caused by: java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(Unknown Source)
at java.net.SocketInputStream.read(Unknown Source)
at java.io.BufferedInputStream.fill(Unknown Source)
at java.io.BufferedInputStream.read(Unknown Source)
at java.io.DataInputStream.readUnsignedByte(Unknown Source)
at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95)
at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:131)
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:533)
Run Code Online (Sandbox Code Playgroud)

采取的步骤:

  • rabbitmq正在服务器上运行.
  • 服务器已指定
  • 指定了默认端口

lsof -i tcp:5672

命令PID用户FD类型设备大小/关闭节点名称

beam.smp 3084 rabbitmq 15u IPv6 18611 0t0 TCP*:amqp(LISTEN)

rabbitmqctl list_connections

列出连接... guest client_server …

java connection amqp rabbitmq

17
推荐指数
2
解决办法
3万
查看次数

Pentaho Kettle:如何在Job和Transformation中使用相同的数据库连接

我有一份工作,并进行了多种转换。如果我想在Job中定义数据库连接,并对所有转换使用相同的数据库连接,我该如何处理?我正在使用社区版本的Pentaho 5.0版本。

我使用勺子在本地创建作业,然后将其移动到Linux服务器,在该服务器中,我将使用kitchen.sh执行作业和转换。

谢谢。

etl pentaho kettle

4
推荐指数
1
解决办法
4024
查看次数

Pentaho 维度查找/更新

我在这里看到了维度查找/更新文档和其他一些博客。但我似乎无法得到一个清晰的想法。我有一个具有以下结构的表:

 Key Name Code Status IN Out Active
Run Code Online (Sandbox Code Playgroud)

来自key name code status activecsv 文件。我需要对 scd type2 使用维度查找/更新步骤并填充IN/Out.

设置连接详细信息后,我已KEY 使用选项将键设置为并将字段设置为所有其他字段Date of last insert (without stream field as source)。如果任何其他字段发生更改,我需要在数据库中创建一个新行。该行将具有相同key且更新的详细信息,设置out为无穷大并in设置为当前系统日期。

日期范围开始字段设置为IN,表日期范围结束字段设置为OUT数据库列。

我不明白这个技术密钥的概念,因为密钥也来自 csv 文件。

当我点击预览时出现错误:

   DB2 SQL error: SQLCODE: -407, SQLSTATE: 23502, SQLERRMC: 
Run Code Online (Sandbox Code Playgroud)

请让我知道更多详细信息以及我错过的任何步骤或设置。

csv etl pentaho kettle

2
推荐指数
1
解决办法
4664
查看次数

标签 统计

etl ×2

kettle ×2

pentaho ×2

amqp ×1

connection ×1

csv ×1

java ×1

rabbitmq ×1