Re: 退订

退订 On Thu, Jul 27, 2023 at 2:40 PM 许琦 wrote: > *退订*

退订

*退订*

Custom TCP server socket source

Hello, I need to write "Custom server socket source" which accepts client connections over a port. 1. How to scale it across task managers with parallelism <= no. of task managers and with same single port 2. This is needed w.r.t Kubernetes POD deployment model where each POD is

Re: Flink netty connector for TCP source

I cannot find any information about netty source in flink website and it is not in the connector list[1], so I'm think that it is not supported by flink community [1] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/overview/ Best, Shammon FY On Thu, Jul 27, 2023

Re: 如何把自己新增的定制化connector deploy snapshot版本到私服仓库

你好， 通常在 pom 中引入 maven-deploy-plugin，并且通过 声明私服地址，使用 mvn clean deploy 命令部署到nexus私服。 部署到 SNAPSHOT 仓库需要项目版本号包含 -SNAPSHOT 后缀，可以在IDE中全局替换，也可以使用 versions-maven-plugin 统一设置。 org.apache.maven.plugins maven-deploy-plugin 2.8.2

RE: Flink netty connector for TCP source

Hello Shammon, Yes socket text stream I am aware of but was thinking if something like as ‘https://github.com/apache/bahir-flink/tree/master/flink-connector-netty’ is also supported by Flink? Rgds, Kamal From: Shammon FY Sent: 27 July 2023 08:15 AM To: Kamal Mittal Cc: user@flink.apache.org

如何把自己新增的定制化connector deploy snapshot版本到私服仓库

我是基于flink 1.16.0开发的，由于版本号没有snapshot，现在又无法发布release版本的，我该怎么办？

Re: Flink netty connector for TCP source

Hi Kamal, There's socket text stream in `DataStream` and you can refer to [1] for more details. [1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/overview/#example-program Best, Shammon FY On Wed, Jul 26, 2023 at 4:26 PM Kamal Mittal via user wrote: > Hello, > > >

RE: Suggestions for Open Source FLINK SQL editor

Hi Rajat, I think Apache StreamPark(Incubating) or Apache Zeppelin is a good choice. https://streampark.apache.org/ https://zeppelin.apache.org/ Best, Jiabao On 2023/07/19 16:47:43 Rajat Ahuja wrote: > Hi team, > > I have set

Re:RE: flink如何正确使用mybatis

好的，谢谢老师 在 2023-07-26 21:04:20，"Jiabao Sun" 写道： >SqlSession 需要关闭，建议使用 SqlSessionManager，可以不用手动关闭 SqlSession。 > > >On 2023/07/18 02:13:16 lxk wrote: >> 在flink内需要使用mybatis做些简化查询的工作，目前我的使用方式如下 >> >> public class MybatisUtil { >> >> private static final Logger LOGGER = >>

RE: flink如何正确使用mybatis

SqlSession 需要关闭，建议使用 SqlSessionManager，可以不用手动关闭 SqlSession。 On 2023/07/18 02:13:16 lxk wrote: > 在flink内需要使用mybatis做些简化查询的工作，目前我的使用方式如下 > > public class MybatisUtil { > > private static final Logger LOGGER = > LogFactory.createNewLogger("MybatisUtil"); > private static ThreadLocal tl = new

RE: Re: flink configuration in flink kubernetes operator question about password

Hi tian tian, I think we can use podTemplate to mount kubernetes secrets as file or environment variables. Then we can access the secrets in our flink program. Please refers to https://github.com/apache/flink-kubernetes-operator/blob/main/examples/pod-template.yaml

退订

退订 | | lei-tian | | totorobabyf...@163.com |

Flink netty connector for TCP source

Hello, Does flink provides netty connector for custom TCP source? Any documentation details please share? Rgds, Kamal

回复: 关于DataStream API计算批数据的聚合值

你好，感谢回复。我使用reduce解决了问题。 祝好运。 发件人: weijie guo 发送时间: 2023年7月26日 10:50 收件人: user-zh@flink.apache.org 主题: Re: 关于DataStream API计算批数据的聚合值 你好： Batch 模式下的 reduce 操作默认应该就是只输出最后一条数据(per-key)的。Agg 的话可能有点麻烦，可以使用 GlobalWindow + 自定义 Trigger 来 Workaround. Best regards,

Re: 退订

退订 wang <24248...@163.com> 于2023年7月13日周四 07:34写道： > 退订 -- Best Regards, *Yaohua Wang 王耀华* School of Software Technology, Xiamen University Tel: (+86)187-0189-5935 E-mail: wangyaohua2...@gmail.com

退订

*退订*