[jira] [Updated] (FLINK-25806) Remove legacy high availability services

[ https://issues.apache.org/jira/browse/FLINK-25806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25806: - Issue Type: Technical Debt (was: Improvement) > Remove legacy high availability

[jira] [Updated] (FLINK-28722) Hybrid Source should use .equals() for Integer comparison

[ https://issues.apache.org/jira/browse/FLINK-28722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28722: - Issue Type: Bug (was: Improvement) > Hybrid Source should use .equals() for Integer

[jira] [Updated] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19358: - Issue Type: Improvement (was: Bug) > when submit job on application mode with HA,the

[jira] [Updated] (FLINK-19358) HA should not always use jobid 0000000000

[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19358: - Summary: HA should not always use jobid 00 (was: when submit job on

[jira] [Updated] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14998: - Issue Type: Technical Debt (was: Bug) > Remove FileUtils#deletePathIfEmpty >

[jira] [Updated] (FLINK-26553) Enable scalafmt for scala codebase

[ https://issues.apache.org/jira/browse/FLINK-26553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26553: - Issue Type: Technical Debt (was: Bug) > Enable scalafmt for scala codebase >

[jira] [Updated] (FLINK-26710) TestLoggerResource hides log lines

[ https://issues.apache.org/jira/browse/FLINK-26710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26710: - Issue Type: Technical Debt (was: Bug) > TestLoggerResource hides log lines >

[jira] [Updated] (FLINK-27163) Fix typo issue in Flink Metrics documentation

[ https://issues.apache.org/jira/browse/FLINK-27163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27163: - Issue Type: Technical Debt (was: Bug) > Fix typo issue in Flink Metrics documentation

[jira] [Updated] (FLINK-27485) Documentation build pipeline is broken

[ https://issues.apache.org/jira/browse/FLINK-27485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27485: - Issue Type: Technical Debt (was: Bug) > Documentation build pipeline is broken >

[jira] [Updated] (FLINK-27751) Dependency resolution from repository.jboss.org fails on CI

[ https://issues.apache.org/jira/browse/FLINK-27751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27751: - Issue Type: Technical Debt (was: Improvement) > Dependency resolution from

[jira] [Updated] (FLINK-27751) Dependency resolution from repository.jboss.org fails on CI

[ https://issues.apache.org/jira/browse/FLINK-27751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27751: - Issue Type: Improvement (was: Bug) > Dependency resolution from repository.jboss.org

[jira] [Updated] (FLINK-28198) CassandraConnectorITCase fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28198: - Issue Type: Technical Debt (was: Bug) > CassandraConnectorITCase fails with timeout >

[jira] [Updated] (FLINK-28263) TPC-DS Bash e2e tests don't clean-up after completing

[ https://issues.apache.org/jira/browse/FLINK-28263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28263: - Issue Type: Technical Debt (was: Bug) > TPC-DS Bash e2e tests don't clean-up after

[jira] [Updated] (FLINK-28388) Python doc build breaking nightly docs

[ https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28388: - Issue Type: Technical Debt (was: Bug) > Python doc build breaking nightly docs >

[jira] [Updated] (FLINK-28781) Hybrid Shuffle should support compression

[ https://issues.apache.org/jira/browse/FLINK-28781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28781: - Issue Type: Improvement (was: Bug) > Hybrid Shuffle should support compression >

[jira] [Updated] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28844: - Issue Type: Technical Debt (was: Bug) > YARNHighAvailabilityITCase fails with

[jira] [Updated] (FLINK-28856) YARNHighAvailabilityITCase tests failed with NoSuchMethodError

[ https://issues.apache.org/jira/browse/FLINK-28856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28856: - Issue Type: Technical Debt (was: Bug) > YARNHighAvailabilityITCase tests failed with

[jira] [Updated] (FLINK-28856) YARNHighAvailabilityITCase tests failed with NoSuchMethodError

[ https://issues.apache.org/jira/browse/FLINK-28856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28856: - Fix Version/s: (was: 1.16.0) > YARNHighAvailabilityITCase tests failed with

[jira] [Updated] (FLINK-28931) BlockingPartitionBenchmark doesn't compile

[ https://issues.apache.org/jira/browse/FLINK-28931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28931: - Issue Type: Technical Debt (was: Bug) > BlockingPartitionBenchmark doesn't compile >

[jira] [Comment Edited] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578890#comment-17578890 ] Chesnay Schepler edited comment on FLINK-28719 at 8/12/22 9:42 AM: ---

[jira] [Comment Edited] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578890#comment-17578890 ] Chesnay Schepler edited comment on FLINK-28719 at 8/12/22 9:43 AM: ---

[jira] [Comment Edited] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578890#comment-17578890 ] Chesnay Schepler edited comment on FLINK-28719 at 8/12/22 9:42 AM: ---

[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578890#comment-17578890 ] Chesnay Schepler commented on FLINK-28719: -- > As far as I understand, op1 and op2 should have

[jira] [Updated] (FLINK-26682) Migrate regression check script to python and to main repository

[ https://issues.apache.org/jira/browse/FLINK-26682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26682: - Issue Type: Technical Debt (was: New Feature) > Migrate regression check script to

[jira] [Updated] (FLINK-24433) "No space left on device" in Azure e2e tests

[ https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24433: - Issue Type: Technical Debt (was: Bug) > "No space left on device" in Azure e2e tests >

[jira] [Closed] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28060. Resolution: Fixed master: bc9b401ed1f2e7257c7b44c9838e34ede9c52ed5 > Kafka Commit on

[jira] [Updated] (FLINK-28857) Add Document for DataStream Cache API

[ https://issues.apache.org/jira/browse/FLINK-28857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28857: - Fix Version/s: 1.16.0 (was: 1.16]) > Add Document for DataStream

[jira] [Updated] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28060: - Fix Version/s: 1.16.0 > Kafka Commit on checkpointing fails repeatedly after a broker

[jira] [Assigned] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28060: Assignee: Chesnay Schepler > Kafka Commit on checkpointing fails repeatedly

[jira] [Updated] (FLINK-28731) Logging of global config should take dynamic properties into account

[ https://issues.apache.org/jira/browse/FLINK-28731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28731: - Priority: Minor (was: Major) > Logging of global config should take dynamic properties

[jira] [Closed] (FLINK-28731) Logging of global config should take dynamic properties into account

[ https://issues.apache.org/jira/browse/FLINK-28731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28731. Resolution: Fixed master: 6b20433e7f007a97a1a958ef28e1c8f58277d940 > Logging of global

[jira] [Commented] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577368#comment-17577368 ] Chesnay Schepler commented on FLINK-28060: -- I ran CI with Kafka 3.2.1 and it passed without

[jira] [Closed] (FLINK-28811) Enable Java 11 tests for Hbase 2

[ https://issues.apache.org/jira/browse/FLINK-28811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28811. Resolution: Fixed master: 5fb135e23e3251bcacf19d8db8cf358ddda76d6e > Enable Java 11

[jira] [Updated] (FLINK-28352) [Umbrella] Make Pulsar connector stable

[ https://issues.apache.org/jira/browse/FLINK-28352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28352: - Priority: Critical (was: Blocker) > [Umbrella] Make Pulsar connector stable >

[jira] [Updated] (FLINK-28865) Add updated Print sink for new interfaces

[ https://issues.apache.org/jira/browse/FLINK-28865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28865: - Description: The built-in print sink still uses the old sink interfaces. Add a new

[jira] [Closed] (FLINK-28865) Add updated Print sink for new interfaces

[ https://issues.apache.org/jira/browse/FLINK-28865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28865. Resolution: Fixed master: aaea1adc155122f066736a4e2a4a287a40a77969 > Add updated Print

[jira] [Commented] (FLINK-28874) Python tests fail locally with flink-connector-hive_2.12 is missing jhyde pentaho-aggdesigner-algorithm:jar:5.1.5-jhyde

[ https://issues.apache.org/jira/browse/FLINK-28874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576907#comment-17576907 ] Chesnay Schepler commented on FLINK-28874: -- You should never run that script locally outside of

[jira] [Closed] (FLINK-28621) Register Java 8 modules in all internal object mappers

[ https://issues.apache.org/jira/browse/FLINK-28621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28621. Fix Version/s: (was: 1.15.2) Resolution: Fixed master:

[jira] [Closed] (FLINK-28333) GlueSchemaRegistryAvroKinesisITCase is being Ignored due to `Access key not configured`

[ https://issues.apache.org/jira/browse/FLINK-28333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28333. Resolution: Not A Problem > GlueSchemaRegistryAvroKinesisITCase is being Ignored due to

[jira] [Closed] (FLINK-28675) Avro Schemas should eagerly validate that class is SpecificRecord

[ https://issues.apache.org/jira/browse/FLINK-28675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28675. Fix Version/s: (was: 1.16.0) Resolution: Invalid This is already enforced by

[jira] [Created] (FLINK-28865) Add updated Print sink for new interfaces

Chesnay Schepler created FLINK-28865: Summary: Add updated Print sink for new interfaces Key: FLINK-28865 URL: https://issues.apache.org/jira/browse/FLINK-28865 Project: Flink Issue

[jira] [Closed] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28844. Resolution: Fixed master: caef5b7a5c1b980cff926fec5dce3a34ad1b354f >

[jira] [Updated] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28844: - Affects Version/s: 1.16.0 > YARNHighAvailabilityITCase fails with NoSuchMethod of

[jira] [Commented] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576370#comment-17576370 ] Chesnay Schepler commented on FLINK-28844: -- No clue why this happens but it should be easy to

[jira] [Assigned] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28844: Assignee: Chesnay Schepler > YARNHighAvailabilityITCase fails with NoSuchMethod

[jira] [Closed] (FLINK-28807) Various components don't respect schema lifecycle

[ https://issues.apache.org/jira/browse/FLINK-28807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28807. Resolution: Fixed master: fb95798b1c301152b912c4b8ec4a737ea16d8641 > Various components

[jira] [Closed] (FLINK-28733) jobmanager.sh should support dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-28733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28733. Resolution: Fixed master: ff2f4cb624ab84c43f2fd0daea2daa8ba74b4169 > jobmanager.sh

[jira] [Created] (FLINK-28841) Document dynamic property support for startup scripts

Chesnay Schepler created FLINK-28841: Summary: Document dynamic property support for startup scripts Key: FLINK-28841 URL: https://issues.apache.org/jira/browse/FLINK-28841 Project: Flink

[jira] [Closed] (FLINK-28713) Remove unused curator-test dependency from flink-test-utils

[ https://issues.apache.org/jira/browse/FLINK-28713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28713. Resolution: Fixed master: 6335b573863af2b30a6541f910be96ddf61f9c84 > Remove unused

[jira] [Closed] (FLINK-28808) CsvFileFormatFactory#createEncodingFormat should create ConverterContext on server-side

[ https://issues.apache.org/jira/browse/FLINK-28808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28808. Resolution: Fixed master: e0f4a0ca9271f0e9e31011578dbdea4b5a8d30fe >

[jira] [Assigned] (FLINK-28183) flink-python is lacking several test dependencies

[ https://issues.apache.org/jira/browse/FLINK-28183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28183: Assignee: Chesnay Schepler > flink-python is lacking several test dependencies >

[jira] [Closed] (FLINK-28804) Use proper stand-ins for missing metrics groups

[ https://issues.apache.org/jira/browse/FLINK-28804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28804. Resolution: Fixed master: fd26e088a43a9426ad5f0b94237495d50d78656b > Use proper

[jira] [Commented] (FLINK-24302) Direct buffer memory leak on Pulsar connector with Java 11

[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575445#comment-17575445 ] Chesnay Schepler commented on FLINK-24302: -- The linked PR was noted merged to 1.10. The merged

[jira] [Updated] (FLINK-28245) Refactor DependencyParser#parseDependencyTreeOutput to return a Tree

[ https://issues.apache.org/jira/browse/FLINK-28245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28245: - Fix Version/s: 1.17.0 (was: 1.16.0) > Refactor

[jira] [Updated] (FLINK-28202) Generalize utils around shade-plugin

[ https://issues.apache.org/jira/browse/FLINK-28202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28202: - Fix Version/s: 1.17.0 (was: 1.16.0) > Generalize utils around

[jira] [Updated] (FLINK-28016) Support Maven 3.3+

[ https://issues.apache.org/jira/browse/FLINK-28016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28016: - Fix Version/s: 1.17.0 (was: 1.16.0) > Support Maven 3.3+ >

[jira] [Updated] (FLINK-28246) Store classifier in dependency

[ https://issues.apache.org/jira/browse/FLINK-28246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28246: - Fix Version/s: 1.17.0 (was: 1.16.0) > Store classifier in

[jira] [Updated] (FLINK-28203) Mark all bundled dependencies as optional

[ https://issues.apache.org/jira/browse/FLINK-28203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28203: - Fix Version/s: 1.17.0 (was: 1.16.0) > Mark all bundled

[jira] [Updated] (FLINK-25252) Enable Kafka E2E tests on Java 11

[ https://issues.apache.org/jira/browse/FLINK-25252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25252: - Summary: Enable Kafka E2E tests on Java 11 (was: Check whether Kafka E2E tests could

[jira] [Closed] (FLINK-25252) Check whether Kafka E2E tests could be run on Java 11

[ https://issues.apache.org/jira/browse/FLINK-25252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25252. Assignee: Martijn Visser Resolution: Fixed master:

[jira] [Comment Edited] (FLINK-24302) Direct buffer memory leak on Pulsar connector with Java 11

[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575197#comment-17575197 ] Chesnay Schepler edited comment on FLINK-24302 at 8/4/22 10:29 AM: ---

[jira] [Commented] (FLINK-24302) Direct buffer memory leak on Pulsar connector with Java 11

[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575197#comment-17575197 ] Chesnay Schepler commented on FLINK-24302: -- There is no release yet with the new APis for

[jira] [Updated] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28680: - Fix Version/s: 1.16.0 1.15.2 1.14.6 > No space

[jira] [Updated] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28680: - Issue Type: Technical Debt (was: Bug) > No space left on device on Azure e2e_2_ci

[jira] [Created] (FLINK-28811) Enabled Java 11 tests for Hbase 2

Chesnay Schepler created FLINK-28811: Summary: Enabled Java 11 tests for Hbase 2 Key: FLINK-28811 URL: https://issues.apache.org/jira/browse/FLINK-28811 Project: Flink Issue Type:

[jira] [Updated] (FLINK-28811) Enable Java 11 tests for Hbase 2

[ https://issues.apache.org/jira/browse/FLINK-28811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28811: - Summary: Enable Java 11 tests for Hbase 2 (was: Enabled Java 11 tests for Hbase 2) >

[jira] [Updated] (FLINK-28807) Various components don't respect schema lifecycle

[ https://issues.apache.org/jira/browse/FLINK-28807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28807: - Description: A surprising number of components never call

[jira] [Updated] (FLINK-28807) Various components don't respect schema lifecycle

[ https://issues.apache.org/jira/browse/FLINK-28807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28807: - Component/s: Connectors / Kinesis > Various components don't respect schema lifecycle >

[jira] [Updated] (FLINK-28808) CsvFileFormatFactory#createEncodingFormat should create ConverterContext on server-side

[ https://issues.apache.org/jira/browse/FLINK-28808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28808: - Description: Since we shouldn't assume that jackson mappers are serializable (due to

[jira] [Created] (FLINK-28808) CsvFileFormatFactory#createEncodingFormat should create ConverterContext on server-side

Chesnay Schepler created FLINK-28808: Summary: CsvFileFormatFactory#createEncodingFormat should create ConverterContext on server-side Key: FLINK-28808 URL: https://issues.apache.org/jira/browse/FLINK-28808

[jira] [Created] (FLINK-28804) Use proper stand-ins for missing metrics groups

Chesnay Schepler created FLINK-28804: Summary: Use proper stand-ins for missing metrics groups Key: FLINK-28804 URL: https://issues.apache.org/jira/browse/FLINK-28804 Project: Flink

[jira] [Created] (FLINK-28807) Various components don't respect schema lifecycle

Chesnay Schepler created FLINK-28807: Summary: Various components don't respect schema lifecycle Key: FLINK-28807 URL: https://issues.apache.org/jira/browse/FLINK-28807 Project: Flink

[jira] [Assigned] (FLINK-28804) Use proper stand-ins for missing metrics groups

[ https://issues.apache.org/jira/browse/FLINK-28804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28804: Assignee: Chesnay Schepler > Use proper stand-ins for missing metrics groups >

[jira] [Closed] (FLINK-28791) flink-sql-gateway-test does not compile on Java 11

[ https://issues.apache.org/jira/browse/FLINK-28791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28791. Resolution: Fixed master: 9efd97e05717181ee9b5489cddc27b6351127e38 >

[jira] [Assigned] (FLINK-28791) flink-sql-gateway-test does not compile on Java 11

[ https://issues.apache.org/jira/browse/FLINK-28791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28791: Assignee: Chesnay Schepler > flink-sql-gateway-test does not compile on Java 11

[jira] [Created] (FLINK-28791) flink-sql-gateway-test does not compile on Java 11

Chesnay Schepler created FLINK-28791: Summary: flink-sql-gateway-test does not compile on Java 11 Key: FLINK-28791 URL: https://issues.apache.org/jira/browse/FLINK-28791 Project: Flink

[jira] [Closed] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28719. Resolution: Information Provided > Mapping a data source before window aggregation causes

[jira] [Commented] (FLINK-28784) ParameterTool support read and parse program arguments from yml file

[ https://issues.apache.org/jira/browse/FLINK-28784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574581#comment-17574581 ] Chesnay Schepler commented on FLINK-28784: -- I would be against this. Arguably Flink should have

[jira] [Comment Edited] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574259#comment-17574259 ] Chesnay Schepler edited comment on FLINK-28653 at 8/2/22 2:21 PM: -- The

[jira] [Commented] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574259#comment-17574259 ] Chesnay Schepler commented on FLINK-28653: -- The issue is that your aggregate function

[jira] [Updated] (FLINK-25962) Flink generated Avro schemas can't be parsed using Python

[ https://issues.apache.org/jira/browse/FLINK-25962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25962: - Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Flink generated Avro

[jira] [Closed] (FLINK-25962) Flink generated Avro schemas can't be parsed using Python

[ https://issues.apache.org/jira/browse/FLINK-25962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25962. Fix Version/s: 1.16.0 Release Note: Avro schemas generated by Flink now use the

[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17573809#comment-17573809 ] Chesnay Schepler commented on FLINK-28719: -- So let's dive into what is happening. The source

[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17573804#comment-17573804 ] Chesnay Schepler commented on FLINK-28719: -- Your test only works when the elements arrive at

[jira] [Comment Edited] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572977#comment-17572977 ] Chesnay Schepler edited comment on FLINK-28653 at 7/29/22 1:17 PM: ---

[jira] [Commented] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572977#comment-17572977 ] Chesnay Schepler commented on FLINK-28653: -- You're also using too many generic parameters;

[jira] [Comment Edited] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572958#comment-17572958 ] Chesnay Schepler edited comment on FLINK-28653 at 7/29/22 1:04 PM: ---

[jira] [Comment Edited] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572958#comment-17572958 ] Chesnay Schepler edited comment on FLINK-28653 at 7/29/22 12:49 PM:

[jira] [Commented] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572958#comment-17572958 ] Chesnay Schepler commented on FLINK-28653: -- FYI, if your lombok class would be recognized as a

[jira] [Comment Edited] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572946#comment-17572946 ] Chesnay Schepler edited comment on FLINK-28653 at 7/29/22 12:14 PM:

[jira] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653 ] Chesnay Schepler deleted comment on FLINK-28653: -- was (Author: zentol): Also, are you intentionally not bundling lombok in your application jar? > State Schema Evolution does not work

[jira] [Commented] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572947#comment-17572947 ] Chesnay Schepler commented on FLINK-28653: -- Also, are you intentionally not bundling lombok in

[jira] [Commented] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572946#comment-17572946 ] Chesnay Schepler commented on FLINK-28653: -- [~peleg68] Please run

[jira] [Updated] (FLINK-28675) Avro Schemas should eagerly validate that class is SpecificRecord

[ https://issues.apache.org/jira/browse/FLINK-28675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28675: - Summary: Avro Schemas should eagerly validate that class is SpecificRecord (was:

[jira] [Updated] (FLINK-27206) Deprecate reflection-based reporter instantiation

[ https://issues.apache.org/jira/browse/FLINK-27206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27206: - Release Note: Configuring reporters by their class has been deprecated. Reporter

[jira] [Created] (FLINK-28735) Deprecate host/webuiport parameter of jobmanager.sh

Chesnay Schepler created FLINK-28735: Summary: Deprecate host/webuiport parameter of jobmanager.sh Key: FLINK-28735 URL: https://issues.apache.org/jira/browse/FLINK-28735 Project: Flink

[jira] [Created] (FLINK-28733) jobmanager.sh should support dynamic properties

Chesnay Schepler created FLINK-28733: Summary: jobmanager.sh should support dynamic properties Key: FLINK-28733 URL: https://issues.apache.org/jira/browse/FLINK-28733 Project: Flink

[jira] [Closed] (FLINK-28634) Add a simple Json (De) SerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-28634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28634. Resolution: Fixed master: ae45bd3c50abf8b2621a5de31410ae381f7ffa04 > Add a simple Json

[jira] [Created] (FLINK-28731) Logging of global config should take dynamic properties into account

Chesnay Schepler created FLINK-28731: Summary: Logging of global config should take dynamic properties into account Key: FLINK-28731 URL: https://issues.apache.org/jira/browse/FLINK-28731

[jira] [Closed] (FLINK-25989) EventTimeWindowCheckpointingITCase failed with exit code 137

[ https://issues.apache.org/jira/browse/FLINK-25989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25989. Resolution: Fixed Memory issue likely related to overloading the machines; hasn't

<    10   11   12   13   14   15   16   17   18   19   >