Hi everybody,
On behalf of the PMC I am delighted to announce Haohui Mai as a new Flink
committer!
Haohui has been an active member of our community for several months.
Among other things, he made major contributions in ideas and code to the
SQL and Table APIs.
Please join me in congratulating H
Congrats and welcome on board :-)
On Wed, Nov 1, 2017 at 9:14 AM, Fabian Hueske wrote:
> Hi everybody,
>
> On behalf of the PMC I am delighted to announce Haohui Mai as a new Flink
> committer!
>
> Haohui has been an active member of our community for several months.
> Among other things, he mad
Congratulations!
On Wed, Nov 1, 2017 at 4:36 PM, Till Rohrmann wrote:
> Congrats and welcome on board :-)
>
> On Wed, Nov 1, 2017 at 9:14 AM, Fabian Hueske wrote:
>
> > Hi everybody,
> >
> > On behalf of the PMC I am delighted to announce Haohui Mai as a new Flink
> > committer!
> >
> > Haohui
Fabian Hueske created FLINK-7955:
Summary: Rowtime attribute cannot be aggregated in group window of
stream Table API
Key: FLINK-7955
URL: https://issues.apache.org/jira/browse/FLINK-7955
Project: Fli
Congratulations! 😃
> On 1. Nov 2017, at 10:13, Shaoxuan Wang wrote:
>
> Congratulations!
>
> On Wed, Nov 1, 2017 at 4:36 PM, Till Rohrmann wrote:
>
>> Congrats and welcome on board :-)
>>
>> On Wed, Nov 1, 2017 at 9:14 AM, Fabian Hueske wrote:
>>
>>> Hi everybody,
>>>
>>> On behalf of the
Till Rohrmann created FLINK-7956:
Summary: Add support for scheduling with slot sharing
Key: FLINK-7956
URL: https://issues.apache.org/jira/browse/FLINK-7956
Project: Flink
Issue Type: Sub-ta
The Apache Flink community is pleased to announce the release of Apache
Flink-shaded 2.0.
The flink-shaded project contains a number of shaded dependencies for
Apache Flink.
This release adds jackson-core/databind/annotations:2.7.9 as a single
flink-shaded-jackson dependency,
and a build
Congratulations!
>> On 1. Nov 2017, at 10:13, Shaoxuan Wang wrote:
>>
>> Congratulations!
>>
>> On Wed, Nov 1, 2017 at 4:36 PM, Till Rohrmann wrote:
>>
>>> Congrats and welcome on board :-)
>>>
>>> On Wed, Nov 1, 2017 at 9:14 AM, Fabian Hueske wrote:
>>>
Hi everybody,
On b
Chesnay Schepler created FLINK-7957:
---
Summary: Add MetricGroup#getLogicalScope
Key: FLINK-7957
URL: https://issues.apache.org/jira/browse/FLINK-7957
Project: Flink
Issue Type: Improvement
Chesnay Schepler created FLINK-7958:
---
Summary: Allow reporters to override the configured delimiter
Key: FLINK-7958
URL: https://issues.apache.org/jira/browse/FLINK-7958
Project: Flink
Issu
Kurt Young created FLINK-7959:
-
Summary: Split CodeGenerator into CodeGeneratorContext and
ExprCodeGenerator
Key: FLINK-7959
URL: https://issues.apache.org/jira/browse/FLINK-7959
Project: Flink
Congrats and welcome on board!
Best,
Kurt
On Wed, Nov 1, 2017 at 8:15 PM, Hai Zhou wrote:
> Congratulations!
>
> On 1. Nov 2017, at 10:13, Shaoxuan Wang wrote:
>
> Congratulations!
>
> On Wed, Nov 1, 2017 at 4:36 PM, Till Rohrmann
> wrote:
>
> Congrats and welcome on board :-)
>
> On Wed, Nov
Gary Yao created FLINK-7960:
---
Summary: ExecutionGraphRestartTest fails sporadically
Key: FLINK-7960
URL: https://issues.apache.org/jira/browse/FLINK-7960
Project: Flink
Issue Type: Bug
Co
Hello,
I have a datastream with sliding windows. I want to ask how can i get which
window pattern matches?
ex window 3 : 11m-21m
[image: Satır içi resim 1]
Can you post the code please
On 1 Nov 2017 16:58, "Erdem erdfem" wrote:
> Hello,
>
> I have a datastream with sliding windows. I want to ask how can i get
> which window pattern matches?
> ex window 3 : 11m-21m
>
> [image: Satır içi resim 1]
>
Congratulations!
On Wed, Nov 1, 2017 at 9:37 PM, Kurt Young wrote:
> Congrats and welcome on board!
>
> Best,
> Kurt
>
> On Wed, Nov 1, 2017 at 8:15 PM, Hai Zhou wrote:
>
>> Congratulations!
>>
>> On 1. Nov 2017, at 10:13, Shaoxuan Wang wrote:
>>
>> Congratulations!
>>
>> On Wed, Nov 1, 2017 a
Congratulations!
On Wed, Nov 1, 2017 at 8:39 AM, Xingcan Cui wrote:
> Congratulations!
>
> On Wed, Nov 1, 2017 at 9:37 PM, Kurt Young wrote:
>
> > Congrats and welcome on board!
> >
> > Best,
> > Kurt
> >
> > On Wed, Nov 1, 2017 at 8:15 PM, Hai Zhou wrote:
> >
> >> Congratulations!
> >>
> >> O
Congratulations!
On Wed, Nov 1, 2017 at 10:04 AM, Bowen Li wrote:
> Congratulations!
>
> On Wed, Nov 1, 2017 at 8:39 AM, Xingcan Cui wrote:
>
> > Congratulations!
> >
> > On Wed, Nov 1, 2017 at 9:37 PM, Kurt Young wrote:
> >
> > > Congrats and welcome on board!
> > >
> > > Best,
> > > Kurt
> >
Thalita Vergilio created FLINK-7961:
---
Summary: Docker-Flink with Docker Swarm doesn't work when machines
are in different clouds
Key: FLINK-7961
URL: https://issues.apache.org/jira/browse/FLINK-7961
Congratulations!
On Wed, Nov 1, 2017 at 2:41 AM, Aljoscha Krettek
wrote:
> Congratulations! 😃
>
> > On 1. Nov 2017, at 10:13, Shaoxuan Wang wrote:
> >
> > Congratulations!
> >
> > On Wed, Nov 1, 2017 at 4:36 PM, Till Rohrmann
> wrote:
> >
> >> Congrats and welcome on board :-)
> >>
> >> On Wed
Congrats and welcome!
On Wed, Nov 1, 2017 at 6:47 PM, Chen Qin wrote:
> Congratulations!
>
> On Wed, Nov 1, 2017 at 2:41 AM, Aljoscha Krettek
> wrote:
>
> > Congratulations! 😃
> >
> > > On 1. Nov 2017, at 10:13, Shaoxuan Wang wrote:
> > >
> > > Congratulations!
> > >
> > > On Wed, Nov 1, 2017
Congratulations!
01.11.2017 7:45 PM "Stephan Ewen" napisał(a):
> Congrats and welcome!
>
> On Wed, Nov 1, 2017 at 6:47 PM, Chen Qin wrote:
>
> > Congratulations!
> >
> > On Wed, Nov 1, 2017 at 2:41 AM, Aljoscha Krettek
> > wrote:
> >
> > > Congratulations! 😃
> > >
> > > > On 1. Nov 2017, at 10
Dian Fu created FLINK-7962:
--
Summary: Add built-in support for min/max aggregation for Timestamp
Key: FLINK-7962
URL: https://issues.apache.org/jira/browse/FLINK-7962
Project: Flink
Issue Type: Task
FlinkKafkaConsumer010 myConsumer = new
FlinkKafkaConsumer010<>("demo", new JSONDeserializationSchema(),
properties);
DataStream dataStream =
env.addSource(myConsumer);
dataStream.windowAll(SlidingEventTimeWindows.of(Time.hours(1),
Time.minutes(1)))
Patte
24 matches
Mail list logo
