[jira] [Created] (FLINK-34364) stage_source_release.sh should exclude tools/release directory from the source release

Etienne Chauchot created FLINK-34364: Summary: stage_source_release.sh should exclude tools/release directory from the source release Key: FLINK-34364 URL: https://issues.apache.org/jira/browse/FLINK-34364

[jira] [Created] (FLINK-34363) Connectors release utils should allow to not specify flink version in stage_jars.sh

Etienne Chauchot created FLINK-34363: Summary: Connectors release utils should allow to not specify flink version in stage_jars.sh Key: FLINK-34363 URL: https://issues.apache.org/jira/browse/FLINK-34363

[jira] [Created] (FLINK-34137) Update CI to test archunit configuration

Etienne Chauchot created FLINK-34137: Summary: Update CI to test archunit configuration Key: FLINK-34137 URL: https://issues.apache.org/jira/browse/FLINK-34137 Project: Flink Issue Type:

[jira] [Created] (FLINK-34136) Execute archunit tests only with Flink version that connectors were built against

Etienne Chauchot created FLINK-34136: Summary: Execute archunit tests only with Flink version that connectors were built against Key: FLINK-34136 URL: https://issues.apache.org/jira/browse/FLINK-34136

[jira] [Created] (FLINK-33059) Support transparent compression for file-connector for all file input formats

Etienne Chauchot created FLINK-33059: Summary: Support transparent compression for file-connector for all file input formats Key: FLINK-33059 URL: https://issues.apache.org/jira/browse/FLINK-33059

[jira] [Created] (FLINK-32563) Allow connectors CI to specify the main supported Flink version

Etienne Chauchot created FLINK-32563: Summary: Allow connectors CI to specify the main supported Flink version Key: FLINK-32563 URL: https://issues.apache.org/jira/browse/FLINK-32563 Project:

[jira] [Created] (FLINK-32222) Cassandra Source uses DataInputDeserializer and DataOutputSerializer non public apis

Etienne Chauchot created FLINK-3: Summary: Cassandra Source uses DataInputDeserializer and DataOutputSerializer non public apis Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3

[jira] [Created] (FLINK-32014) Cassandra source documentation is missing

Etienne Chauchot created FLINK-32014: Summary: Cassandra source documentation is missing Key: FLINK-32014 URL: https://issues.apache.org/jira/browse/FLINK-32014 Project: Flink Issue

[jira] [Created] (FLINK-31927) Cassandra source raises an exception on Flink 1.16.0 on a real Cassandra cluster

Etienne Chauchot created FLINK-31927: Summary: Cassandra source raises an exception on Flink 1.16.0 on a real Cassandra cluster Key: FLINK-31927 URL: https://issues.apache.org/jira/browse/FLINK-31927

[jira] [Created] (FLINK-31870) Cassandra input/output formats documentation is missing

Etienne Chauchot created FLINK-31870: Summary: Cassandra input/output formats documentation is missing Key: FLINK-31870 URL: https://issues.apache.org/jira/browse/FLINK-31870 Project: Flink

[jira] [Created] (FLINK-30805) SplitEnumerator#handleSplitRequest() should be called automatically

Etienne Chauchot created FLINK-30805: Summary: SplitEnumerator#handleSplitRequest() should be called automatically Key: FLINK-30805 URL: https://issues.apache.org/jira/browse/FLINK-30805 Project:

[jira] [Created] (FLINK-30802) Improve SplitReader#fetch() documentation

Etienne Chauchot created FLINK-30802: Summary: Improve SplitReader#fetch() documentation Key: FLINK-30802 URL: https://issues.apache.org/jira/browse/FLINK-30802 Project: Flink Issue

[jira] [Created] (FLINK-29982) Move cassandra connector to dedicated repo

Etienne Chauchot created FLINK-29982: Summary: Move cassandra connector to dedicated repo Key: FLINK-29982 URL: https://issues.apache.org/jira/browse/FLINK-29982 Project: Flink Issue

[jira] [Created] (FLINK-29605) Create a bounded version of SourceTestSuiteBase#testSourceMetrics

Etienne Chauchot created FLINK-29605: Summary: Create a bounded version of SourceTestSuiteBase#testSourceMetrics Key: FLINK-29605 URL: https://issues.apache.org/jira/browse/FLINK-29605 Project:

[jira] [Created] (FLINK-29563) SourceTestSuiteBase#testSourceMetrics enters an infinite waiting loop in case the number of records counter is wrong

Etienne Chauchot created FLINK-29563: Summary: SourceTestSuiteBase#testSourceMetrics enters an infinite waiting loop in case the number of records counter is wrong Key: FLINK-29563 URL:

[jira] [Created] (FLINK-29484) Support orderless check of elements in SourceTestSuiteBase and SinkTestSuiteBase

Etienne Chauchot created FLINK-29484: Summary: Support orderless check of elements in SourceTestSuiteBase and SinkTestSuiteBase Key: FLINK-29484 URL: https://issues.apache.org/jira/browse/FLINK-29484

[jira] [Created] (FLINK-27884) Introduce a flush mechanism for OutputFormats

Etienne Chauchot created FLINK-27884: Summary: Introduce a flush mechanism for OutputFormats Key: FLINK-27884 URL: https://issues.apache.org/jira/browse/FLINK-27884 Project: Flink Issue

[jira] [Created] (FLINK-27866) CassandraOutputFormat and CassandraSink will timeout twice if the number of maximum requests is reached

Etienne Chauchot created FLINK-27866: Summary: CassandraOutputFormat and CassandraSink will timeout twice if the number of maximum requests is reached Key: FLINK-27866 URL:

[jira] [Created] (FLINK-27457) CassandraOutputFormats should support flush

Etienne Chauchot created FLINK-27457: Summary: CassandraOutputFormats should support flush Key: FLINK-27457 URL: https://issues.apache.org/jira/browse/FLINK-27457 Project: Flink Issue

[jira] [Created] (FLINK-25851) CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP

Etienne Chauchot created FLINK-25851: Summary: CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP Key: FLINK-25851 URL:

[jira] [Created] (FLINK-25690) RetryRule should allow a callback to be called on exception and failure cases

Etienne Chauchot created FLINK-25690: Summary: RetryRule should allow a callback to be called on exception and failure cases Key: FLINK-25690 URL: https://issues.apache.org/jira/browse/FLINK-25690

[jira] [Created] (FLINK-25415) implement retrial on connections to Cassandra container

Etienne Chauchot created FLINK-25415: Summary: implement retrial on connections to Cassandra container Key: FLINK-25415 URL: https://issues.apache.org/jira/browse/FLINK-25415 Project: Flink

[jira] [Created] (FLINK-25147) Migrate cassandra tests to test containers

Etienne Chauchot created FLINK-25147: Summary: Migrate cassandra tests to test containers Key: FLINK-25147 URL: https://issues.apache.org/jira/browse/FLINK-25147 Project: Flink Issue

[jira] [Created] (FLINK-24921) FileSourceSplit should not be visible in the user API in ParquetColumnarRowInputFormat

Etienne Chauchot created FLINK-24921: Summary: FileSourceSplit should not be visible in the user API in ParquetColumnarRowInputFormat Key: FLINK-24921 URL: https://issues.apache.org/jira/browse/FLINK-24921

[jira] [Created] (FLINK-24859) Document new File formats

Etienne Chauchot created FLINK-24859: Summary: Document new File formats Key: FLINK-24859 URL: https://issues.apache.org/jira/browse/FLINK-24859 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-23327) Spark Structured Streaming runner sources should be put back to main src folder

Etienne Chauchot created FLINK-23327: Summary: Spark Structured Streaming runner sources should be put back to main src folder Key: FLINK-23327 URL: https://issues.apache.org/jira/browse/FLINK-23327

[jira] [Created] (FLINK-22587) Support aggregations in batch mode with DataStream API

Etienne Chauchot created FLINK-22587: Summary: Support aggregations in batch mode with DataStream API Key: FLINK-22587 URL: https://issues.apache.org/jira/browse/FLINK-22587 Project: Flink

[jira] [Created] (FLINK-21863) SortPartition should allow chaining of KeySelectors to support different sorting orders for the fields

Etienne Chauchot created FLINK-21863: Summary: SortPartition should allow chaining of KeySelectors to support different sorting orders for the fields Key: FLINK-21863 URL:

[jira] [Created] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

Etienne Chauchot created FLINK-21520: Summary: ParquetInputFormat#setfilterPredicate() does not work Key: FLINK-21520 URL: https://issues.apache.org/jira/browse/FLINK-21520 Project: Flink

[jira] [Created] (FLINK-21468) ParquetTableSource: where clause on integer does not work

Etienne Chauchot created FLINK-21468: Summary: ParquetTableSource: where clause on integer does not work Key: FLINK-21468 URL: https://issues.apache.org/jira/browse/FLINK-21468 Project: Flink

[jira] [Created] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

Etienne Chauchot created FLINK-21389: Summary: ParquetInputFormat should not need parquet schema as user input Key: FLINK-21389 URL: https://issues.apache.org/jira/browse/FLINK-21389 Project:

[jira] [Created] (FLINK-21388) Parquet DECIMAL logical type is not properly supported in ParquetInputFormat

Etienne Chauchot created FLINK-21388: Summary: Parquet DECIMAL logical type is not properly supported in ParquetInputFormat Key: FLINK-21388 URL: https://issues.apache.org/jira/browse/FLINK-21388

[jira] [Created] (FLINK-17961) Create an Elasticsearch source

Etienne Chauchot created FLINK-17961: Summary: Create an Elasticsearch source Key: FLINK-17961 URL: https://issues.apache.org/jira/browse/FLINK-17961 Project: Flink Issue Type: New

[jira] [Created] (FLINK-17213) Surefire configuration should override locale

Etienne Chauchot created FLINK-17213: Summary: Surefire configuration should override locale Key: FLINK-17213 URL: https://issues.apache.org/jira/browse/FLINK-17213 Project: Flink Issue