退订

[maozhaolin]

退订

Re: 退订

[JING ZHANG]

Hi,
To unsubscribe emails from Flink dev mail list, send an email to
dev-unsubscr...@flink.apache.org

To unsubscribe emails from Flink user mail list, send an email to
user-unsubscr...@flink.apache.org

To unsubscribe emails from Flink user -zh mail list, send an email to
user-zh-unsubscr...@flink.apache.org

For more information, please go to [1].

[1] https://flink.apache.org/community.html#mailing-lists

Best,
JING ZHANG

maozhaolin  于2021年9月26日周日 下午3:28写道：

> 退订

flink编译问题

[Martin MA]

Hi team,

我 从master分支上clone了最新的flink代码，尝试在centOS7下编译，发现以下错误：

[image: image.png]

编译命令：
 mvn clean install -DskipTests -Dscala-2.12 -rf
:flink-avro-confluent-registry

在此之前使用mvn clean install -DskipTests -Dscala-2.12编译报如下错误：
[image: image.png]

于是我从mvn repo手动下载了jar包，并使用以下命令再次编译：
mvn install:install-file -DgroupId=io.confluent
-DartifactId=kafka-schema-registry-client -Dversion=5.5.2 -Dpackaging=jar
-Dfile=kafka-schema-registry-client-5.5.2.jar

请问该如何解决？Thanks

Re: flink编译问题

[Martin MA]

BTW，忘记说明环境情况了：
Java 1.8.0_281
Scala 2.12.15
Maven 3.6.3

Martin MA  于2021年9月26日周日 下午11:30写道：

> Hi team,
>
> 我 从master分支上clone了最新的flink代码，尝试在centOS7下编译，发现以下错误：
>
> [image: image.png]
>
> 编译命令：
>  mvn clean install -DskipTests -Dscala-2.12 -rf
> :flink-avro-confluent-registry
>
> 在此之前使用mvn clean install -DskipTests -Dscala-2.12编译报如下错误：
> [image: image.png]
>
> 于是我从mvn repo手动下载了jar包，并使用以下命令再次编译：
> mvn install:install-file -DgroupId=io.confluent
> -DartifactId=kafka-schema-registry-client -Dversion=5.5.2 -Dpackaging=jar
> -Dfile=kafka-schema-registry-client-5.5.2.jar
>
> 请问该如何解决？Thanks
>

Re: Flink Session 模式Job日志区分

[Ada Luna]

我这个是Flink SQL任务

陈卓宇 <2572805...@qq.com.invalid> 于2021年9月23日周四 下午3:57写道：
>
> 你不同job任务日志上做一个区别LOG_PREFIX private static final String LOG_PREFIX = 
> "【WF事件组件下发缓存处理器】";
> log.info("|prefix={} ☀️☀️☀️☀️ 进行订阅事件缓存处理开始|message={}|componentEvent={}|", 
> LOG_PREFIX, message, componentEvent);
>
>
>
> 陈卓宇
>
>
>  
>
>
>
>
> -- 原始邮件 --
> 发件人:  
>   "user-zh"   
>  
>  发送时间: 2021年9月23日(星期四) 中午11:16
> 收件人: "user-zh"
> 主题: Flink Session 模式Job日志区分
>
>
>
> 多个Job跑在一个Session中，如何区分不同job的日志呢？目前有什么好的办法吗？

Re: 退订

[Leonard Xu]

如果需要取消订阅 user-zh@flink.apache.org  
邮件组，请发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 
  即可

Best,
Leonard

> 在 2021年9月26日，14:25，luoye <13033709...@163.com> 写道：
> 
> 退订

Re: mysql cdc入hudi湖出错

[Leonard Xu]

Hi, chan

完整的日志能贴下吗？这个日志还看不出来。



> 在 2021年9月24日，18:23，casel.chen  写道：
> 
> SELECT `id`, `name`, `birthday`, `ts`, DATE_FORMAT(`birthday`, 'MMdd') AS 
> `partition` FROM mysql_users;

flink-1.12.5 ????HIVDE DDL ????????comment??????hive????????????????comment

[kcz]

hive3.1.0
ddl:
create table test_hive(
 id int comment 'test comment'
) PARTITIONED BY (dt STRING) STORED AS orc TBLPROPERTIES (
   'partition.time-extractor.kind'='custom',
   'partition.time-extractor.timestamp-pattern'='$dt',
  
 'partition.time-extractor.class'='com.hycan.bigdata.utils.MyPartTimeExtractor',
   'sink.partition-commit.trigger'='partition-time',
   'sink.partition-commit.delay'='1 d',
   'sink.partition-commit.policy.kind'='metastore,success-file'
);

hive desc formatted test_hive comment

GroupWindowAggregate doesn't support consuming update and delete changes which is produced by node Deduplicate

[lzy139...@outlook.com]

使用ROW_NUMBER过滤数据后，进行开窗聚合计算报错

flink 1.13.2 ????avg??????int????????????????????????int??????????????????

[Asahi Lee]

hi!      ??flink 1.13.2?? int 
??avg?? int  
double??decimal??bug

退订

[rzy1107]

退订