ng...@163.com >;
Sent Time:2023/11/7 10:25
To:"Bo"< 99...@qq.com >;
Cc recipient:"Chen Yu"< yuchen.e...@gmail.com >;"user"<
user@flink.apache.org >;
Subject:Re:Re: Auditing sink using table api
Hi, Bo.
Do you means adding a logger sink after th
ector
configurations.
Any thoughts welcome.
Best Regards,
Bo
on/#emit-a-table
发件人: Bo <99...@qq.com>
发送时间: 2023年11月4日 13:53
收件人: user
have some kind of auditing mechanism in place? The only way I could
see now is to make a custom sink that supports detail logging to external
systems.
Any thoughts/suggestions?
Regards,
Bo
The file header says key is NullWritable:
SEQ^F!org.apache.hadoop.io.NullWritable^Yorg.apache.hadoop.io.Text^A^A)org.apache.hadoop.io.compress.SnappyCodec
Might be a hadoop -text problem?
On Sat, 27 Jul 2019 at 11:07, Liu Bo wrote:
> Dear flink users,
>
> We're trying
write value
only in SequenceFileWriter?
Your help will be much of my appreciation.
--
All the best
Liu Bo
r doesn't accept the
offers to start the task manager.
I keep get the log as: flink.log
The task manager doesn't start properly even though there're sufficient
resources..
Thank you in advance, and looking forward for your advices.
Best regards,
Bo
On Tue, Oct 10, 2017 at 12:12
Hello all,
This is Bo, I met some problems when I tried to use flink in my mesos
cluster (1 master, 2 slaves (cpu has 32 cores)).
I tried to start the mesos-appmaster.sh in marathon, the job manager is
started without problem.
mesos-appmaster.sh -Djobmanager.heap.mb=1024 -Dtaskmanager.heap.mb
