Hi -- I'm wondering if you would be interested in a contribution to add a
HadoopFileSystem implementation, with associated RecoverableWriter, for
Google Cloud Storage. This would be similar to what's already in place for
S3, and it would allow writing to GCS using a StreamingFileSink. The
implement
Guowei Ma created FLINK-21213:
-
Summary: Elasticsearch (v5.3.3) sink end-to-end test' failed
Key: FLINK-21213
URL: https://issues.apache.org/jira/browse/FLINK-21213
Project: Flink
Issue Type: Bu
Guowei Ma created FLINK-21214:
-
Summary:
FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed
Key: FLINK-21214
URL: https://issues.apache.org/jira/browse/FLINK-21214
Project: Flink
Guowei Ma created FLINK-21215:
-
Summary: UnalignedCheckpointITCase.execute
Key: FLINK-21215
URL: https://issues.apache.org/jira/browse/FLINK-21215
Project: Flink
Issue Type: Bug
Compone
Guowei Ma created FLINK-21216:
-
Summary: StreamPandasConversionTests Fails
Key: FLINK-21216
URL: https://issues.apache.org/jira/browse/FLINK-21216
Project: Flink
Issue Type: Bug
Compone
Guowei Ma created FLINK-21217:
-
Summary: Resuming Savepoint (rocks, scale up, rocks timers)
end-to-end test
Key: FLINK-21217
URL: https://issues.apache.org/jira/browse/FLINK-21217
Project: Flink
Dongwon Kim created FLINK-21218:
---
Summary: "state.checkpoints.dir" should be required only when
"execution.checkpointing.interval" is specified
Key: FLINK-21218
URL: https://issues.apache.org/jira/browse/FLINK-21218
