[jira] [Created] (FLINK-18453) Stack overflow of AggregateITCase#testAggregationCodeSplit on Azure

Yingjie Cao created FLINK-18453: --- Summary: Stack overflow of AggregateITCase#testAggregationCodeSplit on Azure Key: FLINK-18453 URL: https://issues.apache.org/jira/browse/FLINK-18453 Project: Flink

Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration

Hi community, Recently we found out an issue with the Top-N feature in blink planner, and here is the JIRA ticket https://issues.apache.org/jira/browse/FLINK-18452. After analysis, we believe that it is the flaw in the implementation of equals method, as it does not take the random numbers

[jira] [Created] (FLINK-18452) Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration

Weike Dong created FLINK-18452: -- Summary: Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration Key: FLINK-18452 URL:

[jira] [Created] (FLINK-18451) Flink HA on yarn may appear TaskManager double running when HA is restored

ming li created FLINK-18451: --- Summary: Flink HA on yarn may appear TaskManager double running when HA is restored Key: FLINK-18451 URL: https://issues.apache.org/jira/browse/FLINK-18451 Project: Flink

[jira] [Created] (FLINK-18450) Add watermark alignment logic to SourceReaderBase.

Jiangjie Qin created FLINK-18450: Summary: Add watermark alignment logic to SourceReaderBase. Key: FLINK-18450 URL: https://issues.apache.org/jira/browse/FLINK-18450 Project: Flink Issue

Is it possible to create an Apache Beam (in python) IO connector for RabbitMQ?

Is it possible to create an Apache Beam (in python) IO connector for RabbitMQ I've been over the apache beam docs and also asked this question on stackoverflow, but i still

Re: [DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

Hey Gordon, Thank-you for you review and feedback. I agree with your suggestion for the contribution plan. I have updated the FLIP to include the additional step with the FanOutKinesisProxy/AWS SDK 2.x dependency. I have also added another precursor step to generally improve test coverage. I

Re: [VOTE] Release 1.11.0, release candidate #3

I would close this RC3 vote as Piotr mentioned below, and the next RC4 would be ready for formal vote tomorrow. Best, Zhijiang -- From:Piotr Nowojski Send Time:2020年6月26日(星期五) 15:21 To:Marta Paes Moreira Cc:dev ; Zhijiang

Announcing ApacheCon @Home 2020

Hi, Apache enthusiast! (You’re receiving this because you’re subscribed to one or more dev or user mailing lists for an Apache Software Foundation project.) The ApacheCon Planners and the Apache Software Foundation are pleased to announce that ApacheCon @Home will be held online, September

[jira] [Created] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

Shengkai Fang created FLINK-18449: - Summary: Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API Key: FLINK-18449 URL: https://issues.apache.org/jira/browse/FLINK-18449

[jira] [Created] (FLINK-18448) Update Google Cloud PubSub dependencies

Niels Basjes created FLINK-18448: Summary: Update Google Cloud PubSub dependencies Key: FLINK-18448 URL: https://issues.apache.org/jira/browse/FLINK-18448 Project: Flink Issue Type:

[jira] [Created] (FLINK-18447) Add 'flink-connector-base' to 'flink-dist'

Stephan Ewen created FLINK-18447: Summary: Add 'flink-connector-base' to 'flink-dist' Key: FLINK-18447 URL: https://issues.apache.org/jira/browse/FLINK-18447 Project: Flink Issue Type:

[jira] [Created] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins

franklin DREW created FLINK-18446: - Summary: Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins Key: FLINK-18446 URL: https://issues.apache.org/jira/browse/FLINK-18446 Project: Flink

[jira] [Created] (FLINK-18445) Short circuit join condition for lookup join

Rui Li created FLINK-18445: -- Summary: Short circuit join condition for lookup join Key: FLINK-18445 URL: https://issues.apache.org/jira/browse/FLINK-18445 Project: Flink Issue Type: Improvement