Hi all,
I'm kind of new to flink cluster deployment. I wanted to know which flink
cluster deployment and which job mode in aws is better in terms of ease of
deployment, maintenance, HA, cost, etc. As of now I am considering aws EMR
vs ECS (docker containers). We have a usecase of setting up a data
Timo Walther created FLINK-18890:
Summary: Update AsyncTableFunctions to the new type system
Key: FLINK-18890
URL: https://issues.apache.org/jira/browse/FLINK-18890
Project: Flink
Issue Type:
Hi Till,
The problem is reproducible with a basic shell script doing the following
operations.
1. Post request to /jobs/${JOB_ID}/savepoints with the payload
{"cancel-job": true,"target-directory": $(LOCATION)}
and store the trigger ID
2. Sleep 10 seconds
3. Get jobs/${JOB_ID}
Does this mean this is a valid issue?
If so, we could track it as a starter issue?
On Mon, Aug 3, 2020 at 10:59 AM Aljoscha Krettek
wrote:
> Thanks for the pointer!
>
> On 03.08.20 10:29, Till Rohrmann wrote:
> > Hi Xia Rui,
> >
> > thanks for reporting this issue. I think FLINK-15116 [1] caused
Peng created FLINK-18891:
Summary: flink job failed but yarn application still running via
yarn-per-job mode
Key: FLINK-18891
URL: https://issues.apache.org/jira/browse/FLINK-18891
Project: Flink
Is
Big +1 for this FLIP.
Recently I'm working on some Kafka topics that have timestamps as
metadata, not in the message body. I want to declare a table from the
topics with DDL but "rowtime_column_name" in seems
to accept only existing columns.
> :
> WATERMARK FOR rowtime_column_name AS watermar
Hi Sidhant,
I am not an expert on AWS services but I believe that EMR might be a bit
easier to start with since AWS EMR comes with Flink support out of the box
[1]. On ECS I believe that you would have to set up the containers
yourself. Another interesting deployment option could be to use Flink's
The content length of FLIP-107 is relatively short but the scope and
implications it will cause is actually very big.
>From what I can tell now, I think there is a good chance that we can
deliver part of this FLIP in 1.12, e.g.
accessing the metadata field just like you mentioned.
Best,
Kurt
On
This sounds like a bug in Flink. Could you share the logs of the cluster
(ideally with TRACE log level) with us?
Cheers,
Till
On Tue, Aug 11, 2020 at 9:49 AM Fabian Paul
wrote:
> Hi Till,
>
> The problem is reproducible with a basic shell script doing the following
> operations.
>
> 1. Post req
Hi everyone,
Please review and vote on the release candidate #1 for the version 1.10.2,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
+1 (binding)
On Sun, Aug 9, 2020 at 8:15 PM jincheng sun
wrote:
> Hi Seth,
>
> Thank you for joining the discussion and voting. Could you please have a
> look at the discussion thread.
> It would be great to know that did the follow-up discussion allay your
> concerns and any feedback is welcom
Igor Dvorzhak created FLINK-18892:
-
Summary: Upgrade Guava to version 28.2-jre
Key: FLINK-18892
URL: https://issues.apache.org/jira/browse/FLINK-18892
Project: Flink
Issue Type: Task
Affe
Robert Metzger created FLINK-18893:
--
Summary: Python tests fails with "AppendStreamTableSink requires
that Table has only insert changes."
Key: FLINK-18893
URL: https://issues.apache.org/jira/browse/FLINK-18893
Seth Wiesman created FLINK-18894:
Summary: StateFun job stalls on stop-with-savepoint
Key: FLINK-18894
URL: https://issues.apache.org/jira/browse/FLINK-18894
Project: Flink
Issue Type: Improv
Pasha Shaik created FLINK-18895:
---
Summary: Not able to access Flink 1.7.2 with HDP 3.0.1 cluster
Key: FLINK-18895
URL: https://issues.apache.org/jira/browse/FLINK-18895
Project: Flink
Issue Typ
Feng Jie created FLINK-18896:
Summary: Translate "stateful-functions" page into Chinese
Key: FLINK-18896
URL: https://issues.apache.org/jira/browse/FLINK-18896
Project: Flink
Issue Type: Improvem
+1 (binding)
Thanks,
Dian
> 在 2020年8月11日，下午10:41，Seth Wiesman 写道：
>
> +1 (binding)
>
> On Sun, Aug 9, 2020 at 8:15 PM jincheng sun
> wrote:
>
>> Hi Seth,
>>
>> Thank you for joining the discussion and voting. Could you please have a
>> look at the discussion thread.
>> It would be great to
+1 (non-binding)
Best,
Wei
> 在 2020年8月11日，22:41，Seth Wiesman 写道：
>
> +1 (binding)
>
> On Sun, Aug 9, 2020 at 8:15 PM jincheng sun
> wrote:
>
>> Hi Seth,
>>
>> Thank you for joining the discussion and voting. Could you please have a
>> look at the discussion thread.
>> It would be great to
+1 (binding)
Best,
Hequn
On Wed, Aug 12, 2020 at 10:12 AM Wei Zhong wrote:
> +1 (non-binding)
>
> Best,
> Wei
>
> > 在 2020年8月11日，22:41，Seth Wiesman 写道：
> >
> > +1 (binding)
> >
> > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun
> > wrote:
> >
> >> Hi Seth,
> >>
> >> Thank you for joining the di
+1 (non-binding)
Best,
Xingbo
Wei Zhong 于2020年8月12日周三 上午10:12写道：
> +1 (non-binding)
>
> Best,
> Wei
>
> > 在 2020年8月11日，22:41，Seth Wiesman 写道：
> >
> > +1 (binding)
> >
> > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun
> > wrote:
> >
> >> Hi Seth,
> >>
> >> Thank you for joining the discussion a
+1 (non-binding)
Best,
Shuiqiang
Dian Fu 于2020年8月12日周三 上午10:10写道：
> +1 (binding)
>
> Thanks,
> Dian
>
> > 在 2020年8月11日，下午10:41，Seth Wiesman 写道：
> >
> > +1 (binding)
> >
> > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun
> > wrote:
> >
> >> Hi Seth,
> >>
> >> Thank you for joining the discussion
+1 (binding)
Best,
Jincheng
Shuiqiang Chen 于2020年8月12日周三 上午10:18写道：
> +1 (non-binding)
>
> Best,
> Shuiqiang
>
> Dian Fu 于2020年8月12日周三 上午10:10写道：
>
> > +1 (binding)
> >
> > Thanks,
> > Dian
> >
> > > 在 2020年8月11日，下午10:41，Seth Wiesman 写道：
> > >
> > > +1 (binding)
> > >
> > > On Sun, Aug 9, 2
Jark Wu created FLINK-18897:
---
Summary: Add documentation for the maxwell-json format
Key: FLINK-18897
URL: https://issues.apache.org/jira/browse/FLINK-18897
Project: Flink
Issue Type: Sub-task
+1 for FLIP-107
Reading different parts of source code should be the key feature for Flink SQL,
like metadata in CDC data, key and timestamp in Kafka records.
The scope of FLIP-107 is too big to finish in one version IMO, maybe we can
start part work in 1.12.
Best
Leonard
> 在 2020年8月11日，19:5
Aki Tanaka created FLINK-18898:
--
Summary: .flink-runtime.version.properties file does not exist in
flink-dist.jar
Key: FLINK-18898
URL: https://issues.apache.org/jira/browse/FLINK-18898
Project: Flink
Hi
退订请 发邮件到 user-zh-unsubscr...@flink.apache.org
详细的可以参考 [1]
[1] https://flink.apache.org/zh/community.html#section-1
Best,
Congxian
智子 <769257...@qq.com> 于2020年8月12日周三 上午11:15写道：
>
Hi
Please send an email to dev-unsubscr...@flink.apache.org for
unsubscribing.
You can read more information[1] here
PS: I use Chinses because I thought that the email was sent to user-zh
mail list.
[1] https://flink.apache.org/community.html
Best,
Congxian
Congxian Qiu 于2020年8月12日周三
28 matches
Mail list logo
