issues  

Messages by Thread

• Re: [PR] [hotfix][postgres] Flink CDC Postgres Connector subsribe regular expression [flink-cdc] via GitHub
  • Re: [PR] [hotfix][postgres] Flink CDC Postgres Connector subsribe regular expression [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-34124) Disable Kyro by default Weijie Guo (Jira)
• [jira] [Updated] (FLINK-34124) Disable Kyro by default Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-34124) Disable Kyro by default Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-35068) Introduce built-in serialization support for Set Weijie Guo (Jira)
• [jira] [Commented] (FLINK-35068) Introduce built-in serialization support for Set Weijie Guo (Jira)
• [jira] [Created] (FLINK-37113) Introduce document for datastream api v2 Weijie Guo (Jira)
• [jira] [Commented] (FLINK-36356) HadoopRecoverableWriterTest.testRecoverWithState due to IOException xuyang (Jira)
• Re: [PR] [FLINK-36493][TABLE API] Remove all deprecated methods in MapView [flink] via GitHub
  • Re: [PR] [FLINK-36493][TABLE API] Remove all deprecated methods in MapView [flink] via GitHub
  • Re: [PR] [FLINK-36493][TABLE API] Remove all deprecated methods in MapView [flink] via GitHub
• Re: [PR] [FLINK-36492][TABLE API] Remove all deprecated methods in ListView [flink] via GitHub
  • Re: [PR] [FLINK-36492][TABLE API] Remove all deprecated methods in ListView [flink] via GitHub
  • Re: [PR] [FLINK-36492][TABLE API] Remove all deprecated methods in ListView [flink] via GitHub
• [PR] [hotfix][postgres] PostgresSourceFetchTaskContext log do not output P… [flink-cdc] via GitHub
• Re: [PR] [hotfix][postgres] Flink CDC Postgres Connector subsribe regular expr… [flink-cdc] via GitHub
  • Re: [PR] [hotfix][postgres] Flink CDC Postgres Connector subsribe regular expr… [flink-cdc] via GitHub
• Re: [PR] [FLINK-36497][table]Remove all deprecated methods `CatalogTable` [flink] via GitHub
  • Re: [PR] [FLINK-36497][table]Remove all deprecated methods `CatalogTable` [flink] via GitHub
• [jira] [Resolved] (FLINK-36497) Remove all deprecated methods in `CatalogTable` dalongliu (Jira)
• [jira] [Commented] (FLINK-36497) Remove all deprecated methods in `CatalogTable` dalongliu (Jira)
• Re: [PR] FLINK-36506: Remove all deprecated methods in `ColumnStats` [flink] via GitHub
  • Re: [PR] FLINK-36506: Remove all deprecated methods in `ColumnStats` [flink] via GitHub
• [jira] [Resolved] (FLINK-36506) Remove all deprecated methods in `ColumnStats` dalongliu (Jira)
• [jira] [Resolved] (FLINK-36985) remove Catalog.ColumnAlreadyExistException when apply applyAddColumnEventWithPosition in paimon Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-36985) remove Catalog.ColumnAlreadyExistException when apply applyAddColumnEventWithPosition in paimon Leonard Xu (Jira)
• Re: [PR] [FLINK-36985]remove Catalog.ColumnAlreadyExistException when apply applyAddColumnEventWithPosition in paimon [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-36936) Introduce UpdatableTopNFunction in Rank with Async State API xuyang (Jira)
• [jira] [Comment Edited] (FLINK-36936) Introduce UpdatableTopNFunction in Rank with Async State API xuyang (Jira)
• Re: [PR] [FLINK-37103] The parameters passed when calling method FactoryUtil.createDynamicTableSource are inconsistent [flink-connector-hive] via GitHub
  • Re: [PR] [FLINK-37103] The parameters passed when calling method FactoryUtil.createDynamicTableSource are inconsistent [flink-connector-hive] via GitHub
  • Re: [PR] [FLINK-37103] The parameters passed when calling method FactoryUtil.createDynamicTableSource are inconsistent [flink-connector-hive] via GitHub
• [jira] [Created] (FLINK-37112) FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 xuhuang (Jira)
• Re: [PR] 修改FlinkDeployment的jarURI地址错误的问题 [flink-cdc] via GitHub
  • Re: [PR] 修改FlinkDeployment的jarURI地址错误的问题 [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-36899) Introduce metrics for cache Yanfei Lei (Jira)
• [jira] [Commented] (FLINK-36957) Implement async StreamFlatMap Yanfei Lei (Jira)
• [jira] [Resolved] (FLINK-36957) Implement async StreamFlatMap Yanfei Lei (Jira)
• [jira] [Resolved] (FLINK-36899) Introduce metrics for cache Yanfei Lei (Jira)
• Re: [PR] [hotfix] [docs] Add lead()/lag() Table API agg functions to docs [flink] via GitHub
• [jira] [Created] (FLINK-37111) Allow setting `sink.version` for StarRocks Pipeline connector yux (Jira)
• [jira] [Commented] (FLINK-34123) Introduce built-in serialization support for Map and List Weijie Guo (Jira)
• [jira] [Assigned] (FLINK-36310) Remove per-job and run-application deprecated APIs Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-36836) Autoscaler Supports config the upper and lower limits of target utilization. Rui Fan (Jira)
• [jira] [Updated] (FLINK-36310) Remove per-job and run-application deprecated APIs Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-34123) Introduce built-in serialization support for Map and List Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-35555) Serializing List with null values throws NPE Weijie Guo (Jira)
• [jira] [Assigned] (FLINK-35555) Serializing List with null values throws NPE Weijie Guo (Jira)
• Re: [PR] [FLINK-36986][table] Migrate SplitRemoteConditionFromJoinRule to java [flink] via GitHub
• [jira] [Closed] (FLINK-37110) When the database and schema names of the regular expression are the same, the results of table selector filtering will be incorrect. Jira
• [jira] [Assigned] (FLINK-37101) Remove internal set methods in SerializerConfig Weijie Guo (Jira)
• [jira] [Updated] (FLINK-34037) FLIP-398: Improve Serialization Configuration And Usage In Flink Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-34037) FLIP-398: Improve Serialization Configuration And Usage In Flink Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-37101) Remove internal set methods in SerializerConfig Weijie Guo (Jira)
• Re: [PR] [FLINK-36647][transform] Support Timestampdiff and Timestampadd function in cdc pipeline transform [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36647][transform] Support Timestampdiff and Timestampadd function in cdc pipeline transform [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36647][transform] Support Timestampdiff and Timestampadd function in cdc pipeline transform [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36647][transform] Support Timestampdiff and Timestampadd function in cdc pipeline transform [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37110) When the database and schema names of the regular expression are the same, the results of table selector filtering will be incorrect. Jira
• Re: [PR] [FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. [flink-cdc] via GitHub
• Re: [PR] [FLINK-36452][mysql] Replace ArrayList with TreeSet to speed up searching of FinishedSnapshotSplitInfo for specific chunkKey. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36452][mysql] Replace ArrayList with TreeSet to speed up searching of FinishedSnapshotSplitInfo for specific chunkKey. [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-29961) Make referencing custom image clearer for Docker Mingliang Liu (Jira)
• Re: [PR] [FLINK-29961][doc] Make referencing custom image clearer for Docker [flink] via GitHub
• [jira] [Commented] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates Mingliang Liu (Jira)
  • [jira] [Commented] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates Gabor Somogyi (Jira)
• [jira] [Commented] (FLINK-36932) Add resource-level metrics for different status/states to flink-kubernetes-operator Philippe Gref-Viau (Jira)
• [jira] [Updated] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates Gary Lam (Jira)
• [jira] [Created] (FLINK-37109) Increase state processor API performance when reading keyed rocksdb state Gary Lam (Jira)
• [jira] [Comment Edited] (FLINK-36716) Address vulnerabilities in Flink UI Alexander Fedulov (Jira)
• [jira] [Resolved] (FLINK-35512) ArtifactFetchManagerTest unit tests fail Alexander Fedulov (Jira)
• [jira] [Commented] (FLINK-35512) ArtifactFetchManagerTest unit tests fail Alexander Fedulov (Jira)
• [PR] [FLINK-XXX]: Add Python KafkaSource.set_deserializer API [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-XXX]: Add Python KafkaSource.set_deserializer API [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-36739] Update the NodeJS to v22.11.0 (LTS) [flink] via GitHub
  • Re: [PR] [FLINK-36739] Update the NodeJS to v22.11.0 (LTS) [flink] via GitHub
• [jira] [Resolved] (FLINK-35721) I found out that in the Flink SQL documentation it says that Double type cannot be converted to Boolean type, but in reality, it can. Alexander Fedulov (Jira)
• [jira] [Commented] (FLINK-35721) I found out that in the Flink SQL documentation it says that Double type cannot be converted to Boolean type, but in reality, it can. Alexander Fedulov (Jira)
• [PR] Fix docker compose configuration [flink-playgrounds] via GitHub
• [jira] [Commented] (FLINK-35397) Translate Controller Flow documentation into Chinese Caican Cai (Jira)
  • [jira] [Commented] (FLINK-35397) Translate Controller Flow documentation into Chinese wangyang377 (Jira)
• [jira] [Closed] (FLINK-36645) Gracefully handle null execution plan from autoscaler Gyula Fora (Jira)
• [PR] [FLINK-35512][tests] Do not depend on the `flink-clients` jar in `ArtifactFetchManagerTest` [flink] via GitHub
  • Re: [PR] [FLINK-35512][tests] Do not depend on the `flink-clients` jar in `ArtifactFetchManagerTest` [flink] via GitHub
  • Re: [PR] [FLINK-35512][tests] Do not depend on the `flink-clients` jar in `ArtifactFetchManagerTest` [flink] via GitHub
  • Re: [PR] [FLINK-35512][tests] Do not depend on the `flink-clients` jar in `ArtifactFetchManagerTest` [flink] via GitHub
• [jira] [Updated] (FLINK-37108) Source/Sink test suites test invalid recovery ASF GitHub Bot (Jira)
• [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [flink] via GitHub
  • Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [flink] via GitHub
  • Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [flink] via GitHub
  • [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [flink] via GitHub
  • Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [1.19] [flink] via GitHub
  • Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [1.19] [flink] via GitHub
  • Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [1.19] [flink] via GitHub
  • [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [flink] via GitHub
  • Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [1.20] [flink] via GitHub
  • Re: [PR] [FLINK-37108] Use-non terminal savepoint in source/sink suite [1.20] [flink] via GitHub
• Re: [PR] [FLINK-35512][flink-clients] Don't depend on the flink-clients jar actually existing. [flink] via GitHub
• [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
  • Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
  • Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
  • Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
  • Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
  • Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
  • Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
  • Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
  • Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
  • Re: [PR] [FLINK-36707][table] Add output strategy to SystemTypeInference [flink] via GitHub
• [jira] [Closed] (FLINK-36825) Introduce FastTop1Function in Rank with Async State API lincoln lee (Jira)
• [jira] [Created] (FLINK-37108) Source/Sink test suites test invalid recovery Arvid Heise (Jira)
• [jira] [Closed] (FLINK-36640) Provide an easy way to reset autoscaling Gyula Fora (Jira)
• Re: [PR] [BP-1.20][FLINK-35512][tests] Do not depend on the `flink-clients` jar in `ArtifactFetchManagerTest` [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-35512][tests] Do not depend on the `flink-clients` jar in `ArtifactFetchManagerTest` [flink] via GitHub
• Re: [PR] [BP-1.19][FLINK-35512][tests] Do not depend on the `flink-clients` jar in `ArtifactFetchManagerTest` [flink] via GitHub
  • Re: [PR] [BP-1.19][FLINK-35512][tests] Do not depend on the `flink-clients` jar in `ArtifactFetchManagerTest` [flink] via GitHub
  • Re: [PR] [BP-1.19][FLINK-35512][tests] Do not depend on the `flink-clients` jar in `ArtifactFetchManagerTest` [flink] via GitHub
• Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-37003) Implement async state version of Datastream Interval join Zakelly Lan (Jira)
• [jira] [Commented] (FLINK-37003) Implement async state version of Datastream Interval join Zakelly Lan (Jira)
• [jira] [Updated] (FLINK-35512) ArtifactFetchManagerTest unit tests fail Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-35512) ArtifactFetchManagerTest unit tests fail Ferenc Csaky (Jira)
• [jira] [Assigned] (FLINK-35512) ArtifactFetchManagerTest unit tests fail Ferenc Csaky (Jira)
• [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
  • Re: [PR] [FLINK-37017][Runtime] Allow buffer overdraft in async state processing [flink] via GitHub
• [jira] [Assigned] (FLINK-36858) [pipeline-kafka] JsonRowDataSerializationSchema compatibility bug Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-36858) [pipeline-kafka] JsonRowDataSerializationSchema compatibility bug Leonard Xu (Jira)
• [jira] [Updated] (FLINK-36858) [pipeline-kafka] JsonRowDataSerializationSchema compatibility bug Leonard Xu (Jira)
• [jira] [Updated] (FLINK-37107) Allow buffer overdraft in async state processing Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37107) Allow buffer overdraft in async state processing Zakelly Lan (Jira)
• [jira] [Commented] (FLINK-35412) Batch execution of async state request callback Zakelly Lan (Jira)
• [jira] [Closed] (FLINK-37086) State leaks for JDBC state store after job is stopped Gyula Fora (Jira)
• [PR] [FLINK-36499][table]Remove deprecated method `SupportsProjectionPushDown#applyProjection` [flink] via GitHub
  • Re: [PR] [FLINK-36499][table]Remove deprecated method `SupportsProjectionPushDown#applyProjection` [flink] via GitHub
  • Re: [PR] [FLINK-36499][table]Remove deprecated method `SupportsProjectionPushDown#applyProjection` [flink] via GitHub
  • Re: [PR] [FLINK-36499][table]Remove deprecated method `SupportsProjectionPushDown#applyProjection` [flink] via GitHub
  • Re: [PR] [FLINK-36499][table]Remove deprecated method `SupportsProjectionPushDown#applyProjection` [flink] via GitHub
• Re: [PR] [FLINK-36181] Use Java 17 by default [flink] via GitHub
  • Re: [PR] [FLINK-36181] Use Java 17 by default [flink] via GitHub
  • Re: [PR] [FLINK-36181] Use Java 17 by default [flink] via GitHub
• [jira] [Closed] (FLINK-36761) Add document about how to deploy script with SQL Client and SQL Gateway Shengkai Fang (Jira)
• Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-36964) Fix potential exception when SchemaChange in parallel with Paimon Sink. Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-36964) Fix potential exception when SchemaChange in parallel with Paimon Sink. Leonard Xu (Jira)
• [jira] [Commented] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` xuyang (Jira)
  • [jira] [Commented] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` Dawid Wysakowicz (Jira)
  • [jira] [Commented] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` xuyang (Jira)
• Re: [PR] [FLINK-30064] Apply changes for 1.20.0 [flink-connector-hive] via GitHub
  • Re: [PR] [FLINK-30064] Apply changes for 1.20.0 [flink-connector-hive] via GitHub
• [jira] [Resolved] (FLINK-36910) Support calling time-related dynamic functions with parenthesis Dawid Wysakowicz (Jira)
• [jira] [Resolved] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes Zhongqiang Gong (Jira)
• [jira] [Resolved] (FLINK-36865) Provide UNIX_TIMESTAMP series functions in YAML pipeline Leonard Xu (Jira)
• Re: [PR] [FLINK-36610] MySQL CDC supports parsing gh-ost / pt-osc generated schema changes [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails xuyang (Jira)
  • [jira] [Commented] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails xuyang (Jira)
• [jira] [Updated] (FLINK-36865) Provide UNIX_TIMESTAMP series functions in YAML pipeline Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes Zhongqiang Gong (Jira)
• Re: [PR] [FLINK-36863][autoscaler] Use the maximum parallelism in the past scale-down.interval window when scaling down [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-36863][autoscaler] Use the maximum parallelism in the past scale-down.interval window when scaling down [flink-kubernetes-operator] via GitHub

• Earlier messages
• Later messages