Hi all,
Regarding to the RichAsyncFunction, why we cannot access the state through
runtime context like other operators?
Best,
Shimin Yang
I agree with the additional thoughts of a), b) and c).
In all the current implementations of ChannelSelector, the selector channels
are either one or all, so it makes sense for change the interface as you
suggested if we will not extend other selectors for partial channels in future.
And the si
Not yet. We only have some initial thoughts and have not worked on it yet. We
will update the progress in this discussion if have.
Best,
Zhijiang
--
发件人：Aljoscha Krettek
发送时间：2018年10月18日(星期四) 17:53
收件人：dev ; Zhijiang(wangzhijiang999
Hi,
I checked the following things:
* no dependencies added or changed since Flink 1.5.4
* compiling the source distribution without tests succeeds
* compiling the source distribution with tests fails (see exception
appended below). When I restart the compilation, it goes past flink-hbase
but fai
Hi,
Thanks Chesnay for preparing the RC1 for Flink 1.6.2.
I checked a few things, but there seem to be some issues with the release
candidate.
* no dependencies added or changed since Flink 1.6.1
* building the source distribution without tests succeeds, however, a
second build fails due to gene
Sounds good! @Fabian Hueske
Fabian Hueske 于2018年10月18日周四 下午4:24写道：
> Hi,
>
> I opened a PR to extend the PR description template [1].
>
> @jincheng sun , I'd suggest to start a separate
> discussion about a template for Jira ticket. Let's try to keep this thread
> focused on the tooling to sup
Igal Shilman created FLINK-10605:
Summary: Upgrade AvroSerializer snapshot to implement new
TypeSerializerSnapshot interface
Key: FLINK-10605
URL: https://issues.apache.org/jira/browse/FLINK-10605
Pro
Max created FLINK-10604:
---
Summary: Add Remainder math function supported in Table API and SQL
Key: FLINK-10604
URL: https://issues.apache.org/jira/browse/FLINK-10604
Project: Flink
Issue Type: Task
Chesnay Schepler created FLINK-10603:
Summary: Reduce kafka test duration
Key: FLINK-10603
URL: https://issues.apache.org/jira/browse/FLINK-10603
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-10602:
-
Summary: Run MetricFetcher in metrics ActorSystem
Key: FLINK-10602
URL: https://issues.apache.org/jira/browse/FLINK-10602
Project: Flink
Issue Type: Sub-ta
Paul Lin created FLINK-10601:
Summary: Make user home dir consistent with Flink default
filesystem
Key: FLINK-10601
URL: https://issues.apache.org/jira/browse/FLINK-10601
Project: Flink
Issue Ty
Hi everyone,
Please review and vote on the release candidate #1 for the version
1.6.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],
Hi everyone,
Please review and vote on the release candidate #1 for the version
1.5.5, 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],
Hi Zhijiang,
do you already have working code or a design doc for the second approach?
Best,
Aljoscha
> On 18. Oct 2018, at 08:42, Zhijiang(wangzhijiang999)
> wrote:
>
> Just noticed this discussion from @Till Rohrmann's weekly community update
> and I want to share some thoughts from our ex
Hey,
I also think that 3rd option is the most promising, however logic of “dirty”
channels might be causing some overheads. I was also thinking about other
option:
5. In case of ‘emit’ called on BroadcastRecordWriter, we could write it to
common/shared BufferBuilder, but somehow marked it as t
vinoyang created FLINK-10600:
Summary: Provide End-to-end test cases for modern Kafka connectors
Key: FLINK-10600
URL: https://issues.apache.org/jira/browse/FLINK-10600
Project: Flink
Issue Type:
vinoyang created FLINK-10599:
Summary: Provide documentation for the modern kafka connector
Key: FLINK-10599
URL: https://issues.apache.org/jira/browse/FLINK-10599
Project: Flink
Issue Type: Sub-
vinoyang created FLINK-10598:
Summary: Maintain modern Kafka connector
Key: FLINK-10598
URL: https://issues.apache.org/jira/browse/FLINK-10598
Project: Flink
Issue Type: Task
Components
Thanks a lot for merging and publishing the new review guidelines Fabian!
Cheers,
Till
On Thu, Oct 18, 2018 at 10:22 AM Fabian Hueske wrote:
> Hi,
>
> I merged the PR.
> The review process is documented at [1].
>
> Best, Fabian
>
> [1] https://flink.apache.org/reviewing-prs.html
>
> Am Mi., 10.
Hi,
I opened a PR to extend the PR description template [1].
@jincheng sun , I'd suggest to start a separate
discussion about a template for Jira ticket. Let's try to keep this thread
focused on the tooling to support the review process.
Thanks, Fabian
[1] https://github.com/apache/flink/pull/6
Dawid Wysakowicz created FLINK-10597:
Summary: Enable UDFs support in MATCH_RECOGNIZE
Key: FLINK-10597
URL: https://issues.apache.org/jira/browse/FLINK-10597
Project: Flink
Issue Type: Su
Dawid Wysakowicz created FLINK-10596:
Summary: Add access to timerService in IterativeCondition and
Pattern(Flat)SelectFunction
Key: FLINK-10596
URL: https://issues.apache.org/jira/browse/FLINK-10596
Hi,
I merged the PR.
The review process is documented at [1].
Best, Fabian
[1] https://flink.apache.org/reviewing-prs.html
Am Mi., 10. Okt. 2018 um 17:48 Uhr schrieb Fabian Hueske :
> Hi all,
>
> I opened a PR [1] to add the PR review guide to the Flink website.
>
> Cheers, Fabian
>
> [1] http
Dawid Wysakowicz created FLINK-10595:
Summary: Support patterns that can produce empty matches
Key: FLINK-10595
URL: https://issues.apache.org/jira/browse/FLINK-10595
Project: Flink
Issue
Dawid Wysakowicz created FLINK-10594:
Summary: Support SUBSETS
Key: FLINK-10594
URL: https://issues.apache.org/jira/browse/FLINK-10594
Project: Flink
Issue Type: Sub-task
Compon
Dawid Wysakowicz created FLINK-10593:
Summary: Add support for ALL ROWS PER MATCH
Key: FLINK-10593
URL: https://issues.apache.org/jira/browse/FLINK-10593
Project: Flink
Issue Type: Sub-ta
Dawid Wysakowicz created FLINK-10592:
Summary: Support exclusions in patterns
Key: FLINK-10592
URL: https://issues.apache.org/jira/browse/FLINK-10592
Project: Flink
Issue Type: Sub-task
Dawid Wysakowicz created FLINK-10591:
Summary: Add functions to return TimeIndicators from
MATCH_RECOGNIZE
Key: FLINK-10591
URL: https://issues.apache.org/jira/browse/FLINK-10591
Project: Flink
Dawid Wysakowicz created FLINK-10590:
Summary: Optional quantifier is discarded from first element of
group pattern
Key: FLINK-10590
URL: https://issues.apache.org/jira/browse/FLINK-10590
Project:
Dawid Wysakowicz created FLINK-10589:
Summary: Group patterns should support greedy quantifiers
Key: FLINK-10589
URL: https://issues.apache.org/jira/browse/FLINK-10589
Project: Flink
Issu
Dawid Wysakowicz created FLINK-10588:
Summary: Support reusing same variable in Pattern
Key: FLINK-10588
URL: https://issues.apache.org/jira/browse/FLINK-10588
Project: Flink
Issue Type:
Dawid Wysakowicz created FLINK-10587:
Summary: Improve support of greedy/reluctant quantifiers
Key: FLINK-10587
URL: https://issues.apache.org/jira/browse/FLINK-10587
Project: Flink
Issue
32 matches
Mail list logo
