??servicenative-sessionnodePortnode??-D
??
-- --
??:
Hi, 卓宇,yidan
当前 Flink service 对外暴露的方式有 3 种[1]，可以参考判断当前环境适合使用哪种
1. ClusterIP
Cluster IP 只能在 Flink 内部使用，如果想在外部访问，需要通过 kubectl port-forward
进行流量转发。这种模式下，Flink 拿到的 JobManager 地址为： {clusterId}-rest.{k8s-namespace}:{rest
port}
ClusterIP 在 1.15 版本调整为默认模式
2. NodePort
NodePort 会在每一台 K8S 节点上转发
更正：
1. Cluster IP 只能在 Flink 内部使用 —-> Cluster IP 只能在 Kubernetes 内部使用
> 2022年4月15日 下午4:12，huweihua 写道：
>
> Flink
退订
退订
我记得这个问题常常是因为 lambda 函数的入参/出参被 shade 了，导致找不到对应的实现类了。不太理解你的意思，但是用 sql-client
使用 sql-jar 应该是没有问题的。建议你代码里面也换成 sql jar 先试试看。
Best,
Shengkai
wangzhen 于2022年4月15日周五 11:57写道：
> 退订
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2022-04-14 22:44:48，"顺其自然" <712677...@qq.com.INVALID> 写道：
> >我的flink 1.12.1 sql cline
退订的同学，请发送任意邮件到 user-zh-unsubscr...@flink.apache.org。
Best，
Shengkai
Shengkai Fang 于2022年4月15日周五 17:34写道：
> 我记得这个问题常常是因为 lambda 函数的入参/出参被 shade 了，导致找不到对应的实现类了。不太理解你的意思，但是用 sql-client
> 使用 sql-jar 应该是没有问题的。建议你代码里面也换成 sql jar 先试试看。
>
> Best,
> Shengkai
>
> wangzhen 于2022年4月15日周五 11:57写道：
>
>> 退订
# Port range for the REST and web server to bind to.
#
rest.bind-port: 8080-8090
??
# Port range for the REST and web server to bind to.
#
rest.bind-port: 8080-8090
# The address that the REST & web server binds to
#
#rest.bind-address: 0.0.0.0
退订的同学，请发送任意邮件到 user-zh-unsubscr...@flink.apache.org。
Best,
Shengkai
yefan 于2022年4月15日周五 16:33写道：
> 退订
Hi, 这个就是 Flink UI 监听的端口号。
Best,
Shengkai
陈卓宇 <2572805...@qq.com.invalid> 于2022年4月15日周五 17:47写道：
> 今天看到这两个配置项，有些遗憾：
> # Port range for the REST and web server to bind to.
> #
> rest.bind-port: 8080-8090
> 这个绑定端口是起到什么作用？
> # The address that the REST & web server binds to
> #
> #rest.bind-address:
退订请发送邮件到 user-zh-unsubscr...@flink.apache.org。
Best,
Shengkai
剑来 <1370505...@qq.com.invalid> 于2022年4月15日周五 16:28写道：
> 退订
退订的同学，请发送任意邮件到 user-zh-unsubscr...@flink.apache.org。
BEST,
Shengkai
王健 <13166339...@163.com> 于2022年4月15日周五 14:40写道：
> 退订
Hello, Luning!
我们目前也正在关注Flink在OLAP场景的性能表现，请问你测试的Flink和Trino版本分别是什么呢？另外我看到flink-sql-benchmark中所使用的集群配置和你的不太一样，可能需要根据集群资源对flink-conf.yaml中taskmanager.memory.process.size等资源配置进行调整。
Best,
Zhilong
On Fri, Apr 15, 2022 at 2:38 PM LuNing Wang wrote:
> 跑了100个 TPC-DS SQL
> 10 GB 数据、2个Worker（TM）、每个32G内存
flinksql??
CREATE TABLE products (
id INT NOT NULL,
NAME STRING,
PRIMARY KEY(id) NOT ENFORCED
) WITH (
'connector' = 'oracle-cdc',
'hostname' = '10.16.16.26',
'port' = '1521',
'username' = 'tmp_test0415',
'password' = 'tmp_test0415',
Best wishes！
Vincent
17 matches
Mail list logo
