[jira] [Created] (FLINK-7802) Bug in PushProjectIntoTableSourceScanRule when empty field collection was pushed into TableSource

godfrey he created FLINK-7802: - Summary: Bug in PushProjectIntoTableSourceScanRule when empty field collection was pushed into TableSource Key: FLINK-7802 URL: https://issues.apache.org/jira/browse/FLINK-7802

[jira] [Created] (FLINK-7801) Integrate list command into REST client

Till Rohrmann created FLINK-7801: Summary: Integrate list command into REST client Key: FLINK-7801 URL: https://issues.apache.org/jira/browse/FLINK-7801 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7800) Enable window joins without equi-join predicates

Fabian Hueske created FLINK-7800: Summary: Enable window joins without equi-join predicates Key: FLINK-7800 URL: https://issues.apache.org/jira/browse/FLINK-7800 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-7799) Improve performance of windowed joins

Fabian Hueske created FLINK-7799: Summary: Improve performance of windowed joins Key: FLINK-7799 URL: https://issues.apache.org/jira/browse/FLINK-7799 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7798) Add support for windowed joins to Table API

Fabian Hueske created FLINK-7798: Summary: Add support for windowed joins to Table API Key: FLINK-7798 URL: https://issues.apache.org/jira/browse/FLINK-7798 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-7797) Add support for windowed outer joins for streaming tables

Fabian Hueske created FLINK-7797: Summary: Add support for windowed outer joins for streaming tables Key: FLINK-7797 URL: https://issues.apache.org/jira/browse/FLINK-7797 Project: Flink Issue

[jira] [Created] (FLINK-7796) RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close snapshotCloseableRegistry

Ted Yu created FLINK-7796: - Summary: RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close snapshotCloseableRegistry Key: FLINK-7796 URL: https://issues.apache.org/jira/browse/FLINK-7796 Project:

Not being able to log from Flink to Kafka

Hi Guys I am trying to use log4j to log all the info from my Flink Application into a Kafka Topic. The Flink application is running in cluster mode. but everytime ran it said: 10/10/2017 10:30:00 AM - log4j:ERROR Could not instantiate class [org.apache.kafka.log4jappender.KafkaLog4jAppender]. 10/

[jira] [Created] (FLINK-7795) Utilize error-prone to discover common coding mistakes

Ted Yu created FLINK-7795: - Summary: Utilize error-prone to discover common coding mistakes Key: FLINK-7795 URL: https://issues.apache.org/jira/browse/FLINK-7795 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-7794) Link Broken in -- https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html

Paul Wu created FLINK-7794: -- Summary: Link Broken in -- https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html Key: FLINK-7794 URL: https://issues.apache.org/jira/browse/FLINK-7794

[jira] [Created] (FLINK-7793) SlotManager releases idle TaskManager in standalone mode

Till Rohrmann created FLINK-7793: Summary: SlotManager releases idle TaskManager in standalone mode Key: FLINK-7793 URL: https://issues.apache.org/jira/browse/FLINK-7793 Project: Flink Issue

Re: Get pattern events

Thank you Kostas 2017-10-10 17:47 GMT+03:00 Kostas Kloudas : > The address is u...@flink.apache.org > > You have to subscribe as described here https://flink.apache.org/ > community.html > > Kostas > > > On Oct 10, 2017, at 4:40 PM, Erdem erdfem > wrote:

Re: Get pattern events

The address is u...@flink.apache.org You have to subscribe as described here https://flink.apache.org/community.html Kostas > On Oct 10, 2017, at 4:40 PM, Erdem erdfem wrote: > > What is the address for user mailing? > > 2017-10-10 17:30 GMT+03:00 Ko

Re: Unable to write snapshots to S3 on EMR

Hello, Bowen: Unless I am missing something, it says there needs to be no setup on EMR, Each topic says: "You don’t have to configure this manually if you are running Flink on EMR." S3 access from CLI works fine on my clusters. Chen: Thank you for this, I will look into this if I am unable to g

Re: Get pattern events

What is the address for user mailing? 2017-10-10 17:30 GMT+03:00 Kostas Kloudas : > Also this topic seems to be more suitable for the user mailing, and not > the dev one. > Could you move the discussion there? > > Thanks, > Kostas > > > On Oct 10, 2017, at 4:29 PM, Kostas Kloudas > wrote: > > >

[jira] [Created] (FLINK-7792) CliFrontend tests suppress logging

Chesnay Schepler created FLINK-7792: --- Summary: CliFrontend tests suppress logging Key: FLINK-7792 URL: https://issues.apache.org/jira/browse/FLINK-7792 Project: Flink Issue Type: Bug

Re: Get pattern events

Also this topic seems to be more suitable for the user mailing, and not the dev one. Could you move the discussion there? Thanks, Kostas > On Oct 10, 2017, at 4:29 PM, Kostas Kloudas > wrote: > > Hi Erdem, > > Could you share also your pattern? > If the “first” pattern has no quantifier, the

Re: Get pattern events

Hi Erdem, Could you share also your pattern? If the “first” pattern has no quantifier, then it is expected to have only one event. Kostas > On Oct 10, 2017, at 4:22 PM, Erdem erdfem wrote: > > Hello, > > I want to take get pattern events. I use below code. When debug, context > has one event

Get pattern events

Hello, I want to take get pattern events. I use below code. When debug, context has one event. I cant see other events. Can you help me? for (ObjectNode node : context.getEventsForPattern("first")) { count += node.get(criterias.getPropName()).asInt(); }

[jira] [Created] (FLINK-7791) Integrate LIST command into REST client

Chesnay Schepler created FLINK-7791: --- Summary: Integrate LIST command into REST client Key: FLINK-7791 URL: https://issues.apache.org/jira/browse/FLINK-7791 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-7790) Unresolved query parameters are not omitted

Chesnay Schepler created FLINK-7790: --- Summary: Unresolved query parameters are not omitted Key: FLINK-7790 URL: https://issues.apache.org/jira/browse/FLINK-7790 Project: Flink Issue Type: B

[jira] [Created] (FLINK-7789) Add handler for Async IO operator timeouts

Karthik Deivasigamani created FLINK-7789: Summary: Add handler for Async IO operator timeouts Key: FLINK-7789 URL: https://issues.apache.org/jira/browse/FLINK-7789 Project: Flink Iss