- Trying to connect to address /127.0.0.1:37133
2018-08-17 10:46:45,325 INFO org.apache.flink.runtime.net.ConnectionUtils-17 10:46:45,325 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect:45,325 INFO org.apache.flin
浏览 3提问于2018-08-17得票数 0
1回答
$ftp_user_name = "***"; // Username$conn_id = ftp_connect($ftp_server
浏览 1提问于2012-07-24得票数 0
我试图在纱线集群上运行示例代码(flink_examples_WordCount.jar)，但得到了下面的安全身份验证错误。此外，在执行flink run命令时，我尝试在HDFS文件路径中给出主机:端口。at org.apache.flink.client.program.Client.run(Client.java:356)
at org.apache.flink.client.program.Client.runat org.apache.flink.client.CliFronten
浏览 5提问于2015-08-19得票数 1
Apache Spark <-> Solr Bitnami Data Platform 我找不到具体的例子说明这是如何工作的，但我也在问自己，是否有任何解决方案 Apache Kafka <-> Kafka Connect此外，可能聚合mit Kafka <-> Kafka Connect Solr <-> Solr仅适用于Kafka中的一个主题，所以如果我必须组合来自2个或更多不同主题和聚合的数据，那么Kafka，Spark
浏览 34提问于2021-11-11得票数 0
cluster with JobManager at localhost/127.0.0.1:6123 at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)at java.net.Socket.connect(Socket.java:589)
at org.apache.<
浏览 516提问于2018-12-15得票数 3
我正在尝试读取Kafka主题中的记录，该主题是由kafka connect jdbc源连接器生成的，以下是连接器配置： "name": "customers", "poll.interval.ms"connection.user": "sa", "key.converter": "i
浏览 670提问于2021-02-01得票数 0
回答已采纳
2回答
org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1053) at java.net.AbstractPlainSocketImpl.connect(AbstractP
浏览 0提问于2018-11-17得票数 0
回答已采纳
1回答
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)at java.net.Socket.connect(Socket.java:589
浏览 3提问于2016-03-11得票数 2
回答已采纳
我的项目目前构建在Azure上(数据存储在Azure SQL server中)，我目前正在尝试通过利用PyFilnk将流/批处理功能引入到我的项目中。但是，我没有找到任何关于如何将PyFlink连接到Azure SQL server的文档，有没有一种方法可以在PyFlink中使用Azure SQL server作为数据源？
浏览 13提问于2021-07-22得票数 0
当我尝试使用start-clusted.sh和Flink在本地运行它时，我没有问题。java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
java.net.Sock
浏览 4提问于2016-10-19得票数 2
回答已采纳
2回答
我有一个带有独立模式的Apache Flink集群，我想配置Flink Metrics。java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net.SocksSocketImpl.connect(SocksS
浏览 31提问于2019-01-17得票数 1
回答已采纳
下面是SBT配置libraryDependencies += "org.apache.flink" %% "flink-scala" % "1.9.1"
// https://mvnrepository.com/
浏览 1提问于2020-02-27得票数 1
回答已采纳
- Could not resolve ResourceManager address akka.tcp://flink@flink-jobmanager:6123/user/resourcemanager, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@flink-jobmanager- Could not resol
浏览 277提问于2020-05-01得票数 0
1回答
我在Flink SQL中使用CEP模式，它正在按预期工作，连接到Kafka broker。但是当我连接到基于集群的云kafka设置时，Flink CEP并没有触发。":1635206501735,"row_time":"2021-10-25 16:07:09.019Z"} )
每一条卡夫
浏览 1提问于2021-10-25得票数 0
回答已采纳
.
import org.apache.flink.api.java.utils.ParameterToolparameters to be set * - "zookeeper.connectYou can pass these requi
浏览 29提问于2020-01-19得票数 0
我正在使用flink elastic search连接器将数据发送到elastic search index。 at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory
浏览 16提问于2017-06-08得票数 0
TimeCharacteristic.EventTime)
.topic("user") .property("zookeeper.connectThe following properties are requested:
co
浏览 4提问于2018-09-25得票数 0
1回答
- Trying to connect to address /10.127.68.136:348112016-03-02 18:01:14,082 INFO org.apache.flink.r
浏览 1提问于2016-03-31得票数 3
回答已采纳
}
try (Session session = cluster.connect127.0.0.1:9042 (com.datastax.driver.core.exceptions.TransportException: [localhost/127.0.0.1] Cannot connectcom.datastax.driver.core.ControlConnection.reconnectInternal(Control
浏览 36提问于2020-08-31得票数 0
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
