Thanks a lot for being our release manager Thomas. Great work! Also thanks
to the community for making this release possible.
Cheers,
Till
On Thu, Dec 27, 2018 at 2:58 AM Jeff Zhang wrote:
> Thanks Thomas. It's nice to have a more stable flink 1.5.x
>
> vino yang 于2018年12月27日周四 上午9:43写道：
>
>>
@Steven: Do you happen do know whether a JIRA exists for this issue?
@Joshua: Does this also happen if you use log4j?
On 26.12.2018 11:33, Joshua Fan wrote:
wow, I met similar situation using flink 1.7 on yarn.
there was no jobmanager.log on the node but jobmanager.out and
jobmanager.error, a
The configuration is not accessible to user-functions or the main method.
The could either override ConfigurableStatebackend#configure, or
configure the statebackend globally (see
https://ci.apache.org/projects/flink/flink-docs-release-1.7/ops/state/state_backends.html#setting-default-state-bac
Hi everyone,
I recently attempted to create a Flink cluster on YARN by executing the
following:
~/flink-1.5.4/bin/yarn-session.sh -n 5 -tm 2048 -s 4 -d -nm flink_yarn
The resulting command was not completely successful but it did end up creating
a Apache Flink Dashboard with 1 Task Manager, 1 T
Hi Experts,
From github I saw flink 1.7.1 is released about 7days ago. But I still
can not downloaded from maven repository.
May I know why there are some lag between them? When could the jar be
downloaded from maven repository?
Best
Henry
Hi Jiayichao,
The two methods do not have to appear in pairs, so you can't use
timestamp.getTime() directly.
Currently, Flink doesn't support time zone configuration. The
timestamp(time of type Timestamp) always means the time in UTC+0. So in the
test of your pr[1], the output timestamp means a ti
Hi, yinhua
Thanks for looking into the problem. I'm not familiar with the code of
these part. As a workaround, you can put your jars into the flink lib
folder or add your jars into the classpath. Hope this helps.
Best, Hequn
On Fri, Dec 28, 2018 at 11:52 AM yinhua.dai wrote:
> I am using Flin
