[jira] [Created] (FLINK-35052) Webhook validator should reject unsupported Flink versions

Alexander Fedulov created FLINK-35052: - Summary: Webhook validator should reject unsupported Flink versions Key: FLINK-35052 URL: https://issues.apache.org/jira/browse/FLINK-35052 Project: Flink

[jira] [Created] (FLINK-34117) CompactCoordinator for table file sink loses data upon job termination

Alexander Fedulov created FLINK-34117: - Summary: CompactCoordinator for table file sink loses data upon job termination Key: FLINK-34117 URL: https://issues.apache.org/jira/browse/FLINK-34117

[jira] [Created] (FLINK-33789) Expose restart time as metric

Alexander Fedulov created FLINK-33789: - Summary: Expose restart time as metric Key: FLINK-33789 URL: https://issues.apache.org/jira/browse/FLINK-33789 Project: Flink Issue Type: New

[jira] [Created] (FLINK-33525) Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API

Alexander Fedulov created FLINK-33525: - Summary: Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API Key: FLINK-33525 URL: https://issues.apache.org/jira/browse/FLINK-33525

[jira] [Created] (FLINK-33335) Remove unused e2e tests

Alexander Fedulov created FLINK-5: - Summary: Remove unused e2e tests Key: FLINK-5 URL: https://issues.apache.org/jira/browse/FLINK-5 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-33326) Remove usage of FromElementsFunction

Alexander Fedulov created FLINK-33326: - Summary: Remove usage of FromElementsFunction Key: FLINK-33326 URL: https://issues.apache.org/jira/browse/FLINK-33326 Project: Flink Issue Type:

[jira] [Created] (FLINK-33286) DataGeneratorSource should support automatic return type detection

Alexander Fedulov created FLINK-33286: - Summary: DataGeneratorSource should support automatic return type detection Key: FLINK-33286 URL: https://issues.apache.org/jira/browse/FLINK-33286

[jira] [Created] (FLINK-33199) ArchitectureTests should test for canonical class names instead of Class objects

Alexander Fedulov created FLINK-33199: - Summary: ArchitectureTests should test for canonical class names instead of Class objects Key: FLINK-33199 URL: https://issues.apache.org/jira/browse/FLINK-33199

[jira] [Created] (FLINK-32904) Support cron expressions for periodic snapshots triggering

Alexander Fedulov created FLINK-32904: - Summary: Support cron expressions for periodic snapshots triggering Key: FLINK-32904 URL: https://issues.apache.org/jira/browse/FLINK-32904 Project: Flink

[jira] [Created] (FLINK-32719) Block upgrades during checkpoints when LATEST_STATE recovery is configured

Alexander Fedulov created FLINK-32719: - Summary: Block upgrades during checkpoints when LATEST_STATE recovery is configured Key: FLINK-32719 URL: https://issues.apache.org/jira/browse/FLINK-32719

[jira] [Created] (FLINK-32713) Cascade deprecation to non-private methods that reference SourceFunction

Alexander Fedulov created FLINK-32713: - Summary: Cascade deprecation to non-private methods that reference SourceFunction Key: FLINK-32713 URL: https://issues.apache.org/jira/browse/FLINK-32713

[jira] [Created] (FLINK-32696) Promote Kinesis connector support to PublicEvolving

Alexander Fedulov created FLINK-32696: - Summary: Promote Kinesis connector support to PublicEvolving Key: FLINK-32696 URL: https://issues.apache.org/jira/browse/FLINK-32696 Project: Flink

[jira] [Created] (FLINK-32695) Migrate SourceFunction in Tests to Source API

Alexander Fedulov created FLINK-32695: - Summary: Migrate SourceFunction in Tests to Source API Key: FLINK-32695 URL: https://issues.apache.org/jira/browse/FLINK-32695 Project: Flink

[jira] [Created] (FLINK-32694) Cascade deprecation to classes that implement ParallelSourceFunction

Alexander Fedulov created FLINK-32694: - Summary: Cascade deprecation to classes that implement ParallelSourceFunction Key: FLINK-32694 URL: https://issues.apache.org/jira/browse/FLINK-32694

[jira] [Created] (FLINK-32693) Cascade deprecation to classes that directly implement SourceFunction

Alexander Fedulov created FLINK-32693: - Summary: Cascade deprecation to classes that directly implement SourceFunction Key: FLINK-32693 URL: https://issues.apache.org/jira/browse/FLINK-32693

[jira] [Created] (FLINK-32692) [umbrella] Nice-to-haves for SourceFunction API removal

Alexander Fedulov created FLINK-32692: - Summary: [umbrella] Nice-to-haves for SourceFunction API removal Key: FLINK-32692 URL: https://issues.apache.org/jira/browse/FLINK-32692 Project: Flink

[jira] [Created] (FLINK-32673) Migrage Google PubSub connector to V2

Alexander Fedulov created FLINK-32673: - Summary: Migrage Google PubSub connector to V2 Key: FLINK-32673 URL: https://issues.apache.org/jira/browse/FLINK-32673 Project: Flink Issue Type:

[jira] [Created] (FLINK-32672) Migrate RabbitMQ connector to Source V2 API

Alexander Fedulov created FLINK-32672: - Summary: Migrate RabbitMQ connector to Source V2 API Key: FLINK-32672 URL: https://issues.apache.org/jira/browse/FLINK-32672 Project: Flink Issue

[jira] [Created] (FLINK-32670) Annotate interfaces that inherit from SourceFunction as deprecated

Alexander Fedulov created FLINK-32670: - Summary: Annotate interfaces that inherit from SourceFunction as deprecated Key: FLINK-32670 URL: https://issues.apache.org/jira/browse/FLINK-32670

[jira] [Created] (FLINK-32373) Support passing headers with SQL Client gateway requests

Alexander Fedulov created FLINK-32373: - Summary: Support passing headers with SQL Client gateway requests Key: FLINK-32373 URL: https://issues.apache.org/jira/browse/FLINK-32373 Project: Flink

[jira] [Created] (FLINK-32035) SQL Client should support HTTPS with built-in JDK certificates

Alexander Fedulov created FLINK-32035: - Summary: SQL Client should support HTTPS with built-in JDK certificates Key: FLINK-32035 URL: https://issues.apache.org/jira/browse/FLINK-32035 Project:

[jira] [Created] (FLINK-32030) SQL Client gateway mode should accept URLs

Alexander Fedulov created FLINK-32030: - Summary: SQL Client gateway mode should accept URLs Key: FLINK-32030 URL: https://issues.apache.org/jira/browse/FLINK-32030 Project: Flink Issue

[jira] [Created] (FLINK-31871) Interpret Flink MemoryUnits according to the actual user input

Alexander Fedulov created FLINK-31871: - Summary: Interpret Flink MemoryUnits according to the actual user input Key: FLINK-31871 URL: https://issues.apache.org/jira/browse/FLINK-31871 Project:

[jira] [Created] (FLINK-29890) UDFs classloading from JARs in 1.16 is broken

Alexander Fedulov created FLINK-29890: - Summary: UDFs classloading from JARs in 1.16 is broken Key: FLINK-29890 URL: https://issues.apache.org/jira/browse/FLINK-29890 Project: Flink

[jira] [Created] (FLINK-29727) Fall back to flink-conf.yaml if no JOB_MANAGER_RPC_ADDRESS is specified

Alexander Fedulov created FLINK-29727: - Summary: Fall back to flink-conf.yaml if no JOB_MANAGER_RPC_ADDRESS is specified Key: FLINK-29727 URL: https://issues.apache.org/jira/browse/FLINK-29727

[jira] [Created] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

Alexander Fedulov created FLINK-29476: - Summary: Kinesis Connector retry mechanism not applied to EOFException Key: FLINK-29476 URL: https://issues.apache.org/jira/browse/FLINK-29476 Project:

[jira] [Created] (FLINK-29364) Root cause of Exceptions thrown in the SourceReader start() method gets "swallowed".

Alexander Fedulov created FLINK-29364: - Summary: Root cause of Exceptions thrown in the SourceReader start() method gets "swallowed". Key: FLINK-29364 URL: https://issues.apache.org/jira/browse/FLINK-29364

[jira] [Created] (FLINK-28410) Add Elasticsearch E2E test cases to the external repository

Alexander Fedulov created FLINK-28410: - Summary: Add Elasticsearch E2E test cases to the external repository Key: FLINK-28410 URL: https://issues.apache.org/jira/browse/FLINK-28410 Project: Flink

[jira] [Created] (FLINK-28409) Move FlinkContainerTestEnvironment and its dependencied into flink-connector-test-utils

Alexander Fedulov created FLINK-28409: - Summary: Move FlinkContainerTestEnvironment and its dependencied into flink-connector-test-utils Key: FLINK-28409 URL: https://issues.apache.org/jira/browse/FLINK-28409

[jira] [Created] (FLINK-28229) Introduce Source API alternatives for StreamExecutionEnvironment#fromCollection() methods

Alexander Fedulov created FLINK-28229: - Summary: Introduce Source API alternatives for StreamExecutionEnvironment#fromCollection() methods Key: FLINK-28229 URL:

[jira] [Created] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

Alexander Fedulov created FLINK-28227: - Summary: Add implementations for classes in o.a.f.streaming.examples based on the new new Source API Key: FLINK-28227 URL:

[jira] [Created] (FLINK-28056) Introduce high level API for cases that do not require specific SourceEnumerator logic.

Alexander Fedulov created FLINK-28056: - Summary: Introduce high level API for cases that do not require specific SourceEnumerator logic. Key: FLINK-28056 URL: https://issues.apache.org/jira/browse/FLINK-28056

[jira] [Created] (FLINK-28055) Introduce Source API utilities for throttling number of records emitted per second.

Alexander Fedulov created FLINK-28055: - Summary: Introduce Source API utilities for throttling number of records emitted per second. Key: FLINK-28055 URL: https://issues.apache.org/jira/browse/FLINK-28055

[jira] [Created] (FLINK-28054) Introduce Source API utilities to control records emitted per checkpoint

Alexander Fedulov created FLINK-28054: - Summary: Introduce Source API utilities to control records emitted per checkpoint Key: FLINK-28054 URL: https://issues.apache.org/jira/browse/FLINK-28054

[jira] [Created] (FLINK-28051) Introduce Source API alternative to ExternallyInducedSource

Alexander Fedulov created FLINK-28051: - Summary: Introduce Source API alternative to ExternallyInducedSource Key: FLINK-28051 URL: https://issues.apache.org/jira/browse/FLINK-28051 Project: Flink

[jira] [Created] (FLINK-28050) Introduce Source API alternative to SourceExecutionContext#fromCollection(*) methods

Alexander Fedulov created FLINK-28050: - Summary: Introduce Source API alternative to SourceExecutionContext#fromCollection(*) methods Key: FLINK-28050 URL: https://issues.apache.org/jira/browse/FLINK-28050

[jira] [Created] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records

Alexander Fedulov created FLINK-28049: - Summary: Introduce FLIP-208 functionality to stop Source based on consumed records Key: FLINK-28049 URL: https://issues.apache.org/jira/browse/FLINK-28049

[jira] [Created] (FLINK-28048) Introduce Source API alternative to FiniteTestSource

Alexander Fedulov created FLINK-28048: - Summary: Introduce Source API alternative to FiniteTestSource Key: FLINK-28048 URL: https://issues.apache.org/jira/browse/FLINK-28048 Project: Flink

[jira] [Created] (FLINK-28047) Deprecate StreamExecutionEnvironment#readFiles(*) methods in favor of FileSource#forRecordStreamFormat/forBulkFileFormat.

Alexander Fedulov created FLINK-28047: - Summary: Deprecate StreamExecutionEnvironment#readFiles(*) methods in favor of FileSource#forRecordStreamFormat/forBulkFileFormat. Key: FLINK-28047 URL:

[jira] [Created] (FLINK-28046) Annotate SourceFunction as deprecated

Alexander Fedulov created FLINK-28046: - Summary: Annotate SourceFunction as deprecated Key: FLINK-28046 URL: https://issues.apache.org/jira/browse/FLINK-28046 Project: Flink Issue Type:

[jira] [Created] (FLINK-28045) [umbrella] Deprecate SourceFunction API

Alexander Fedulov created FLINK-28045: - Summary: [umbrella] Deprecate SourceFunction API Key: FLINK-28045 URL: https://issues.apache.org/jira/browse/FLINK-28045 Project: Flink Issue

[jira] [Created] (FLINK-27919) Add FLIP-27-based Data Generator Source

Alexander Fedulov created FLINK-27919: - Summary: Add FLIP-27-based Data Generator Source Key: FLINK-27919 URL: https://issues.apache.org/jira/browse/FLINK-27919 Project: Flink Issue

[jira] [Created] (FLINK-27854) Refactor FlinkImageBuilder and FlinkContainerBuilder

Alexander Fedulov created FLINK-27854: - Summary: Refactor FlinkImageBuilder and FlinkContainerBuilder Key: FLINK-27854 URL: https://issues.apache.org/jira/browse/FLINK-27854 Project: Flink

[jira] [Created] (FLINK-27671) Publish SNAPSHOT docker images

Alexander Fedulov created FLINK-27671: - Summary: Publish SNAPSHOT docker images Key: FLINK-27671 URL: https://issues.apache.org/jira/browse/FLINK-27671 Project: Flink Issue Type:

[jira] [Created] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

Alexander Fedulov created FLINK-27142: - Summary: Remove bash tests dependencies on the Elasticsearch connector. Key: FLINK-27142 URL: https://issues.apache.org/jira/browse/FLINK-27142 Project:

[jira] [Created] (FLINK-27066) Reintroduce e2e tests in ES as Java tests.

Alexander Fedulov created FLINK-27066: - Summary: Reintroduce e2e tests in ES as Java tests. Key: FLINK-27066 URL: https://issues.apache.org/jira/browse/FLINK-27066 Project: Flink Issue

[jira] [Created] (FLINK-26716) Migrate PostgreSQL tests to Testcontainers

Alexander Fedulov created FLINK-26716: - Summary: Migrate PostgreSQL tests to Testcontainers Key: FLINK-26716 URL: https://issues.apache.org/jira/browse/FLINK-26716 Project: Flink Issue

[jira] [Created] (FLINK-26557) Extend CsvFormat documentation based on release-testing feedback

Alexander Fedulov created FLINK-26557: - Summary: Extend CsvFormat documentation based on release-testing feedback Key: FLINK-26557 URL: https://issues.apache.org/jira/browse/FLINK-26557 Project:

[jira] [Created] (FLINK-26342) Add missing CSV format page

Alexander Fedulov created FLINK-26342: - Summary: Add missing CSV format page Key: FLINK-26342 URL: https://issues.apache.org/jira/browse/FLINK-26342 Project: Flink Issue Type:

[jira] [Created] (FLINK-26311) Test CsvFormat

Alexander Fedulov created FLINK-26311: - Summary: Test CsvFormat Key: FLINK-26311 URL: https://issues.apache.org/jira/browse/FLINK-26311 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26233) FileSinkCompactionSwitchITCase.testSwitchingCompaction() fails

Alexander Fedulov created FLINK-26233: - Summary: FileSinkCompactionSwitchITCase.testSwitchingCompaction() fails Key: FLINK-26233 URL: https://issues.apache.org/jira/browse/FLINK-26233 Project:

[jira] [Created] (FLINK-26074) Improve FlameGraphs scalability for high parallelism jobs

Alexander Fedulov created FLINK-26074: - Summary: Improve FlameGraphs scalability for high parallelism jobs Key: FLINK-26074 URL: https://issues.apache.org/jira/browse/FLINK-26074 Project: Flink

[jira] [Created] (FLINK-25931) Add projection pushdown support for CsvFormatFactory

Alexander Fedulov created FLINK-25931: - Summary: Add projection pushdown support for CsvFormatFactory Key: FLINK-25931 URL: https://issues.apache.org/jira/browse/FLINK-25931 Project: Flink

[jira] [Created] (FLINK-25927) Make flink-connector-base dependency usage consistent across all connectors.

Alexander Fedulov created FLINK-25927: - Summary: Make flink-connector-base dependency usage consistent across all connectors. Key: FLINK-25927 URL: https://issues.apache.org/jira/browse/FLINK-25927

[jira] [Created] (FLINK-25822) Migrate away from using Source- and SinkFunctions for internal tests

Alexander Fedulov created FLINK-25822: - Summary: Migrate away from using Source- and SinkFunctions for internal tests Key: FLINK-25822 URL: https://issues.apache.org/jira/browse/FLINK-25822

[jira] [Created] (FLINK-24703) Add support for reading CSV files based on StreamFormat (new file source API)

Alexander Fedulov created FLINK-24703: - Summary: Add support for reading CSV files based on StreamFormat (new file source API) Key: FLINK-24703 URL: https://issues.apache.org/jira/browse/FLINK-24703

[jira] [Created] (FLINK-18398) ElasticSearch unavailibility causes TM shutdown

Alexander Fedulov created FLINK-18398: - Summary: ElasticSearch unavailibility causes TM shutdown Key: FLINK-18398 URL: https://issues.apache.org/jira/browse/FLINK-18398 Project: Flink

[jira] [Created] (FLINK-16222) Use plugins mechanism for initializing MetricReporters

Alexander Fedulov created FLINK-16222: - Summary: Use plugins mechanism for initializing MetricReporters Key: FLINK-16222 URL: https://issues.apache.org/jira/browse/FLINK-16222 Project: Flink

[jira] [Created] (FLINK-16022) AbstractDownloadCache does not clean up download directory in case of failures

Alexander Fedulov created FLINK-16022: - Summary: AbstractDownloadCache does not clean up download directory in case of failures Key: FLINK-16022 URL: https://issues.apache.org/jira/browse/FLINK-16022

[jira] [Created] (FLINK-13703) AvroTypeInfo requires objects to be strict POJOs (mutable, with setters)

Alexander Fedulov created FLINK-13703: - Summary: AvroTypeInfo requires objects to be strict POJOs (mutable, with setters) Key: FLINK-13703 URL: https://issues.apache.org/jira/browse/FLINK-13703

[jira] [Created] (FLINK-12870) Improve documentation of keys schema evolution

Alexander Fedulov created FLINK-12870: - Summary: Improve documentation of keys schema evolution Key: FLINK-12870 URL: https://issues.apache.org/jira/browse/FLINK-12870 Project: Flink

[jira] [Created] (FLINK-10753) Propagate and log snapshotting exceptions

Alexander Fedulov created FLINK-10753: - Summary: Propagate and log snapshotting exceptions Key: FLINK-10753 URL: https://issues.apache.org/jira/browse/FLINK-10753 Project: Flink Issue