shiv kumar created FLINK-12093:
--
Summary: Apache Flink:Active MQ consumer job is getting finished
after first message consume.
Key: FLINK-12093
URL: https://issues.apache.org/jira/browse/FLINK-12093
Proj
Jingsong Lee created FLINK-12094:
Summary: Introduce sort merge join operator to blink batch
Key: FLINK-12094
URL: https://issues.apache.org/jira/browse/FLINK-12094
Project: Flink
Issue Type:
Hi Andrey,
Thanks for concluding this valuable proposal. It really extends and enhances
the details of partition lifecycle management ever mentioned in FLIP-31. I
reviewed the google doc and agreed the general points in it.
One implict point in doc is that the shuffle is not limted to only serv
Mike Pedersen created FLINK-12095:
-
Summary: Canceling vs cancelling
Key: FLINK-12095
URL: https://issues.apache.org/jira/browse/FLINK-12095
Project: Flink
Issue Type: Bug
Component
You now have contributor permissions.
On 03/04/2019 08:18, Hefei Li wrote:
Hi guys,
I want to contribute to Apache Flink.
Would you please give me the permission as a contributor ?
My JIRA username is *lhfei *.
===
Best Regards
Hefei LiHefei Li
MP: +86 1870158
Yogesh Nandigamq created FLINK-12096:
Summary: Flink counter state getting stuck on usin
Key: FLINK-12096
URL: https://issues.apache.org/jira/browse/FLINK-12096
Project: Flink
Issue Type:
xu created FLINK-12097:
--
Summary: Flink SQL hangs in StreamTableEnvironment.sqlUpdate,
keeps executing and seems never stop, finally lead to
java.lang.OutOfMemoryError: GC overhead limit exceeded
Key: FLINK-12097
URL: https
Hello everyone,
I'm proposing to remove the connector for elasticsearch 1.
The connector is used significantly less than more recent versions (2&5
are downloaded 4-5x more), and hasn't seen any development for over a
hear, yet still incurred maintenance overhead due to licensing and testing.
godfrey he created FLINK-12098:
--
Summary: Add support for generating optimized logical plan for
simple group aggregate on batch
Key: FLINK-12098
URL: https://issues.apache.org/jira/browse/FLINK-12098
Pro
Chesnay Schepler created FLINK-12099:
Summary: Elasticsearch(1)SinkITCase fails on Java 9
Key: FLINK-12099
URL: https://issues.apache.org/jira/browse/FLINK-12099
Project: Flink
Issue Type
Chesnay Schepler created FLINK-12100:
Summary: Kafka 0.10 tests fail on Java 9
Key: FLINK-12100
URL: https://issues.apache.org/jira/browse/FLINK-12100
Project: Flink
Issue Type: Sub-task
Maximilian Michels created FLINK-12101:
--
Summary: Race condition when concurrenty running uploaded jars via
REST
Key: FLINK-12101
URL: https://issues.apache.org/jira/browse/FLINK-12101
Project: F
Chesnay Schepler created FLINK-12102:
Summary: FlinkILoopTest fails on Java 9
Key: FLINK-12102
URL: https://issues.apache.org/jira/browse/FLINK-12102
Project: Flink
Issue Type: Sub-task
Ben Marini created FLINK-12103:
--
Summary: Extend builtin operator metrics with user defined scope
and variables
Key: FLINK-12103
URL: https://issues.apache.org/jira/browse/FLINK-12103
Project: Flink
Tim created FLINK-12104:
---
Summary: Flink Kafka fails with Incompatible KafkaProducer version
/ NoSuchFieldException sequenceNumbers
Key: FLINK-12104
URL: https://issues.apache.org/jira/browse/FLINK-12104
Projec
Vinod Mehra created FLINK-12105:
---
Summary: TUMBLE INTERVAL value errors out for 100 or more value
Key: FLINK-12105
URL: https://issues.apache.org/jira/browse/FLINK-12105
Project: Flink
Issue Ty
Thanks a lot for driving the FLIP, jincheng. The approach looks
good. Adding multi-lang support sounds a promising direction to expand the
footprint of Flink. Do we have plan for adding Golang support? As many
backend engineers nowadays are familiar with Go, but probably not Java as
much, adding Go
I’m hereby canceling the vote for Flink 1.8.0 RC4 in favour of a new RC that I
will create shortly now that the blockers are resolved.
> On 1. Apr 2019, at 13:21, Till Rohrmann wrote:
>
> Thanks for reporting this problem and opening a JIRA issue. I've created a
> fix for the problem [1].
>
>
John created FLINK-12106:
Summary: Jobmanager is killing FINISHED taskmanger containers,
causing exception in still running Taskmanagers an
Key: FLINK-12106
URL: https://issues.apache.org/jira/browse/FLINK-12106
Thanks for putting this proposal together.
It would be nice, if you could share a few use case examples (maybe add
them as section to the FLIP?).
The reason I ask: The table API is immensely useful, but it isn't clear to
me what value other language bindings provide without UDF support. With
FLIP
Luka Jurukovski created FLINK-12107:
---
Summary: Use Proxy For DataDog Validation
Key: FLINK-12107
URL: https://issues.apache.org/jira/browse/FLINK-12107
Project: Flink
Issue Type: Improvemen
Hi,
I want to contribute to Apache Flink.
Would you please give me the contributor permission?
My JIRA ID is shaozhipeng.
Thank you very much.
Hi everyone,
Please review and vote on the release candidate 5 for Flink 1.8.0, 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],
* the off
Hi Jeff, thank you for your encouragement and valuable comments on the
google doc.
I saw that you participated in many pySpark discussions a long time ago, I
am very grateful and look forward to your follow-up comments on pyFlink!
Thanks,
Jincheng
Jeff Zhang 于2019年4月2日周二 下午10:53写道:
> Thanks ji
Hi Shuyi,
Glad to see your feedback and port more requirements about multi-language!
I think the Flink community is very much looking forward to more language
support, of course, Golang should be in the future support list.
Since the topic of supporting Python on Flink has been researched and
dis
Dawid Wysakowicz created FLINK-12108:
Summary: Simplify splitting expressions into projections,
aggregations & windowProperties
Key: FLINK-12108
URL: https://issues.apache.org/jira/browse/FLINK-12108
26 matches
Mail list logo