[jira] [Created] (FLINK-8430) Implement stream-stream non-window full outer join

Hequn Cheng created FLINK-8430: -- Summary: Implement stream-stream non-window full outer join Key: FLINK-8430 URL: https://issues.apache.org/jira/browse/FLINK-8430 Project: Flink Issue Type:

[jira] [Created] (FLINK-8429) Implement stream-stream non-window right outer join

Hequn Cheng created FLINK-8429: -- Summary: Implement stream-stream non-window right outer join Key: FLINK-8429 URL: https://issues.apache.org/jira/browse/FLINK-8429 Project: Flink Issue Type:

[jira] [Created] (FLINK-8428) Implement stream-stream non-window left outer join

Hequn Cheng created FLINK-8428: -- Summary: Implement stream-stream non-window left outer join Key: FLINK-8428 URL: https://issues.apache.org/jira/browse/FLINK-8428 Project: Flink Issue Type:

[jira] [Created] (FLINK-8427) Checkstyle for org.apache.flink.optimizer.costs

Greg Hogan created FLINK-8427: - Summary: Checkstyle for org.apache.flink.optimizer.costs Key: FLINK-8427 URL: https://issues.apache.org/jira/browse/FLINK-8427 Project: Flink Issue Type:

[jira] [Created] (FLINK-8426) Error in Generating Timestamp/Watermakr doc

Christophe Jolif created FLINK-8426: --- Summary: Error in Generating Timestamp/Watermakr doc Key: FLINK-8426 URL: https://issues.apache.org/jira/browse/FLINK-8426 Project: Flink Issue Type:

[jira] [Created] (FLINK-8425) SpilledSubpartitionView not protected against concurrent release calls

Nico Kruber created FLINK-8425: -- Summary: SpilledSubpartitionView not protected against concurrent release calls Key: FLINK-8425 URL: https://issues.apache.org/jira/browse/FLINK-8425 Project: Flink

difference b/t filesystem and connector-filesystem

Hi, I'm trying to understand the difference between the flink-filesystem and flink-connector-filesystem.  How is each intended to be used? If adding support for a different storage provider that supports HDFS, should additions be made to one or the other, or both?  Thanks.

[jira] [Created] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one

Joao Boto created FLINK-8424: Summary: [Cassandra Connector] Update Cassandra version to last one Key: FLINK-8424 URL: https://issues.apache.org/jira/browse/FLINK-8424 Project: Flink Issue Type:

[jira] [Created] (FLINK-8423) OperatorChain#pushToOperator catch block may fail with NPE

Chesnay Schepler created FLINK-8423: --- Summary: OperatorChain#pushToOperator catch block may fail with NPE Key: FLINK-8423 URL: https://issues.apache.org/jira/browse/FLINK-8423 Project: Flink

[jira] [Created] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple

Greg Hogan created FLINK-8422: - Summary: Checkstyle for org.apache.flink.api.java.tuple Key: FLINK-8422 URL: https://issues.apache.org/jira/browse/FLINK-8422 Project: Flink Issue Type:

[jira] [Created] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore

Tzu-Li (Gordon) Tai created FLINK-8421: -- Summary: HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore Key: FLINK-8421 URL:

[jira] [Created] (FLINK-8420) Timeout exceptions are not properly recognized by RetryingRegistration

Till Rohrmann created FLINK-8420: Summary: Timeout exceptions are not properly recognized by RetryingRegistration Key: FLINK-8420 URL: https://issues.apache.org/jira/browse/FLINK-8420 Project: Flink

Ordering in ProcessFunction after emitting multiple events from WindowFunction

Hello, I have dev related question. How will Flink behave when processing events in WindowFunciton (version 1.3 or 1.4 including ProcessWindowFuncton) produces multiple events? Does Flink guarantee that ProcessFunction will process them in order after window outputs them in order into Collector

Re: Dynamic SessionWindow gaps

I've put up some implementation information and a link to the working branch for comment while I get the documentation written up: https://issues.apache.org/jira/browse/FLINK-8384 Thanks, Dyana On 2018-01-02 13:54, jincheng sun wrote: > Hi, Dyana dynamic gap is