[jira] [Created] (FLINK-19012) E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument."

Robert Metzger created FLINK-19012: -- Summary: E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument." Key: FLINK-19012 URL: https://issues.apache.or

[jira] [Created] (FLINK-19013) Log start/end of state restoration

Chesnay Schepler created FLINK-19013: Summary: Log start/end of state restoration Key: FLINK-19013 URL: https://issues.apache.org/jira/browse/FLINK-19013 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-19014) Investigate minimum e2e test duration

Chesnay Schepler created FLINK-19014: Summary: Investigate minimum e2e test duration Key: FLINK-19014 URL: https://issues.apache.org/jira/browse/FLINK-19014 Project: Flink Issue Type: Tas

[jira] [Created] (FLINK-19015) java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15'

jack sun created FLINK-19015: Summary: java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15' Key: FLINK-19015 URL: https://issues.apache.org/jira/browse/FLINK-19015 Proje

[jira] [Created] (FLINK-19016) Checksum mismatch when restore from RocksDB

Jiayi Liao created FLINK-19016: -- Summary: Checksum mismatch when restore from RocksDB Key: FLINK-19016 URL: https://issues.apache.org/jira/browse/FLINK-19016 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19017) Increases the visibility of a remote function call retry

Igal Shilman created FLINK-19017: Summary: Increases the visibility of a remote function call retry Key: FLINK-19017 URL: https://issues.apache.org/jira/browse/FLINK-19017 Project: Flink Issu

[jira] [Created] (FLINK-19018) Add connection timeout to remote functions.

Igal Shilman created FLINK-19018: Summary: Add connection timeout to remote functions. Key: FLINK-19018 URL: https://issues.apache.org/jira/browse/FLINK-19018 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-19019) Add HDFS / S3 / GCS support to Flink-StateFun Docker image.

Igal Shilman created FLINK-19019: Summary: Add HDFS / S3 / GCS support to Flink-StateFun Docker image. Key: FLINK-19019 URL: https://issues.apache.org/jira/browse/FLINK-19019 Project: Flink

[jira] [Created] (FLINK-19020) Add more metrics around async operations and backpressure

Igal Shilman created FLINK-19020: Summary: Add more metrics around async operations and backpressure Key: FLINK-19020 URL: https://issues.apache.org/jira/browse/FLINK-19020 Project: Flink Iss

[jira] [Created] (FLINK-19021) Cleanups of the ResultPartition components

Stephan Ewen created FLINK-19021: Summary: Cleanups of the ResultPartition components Key: FLINK-19021 URL: https://issues.apache.org/jira/browse/FLINK-19021 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-19022) AkkaRpcActor failed to start but no exception information

tartarus created FLINK-19022: Summary: AkkaRpcActor failed to start but no exception information Key: FLINK-19022 URL: https://issues.apache.org/jira/browse/FLINK-19022 Project: Flink Issue Type:

Unclean S3 checkpointing using Presto plugin

Hello! My streaming job periodically checkpoints state to S3. While the checkpointing itself works fine, I do see this log message each time its triggered and am curious whether there's anything we can do about it. 2020-08-21 08:32:38,031 INFO org.apache.flink.fs.s3base.shaded.com.amazonaws.latenc

[jira] [Created] (FLINK-19023) Remove pruning of Record Serializer Buffer

Stephan Ewen created FLINK-19023: Summary: Remove pruning of Record Serializer Buffer Key: FLINK-19023 URL: https://issues.apache.org/jira/browse/FLINK-19023 Project: Flink Issue Type: Sub-ta

Re: [DISCUSS] FLIP-132: Temporal Table DDL

Thanks @Fabian @Jark @Rui for sharing your opinions. For the the small divergence about choose a temporal join name or temporal table name, I don't have strong inclination. Regarding to choose a different name for this join: I agree with Jark and Rui to keep the existing "event-time temporal jo

[jira] [Created] (FLINK-19024) Remove unused "releaseMemory" from ResultSubpartition

Stephan Ewen created FLINK-19024: Summary: Remove unused "releaseMemory" from ResultSubpartition Key: FLINK-19024 URL: https://issues.apache.org/jira/browse/FLINK-19024 Project: Flink Issue T

SDK vs Connectors

Hi Team, Following is the pipeline Kafka => Processing => SNS Topics . Flink Does not provide a SNS connector out of the box. a) I implemented the above by using AWS SDK and published the messages in the Map operator itself. The pipeline is working well. I see messages flowing to SNS topics. b)