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
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
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)
16 matches
Mail list logo