Thanks Terry for bringing this up. TableEnv's interface is really critical
not only
to users, but also for components built upon it like SQL CLI. Your proposal
solved some pain points we currently have, so +1 to the proposal.
I left some comments in the document.
Best,
Kurt
On Thu, Oct 31,
Hi, everyone~
Sorry so late to reply this this thread again.
I am working on FLIP-84 recently to make sql api support return value which
this flip depends on.
I think it’s time to pick up this discussion again and there are some new
updates in this flip design:
+1 (non-binding)
Very thanks for bringing this to the community!
--
From:jincheng sun
Send Time:2019 Oct. 31 (Thu.) 10:22
To:dev
Cc:Vasiliki Kalavri
Subject:Re: [VOTE] Accept Stateful Functions into Apache Flink
big +1
Hi everyone,
TableEnvironment has provided two `Table sqlQuery(String sql)` and `void
sqlUpdate(String sql)` interfaces to create a table(actually a view here) or
describe an update action from one sql string.
But with more use cases come up, there are some fatal shortcomings in current
API
big +1 (binding)
Andrey Zagrebin 于2019年10月30日 周三23:45写道：
> sorry, my +1 was non-binding, confused that it was not a committer vote but
> PMC.
>
> On Wed, Oct 30, 2019 at 4:43 PM Chesnay Schepler
> wrote:
>
> > +1 (binding)
> >
> > On 30/10/2019 15:25, Vasiliki Kalavri wrote:
> > > +1 (binding)
Thanks for your attentions!
@shixiaoga...@gmail.com
Yes correct. We try to avoid jobs affect one another. Also a local
ClusterClient
in case saves the overhead about retry before leader elected and persist
JobGraph before submission in RestClusterClient as well as the net cost.
@Paul Lam
1.
Bowen Li created FLINK-14579:
Summary: enable SQL CLI to configure modules via yaml config
Key: FLINK-14579
URL: https://issues.apache.org/jira/browse/FLINK-14579
Project: Flink
Issue Type:
Bowen Li created FLINK-14580:
Summary: add HiveModuleFactory, HiveModuleDescriptor, and
HiveModuleValidator
Key: FLINK-14580
URL: https://issues.apache.org/jira/browse/FLINK-14580
Project: Flink
Bowen Li created FLINK-14578:
Summary: load/unloadModule() should throw RuntimeException rather
than checked exception
Key: FLINK-14578
URL: https://issues.apache.org/jira/browse/FLINK-14578
Project:
Nikita Ryanov created FLINK-14577:
-
Summary: Hortonworks schema registry support for avro
deserialization
Key: FLINK-14577
URL: https://issues.apache.org/jira/browse/FLINK-14577
Project: Flink
Gary Yao created FLINK-14576:
Summary: Elasticsearch (v6.3.1) sink end-to-end test instable
Key: FLINK-14576
URL: https://issues.apache.org/jira/browse/FLINK-14576
Project: Flink
Issue Type: Bug
Hi guys,
during our upgrade from 1.8.1 to 1.9.1, one of our jobs fail to start with
the following exception. We deploy the job with 'allow-non-restored-state'
option and from the latest checkpoint dir of the 1.8.1 version.
org.apache.flink.util.StateMigrationException: The new state
sorry, my +1 was non-binding, confused that it was not a committer vote but
PMC.
On Wed, Oct 30, 2019 at 4:43 PM Chesnay Schepler wrote:
> +1 (binding)
>
> On 30/10/2019 15:25, Vasiliki Kalavri wrote:
> > +1 (binding) from me. I hope this is not too late :)
> >
> > Thank you for this great
+1 (binding)
On 30/10/2019 15:25, Vasiliki Kalavri wrote:
+1 (binding) from me. I hope this is not too late :)
Thank you for this great contribution!
On Wed, 30 Oct 2019 at 14:45, Stephan Ewen wrote:
Thank you all for voting.
The voting period has passed, but only 13 PMC members have
Nico Kruber created FLINK-14575:
---
Summary: Wrong (parent-first) class loader during serialization
while submitting jobs
Key: FLINK-14575
URL: https://issues.apache.org/jira/browse/FLINK-14575
Project:
+1. Good catch Jingsong!
Best, Hequn
On Wed, Oct 30, 2019 at 7:26 PM Zhenghua Gao wrote:
> +1 (non-binding)
>
> *Best Regards,*
> *Zhenghua Gao*
>
>
> On Wed, Oct 30, 2019 at 12:05 PM Jingsong Li
> wrote:
>
> > Hi all:
> >
> > We already have the parent model of formats. we have put other
> >
+1 (binding) from me. I hope this is not too late :)
Thank you for this great contribution!
On Wed, 30 Oct 2019 at 14:45, Stephan Ewen wrote:
> Thank you all for voting.
>
> The voting period has passed, but only 13 PMC members have voted so far,
> that is less than 2/3rd of the PMCs (17
Thanks for bringing this up again Vino.
Considering the current status that the community is lack of committer
bandwidth on QueryableState [1] [2], I think David has made a good
point/concern, that we need to collect more information about valid
in-production QueryableState use cases to draw more
Thank you all for voting.
The voting period has passed, but only 13 PMC members have voted so far,
that is less than 2/3rd of the PMCs (17 members).
I will take a few days to ping other members to vote, after that we will
gradually lower the threshold as per the process to account for inactive
Piotr Nowojski created FLINK-14574:
--
Summary: flink-s3-fs-hadoop doesn't work with plugins mechanism
Key: FLINK-14574
URL: https://issues.apache.org/jira/browse/FLINK-14574
Project: Flink
Hi,
Thanks for starting the discussion.
WRT the per-job semantic, it looks natural to me that per-job means
per-job-graph,
because in my understanding JobGraph is the representation of a job. Could you
share some use case in which a user program should contain multiple job graphs?
WRT the
+1 (non-binding)
*Best Regards,*
*Zhenghua Gao*
On Wed, Oct 30, 2019 at 12:05 PM Jingsong Li wrote:
> Hi all:
>
> We already have the parent model of formats. we have put other
> formats(flink-avro, flink-json, flink-parquet, flink-json, flink-csv,
> flink-sequence-file) to flink-formats.
Hi Yu,
Thanks for bringing this up.
+1 for the idea and the proposal from my side.
I think that the proposed Test Job List might be a bit redundant/excessive, but:
- we can always adjust this later, once we have the infrastructure in place
- as long as we have the computing resources and
Hi everyone,
We would like to propose FLIP-83 that adds an end-to-end performance
testing framework for Flink. We discovered some potential problems through
such an internal end-to-end performance testing framework before the
release of 1.9.0 [1], so we'd like to contribute it to Flink community
Congratulations Becket!
Best Regards,
Yu
On Wed, 30 Oct 2019 at 18:01, Andrey Zagrebin wrote:
> Congrats Becket!
>
> On Tue, Oct 29, 2019 at 6:11 PM Xuannan Su wrote:
>
> > Congratulations Becket! :-)
> >
> > Xuannan
> >
> > > On Oct 28, 2019, at 6:07 AM, Fabian Hueske wrote:
> > >
> > >
Huang Xingbo created FLINK-14573:
Summary: Support time data types in Python user-defined functions
Key: FLINK-14573
URL: https://issues.apache.org/jira/browse/FLINK-14573
Project: Flink
Congrats Becket!
On Tue, Oct 29, 2019 at 6:11 PM Xuannan Su wrote:
> Congratulations Becket! :-)
>
> Xuannan
>
> > On Oct 28, 2019, at 6:07 AM, Fabian Hueske wrote:
> >
> > Hi everyone,
> >
> > I'm happy to announce that Becket Qin has joined the Flink PMC.
> > Let's congratulate and welcome
+1 from my side as well.
Am Mi., 30. Okt. 2019 um 04:51 Uhr schrieb Jingsong Li <
jingsongl...@gmail.com>:
> Thanks jark for reminding me.
> I will start a vote thread.
>
> On Wed, Oct 30, 2019 at 11:40 AM Jark Wu wrote:
>
> > Hi Jingsong,
> >
> > Do we need a formal vote? Or do we need to wait
Gary Yao created FLINK-14572:
Summary: BlobsCleanupITCase failed in Travis stage core -
scheduler_ng
Key: FLINK-14572
URL: https://issues.apache.org/jira/browse/FLINK-14572
Project: Flink
Issue
xiaodao created FLINK-14571:
---
Summary: flink connector for redis
Key: FLINK-14571
URL: https://issues.apache.org/jira/browse/FLINK-14571
Project: Flink
Issue Type: New Feature
Hi
Thanks for bringing this.
The design looks very nice to me in that
1. In the new per-job mode, we don't need to compile user programs in the
client and can directly run user programs with user jars. That way, it's
easier for resource isolation in multi-tenant platforms and is much safer.
2.
+1 (non-binding)
Best,
Vino
Dawid Wysakowicz 于2019年10月30日周三 下午4:07写道：
> +1
>
> Best,
>
> Dawid
>
> On 30/10/2019 04:49, Jingsong Li wrote:
> > Hi all:
> >
> > We already have the parent model of formats. we have put other
> > formats(flink-avro, flink-json, flink-parquet, flink-json,
+1
Best,
Jark
On Wed, 30 Oct 2019 at 16:07, Dawid Wysakowicz
wrote:
> +1
>
> Best,
>
> Dawid
>
> On 30/10/2019 04:49, Jingsong Li wrote:
> > Hi all:
> >
> > We already have the parent model of formats. we have put other
> > formats(flink-avro, flink-json, flink-parquet, flink-json, flink-csv,
vinoyang created FLINK-14570:
Summary: KeyedStateBootstrapFunction missed onTimer callback
method to fire timer
Key: FLINK-14570
URL: https://issues.apache.org/jira/browse/FLINK-14570
Project: Flink
kk created FLINK-14569:
--
Summary: use flink to deal with batch task,when parallelism
granter than 1, always 1 or 2 records loss
Key: FLINK-14569
URL: https://issues.apache.org/jira/browse/FLINK-14569
Project:
+1
Best,
Dawid
On 30/10/2019 04:49, Jingsong Li wrote:
> Hi all:
>
> We already have the parent model of formats. we have put other
> formats(flink-avro, flink-json, flink-parquet, flink-json, flink-csv,
> flink-sequence-file) to flink-formats. flink-orc is a format too. So we can
> move it to
Dawid Wysakowicz created FLINK-14568:
Summary: Add methods for interacting with temporary functions
Key: FLINK-14568
URL: https://issues.apache.org/jira/browse/FLINK-14568
Project: Flink
Hi,
As discussed before, Flink ARM builds and test now is running as cron job
in OpenLab CI. The test result can be sent to this mail list once a day
from "i...@openlabtesting.org". Can you give ` i...@openlabtesting.org`
the right to send e-mail to bui...@flink.apache.org? It can help
(CC user list because I think users may have ideas on how per-job mode
should look like)
Hi all,
In the discussion about Flink on k8s[1] we encounter a problem that opinions
diverge in how so-called per-job mode works. This thread is aimed at stating
a dedicated discussion about per-job semantic
Jark Wu created FLINK-14567:
---
Summary: Aggregate query with more than two group fields can't be
write into HBase sink
Key: FLINK-14567
URL: https://issues.apache.org/jira/browse/FLINK-14567
Project: Flink
Zhu Zhu created FLINK-14566:
---
Summary: Enable ResourceSpec to get/set whether managed memory is
used
Key: FLINK-14566
URL: https://issues.apache.org/jira/browse/FLINK-14566
Project: Flink
Issue
41 matches
Mail list logo
