Re: How to change the flink web-ui jobServer?

[tison]

IIRC Flink on Kubernetes doesn't support configure rest port as port range.

Maybe Yang(in cc) can give more information and if so, our current logic
only take care of RestOptions.PORT but not RestOptions.BIND_PORT, which
will be a bug.

Best,
tison.


LakeShen  于2020年3月15日周日 上午11:25写道：

> Ok, thanks! Arvid
>
> Arvid Heise  于2020年3月10日周二 下午4:14写道：
>
>> Hi LakeShen,
>>
>> you can change the port with
>>
>> conf.setInteger(RestOptions.PORT, 8082);
>>
>> or if want to be on the safe side specify a range
>>
>> conf.setString(RestOptions.BIND_PORT, "8081-8099");
>>
>>
>> On Mon, Mar 9, 2020 at 10:47 AM LakeShen 
>> wrote:
>>
>>> Hi community,
>>>now I am moving the flink job to k8s,and I plan to use the
>>> ingress to show the flink web ui  , the problem is that fink job server
>>> aren't correct, so I want to change the flink web-ui jobserver ,I don't
>>> find the any method  to change it ,are there some method to do that?
>>>Thanks to your reply.
>>>
>>> Best wishes,
>>> LakeShen
>>>
>>

Re: How to change the flink web-ui jobServer?

[LakeShen]

Ok, thanks! Arvid

Arvid Heise  于2020年3月10日周二 下午4:14写道：

> Hi LakeShen,
>
> you can change the port with
>
> conf.setInteger(RestOptions.PORT, 8082);
>
> or if want to be on the safe side specify a range
>
> conf.setString(RestOptions.BIND_PORT, "8081-8099");
>
>
> On Mon, Mar 9, 2020 at 10:47 AM LakeShen 
> wrote:
>
>> Hi community,
>>now I am moving the flink job to k8s,and I plan to use the ingress
>> to show the flink web ui  , the problem is that fink job server aren't
>> correct, so I want to change the flink web-ui jobserver ,I don't find the
>> any method  to change it ,are there some method to do that?
>>Thanks to your reply.
>>
>> Best wishes,
>> LakeShen
>>
>

Re: ddl

[王志华]

好的 感谢


| |
王志华
|
|
a15733178...@163.com
|
签名由网易邮箱大师定制


On 03/14/2020 11:13，LakeShen wrote：
Hi 志华，
你可以完全自己扩展 Flink SQL DDL 语法的功能，用来支持你们公司自己的实时数据源，或者 Sink
等等，具体实现，请参考楼上 jinhai
的链接

Best wishes,
沈磊

jinhai wang  于2020年3月13日周五 下午7:22写道：

Page on “User-defined Sources & Sinks”. For flink 1.10:
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html
<
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html


Best Regards

jinhai...@gmail.com

2020年3月13日 下午7:17，王志华  写道：

目前FLINK中对于DDL这块，它都只能什么类型的技术作为源头表或者SINK 表呢，我也网上也仅仅看到了ddl mysql sink、ddl
hbase sink等。还有其他类型的支持吗？如果不支持的话，是否flink开放了相关的接口，可以提供对其他类型技术的ddl语法支持呢？比如想做一个
ddl kudu sink之类的


| |
王志华
|
|
a15733178...@163.com
|
签名由网易邮箱大师定制