Thanks for being awesome RE, as always, Robert!
- Henry
On Tue, Apr 25, 2017 at 2:09 AM, Robert Metzger wrote:
> I've uploaded the artifacts to the apache mirrors and released the maven
> stuff to central.
>
> While the artifacts are syncing, please review the release announcement:
> https://gi
Cool! So, it begins =)
- Henry
On Wed, Apr 26, 2017 at 7:30 AM, Aljoscha Krettek
wrote:
> I merged the stricter checkstyle for flink-streaming-java today. (Sans
> checking for right curly braces)
>
> > On 18. Apr 2017, at 22:17, Chesnay Schepler wrote:
> >
> > +1 to use earth rotation as the n
sunjincheng created FLINK-6392:
--
Summary: Change the alias of Window from optional to essential.
Key: FLINK-6392
URL: https://issues.apache.org/jira/browse/FLINK-6392
Project: Flink
Issue Type:
Eron Wright created FLINK-6391:
---
Summary: fix build for scala 2.11 (gelly-examples)
Key: FLINK-6391
URL: https://issues.apache.org/jira/browse/FLINK-6391
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-6390:
---
Summary: Add Trigger Hooks to the Checkpoint Coordinator
Key: FLINK-6390
URL: https://issues.apache.org/jira/browse/FLINK-6390
Project: Flink
Issue Type: New F
Ted Yu created FLINK-6389:
-
Summary: Upgrade hbase dependency to 1.3.1
Key: FLINK-6389
URL: https://issues.apache.org/jira/browse/FLINK-6389
Project: Flink
Issue Type: Improvement
Reporte
Stefano Bortoli created FLINK-6388:
--
Summary: Add support for DISTINCT into Code Generated Aggregations
Key: FLINK-6388
URL: https://issues.apache.org/jira/browse/FLINK-6388
Project: Flink
I
Hi Aljoscha,
I see. Thanks for your reply.
Best,
Tony Wei
Aljoscha Krettek 於 2017年4月26日 週三，下午10:29寫道：
> Hi,
> Both implementations work so no one bothered to change the older
> implementations yet. I don’t think it’s a problem but if you want you can
> adapt reduce/fold to the newer implementat
No worries, thanks for the heads up. Good luck wrapping all that stuff up.
-Tyler
On Tue, Apr 25, 2017 at 12:07 AM Fabian Hueske wrote:
> Hi Tyler,
>
> thanks for pushing this effort and including the Flink list.
> I haven't managed to read the doc yet, but just wanted to thank you for the
> wr
I merged the stricter checkstyle for flink-streaming-java today. (Sans checking
for right curly braces)
> On 18. Apr 2017, at 22:17, Chesnay Schepler wrote:
>
> +1 to use earth rotation as the new standard time unit. Maybe more
> importantly, I'm absolutely in favor of merging it.
>
> On 18.0
Hi,
Both implementations work so no one bothered to change the older
implementations yet. I don’t think it’s a problem but if you want you can adapt
reduce/fold to the newer implementation.
Best,
Aljoscha
> On 26. Apr 2017, at 14:51, 魏偉哲 wrote:
>
> Hi Aljoscha,
>
> I know the aggregate code i
Hi Aljoscha,
I know the aggregate code is newer. I am confused because the
implementations are not consistent.
Does it mean that the reduce/fold implementation would need to be
refactored for the purpose of having less layers ?
Or is it better to remain the current implementations for some reasons
Hi Tony,
The reason for this is that the aggregate code is newer. The new code has less
layers, compared to the reduce/fold implementation where it is
InternalFunction(ReduceApplyFunction(Reduce)) instead of
InteralAggregateFunction(Aggregate).
Best,
Aljoscha
> On 26. Apr 2017, at 06:39, 魏偉哲
shijinkui created FLINK-6387:
Summary: Flink UI support access log
Key: FLINK-6387
URL: https://issues.apache.org/jira/browse/FLINK-6387
Project: Flink
Issue Type: Improvement
Component
14 matches
Mail list logo
