[jira] [Created] (FLINK-10622) Add end-to-end test for time versioned joins

Till Rohrmann created FLINK-10622: - Summary: Add end-to-end test for time versioned joins Key: FLINK-10622 URL: https://issues.apache.org/jira/browse/FLINK-10622 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-10623) Extend streaming SQL end-to-end test to test MATCH_RECOGNIZE

Till Rohrmann created FLINK-10623: - Summary: Extend streaming SQL end-to-end test to test MATCH_RECOGNIZE Key: FLINK-10623 URL: https://issues.apache.org/jira/browse/FLINK-10623 Project: Flink

[jira] [Created] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

Till Rohrmann created FLINK-10624: - Summary: Extend SQL client end-to-end to test new KafkaTableSink Key: FLINK-10624 URL: https://issues.apache.org/jira/browse/FLINK-10624 Project: Flink Iss

[jira] [Created] (FLINK-10625) Add MATCH_RECOGNIZE documentation

Till Rohrmann created FLINK-10625: - Summary: Add MATCH_RECOGNIZE documentation Key: FLINK-10625 URL: https://issues.apache.org/jira/browse/FLINK-10625 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10626) Add documentation for time versioned joins

Till Rohrmann created FLINK-10626: - Summary: Add documentation for time versioned joins Key: FLINK-10626 URL: https://issues.apache.org/jira/browse/FLINK-10626 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-10627) Extend test_streaming_file_sink to test S3 writer

Till Rohrmann created FLINK-10627: - Summary: Extend test_streaming_file_sink to test S3 writer Key: FLINK-10627 URL: https://issues.apache.org/jira/browse/FLINK-10627 Project: Flink Issue Typ

[jira] [Created] (FLINK-10628) Add end-to-end test for REST communication encryption

Till Rohrmann created FLINK-10628: - Summary: Add end-to-end test for REST communication encryption Key: FLINK-10628 URL: https://issues.apache.org/jira/browse/FLINK-10628 Project: Flink Issue

[jira] [Created] (FLINK-10629) FlinkKafkaProducerITCase.testFlinkKafkaProducer10FailTransactionCoordinatorBeforeNotify failed on Travis

Till Rohrmann created FLINK-10629: - Summary: FlinkKafkaProducerITCase.testFlinkKafkaProducer10FailTransactionCoordinatorBeforeNotify failed on Travis Key: FLINK-10629 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-10630) Update migration tests for Flink 1.6

Till Rohrmann created FLINK-10630: - Summary: Update migration tests for Flink 1.6 Key: FLINK-10630 URL: https://issues.apache.org/jira/browse/FLINK-10630 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-10631) Update jepsen tests to run with multiple slots

Till Rohrmann created FLINK-10631: - Summary: Update jepsen tests to run with multiple slots Key: FLINK-10631 URL: https://issues.apache.org/jira/browse/FLINK-10631 Project: Flink Issue Type:

[jira] [Created] (FLINK-10632) Run general purpose test job with failures in per-job mode

Till Rohrmann created FLINK-10632: - Summary: Run general purpose test job with failures in per-job mode Key: FLINK-10632 URL: https://issues.apache.org/jira/browse/FLINK-10632 Project: Flink

[jira] [Created] (FLINK-10633) End-to-end test: Prometheus reporter

Till Rohrmann created FLINK-10633: - Summary: End-to-end test: Prometheus reporter Key: FLINK-10633 URL: https://issues.apache.org/jira/browse/FLINK-10633 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10634) End-to-end test: Metrics accessible via REST API

Till Rohrmann created FLINK-10634: - Summary: End-to-end test: Metrics accessible via REST API Key: FLINK-10634 URL: https://issues.apache.org/jira/browse/FLINK-10634 Project: Flink Issue Type

[jira] [Created] (FLINK-10635) End-to-end test: Take & resume from savepoint when using per-job mode

Till Rohrmann created FLINK-10635: - Summary: End-to-end test: Take & resume from savepoint when using per-job mode Key: FLINK-10635 URL: https://issues.apache.org/jira/browse/FLINK-10635 Project: Flin

Re: State access in RichAsyncFunction

Thanks, Till. Best Shimin Till Rohrmann 于2018年10月19日周五 下午4:22写道： > The problem is that `RichAsyncFunction` is allowed to trigger an > asynchronous operation which can keep a reference to the `RuntimeContext`. > However, it is not guaranteed when this operation is actually executed. Due > to thi

[jira] [Created] (FLINK-10636) ERROR org.apache.flink.shaded.curator.org.apache.curator.ConnectionState - Authentication failed

dalongliu created FLINK-10636: - Summary: ERROR org.apache.flink.shaded.curator.org.apache.curator.ConnectionState - Authentication failed Key: FLINK-10636 URL: https://issues.apache.org/jira/browse/FLINK-10636