dev  

Messages by Thread

• • Re: [DISCUSS] Elasticsearch v3.1 release Danny Cranmer
  • Re: [DISCUSS] Elasticsearch v3.1 release Ahmed Hamdy
  • Re: [DISCUSS] Elasticsearch v3.1 release Yanquan Lv
  • Re: [DISCUSS] Elasticsearch v3.1 release Ahmed Hamdy
  • Re: [DISCUSS] Elasticsearch v3.1 release weijie guo
  • Re: [DISCUSS] Elasticsearch v3.1 release weijie guo
• [jira] [Created] (FLINK-36527) Introduce a parameter to support the autoscaler to adopt a more aggressive strategy when Source or upstream shuffle is keyBy yuanfenghu (Jira)
• [jira] [Created] (FLINK-36526) Optimize the overhead of writing with direct buffer in ForSt Zakelly Lan (Jira)
• Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
  • RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD David Radley
  • RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Ferenc Csaky
  • Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
  • Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
  • RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD David Radley
• [jira] [Created] (FLINK-36525) Support for AI Model Integration for Data Processing wuzexian (Jira)
• [jira] [Created] (FLINK-36524) upgrade paimon 0.9.0 melin (Jira)
• FLIP-202: Flink Clickhouse Connector to Flink Community ConradJam
• Fwd: Custom Windowing Strategies in SQL Justin Ngai
  • Re: Fwd: Custom Windowing Strategies in SQL Timo Walther
• [jira] [Created] (FLINK-36523) DDB Streams connector treating LATEST as TRIM_HORIZON for some cases Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36522) Bump mysql-connector-j version Kartik Goyal (Jira)
• [jira] [Created] (FLINK-36521) Introduce TtlAwareSerializer to resolve the compatibility check between ttlSerializer and original serializer xiangyu feng (Jira)
• [VOTE] Release 2.0-preview1, release candidate #1 Xintong Song
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Junrui Lee
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 weijie guo
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Lincoln Lee
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Zhu Zhu
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Yuan Mei
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Rui Fan
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Yunfeng Zhou
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Jingsong Li
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Jark Wu
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Zakelly Lan
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Xingbo Huang
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Xintong Song
  • Re: [VOTE] Release 2.0-preview1, release candidate #1 Yanquan Lv
• [jira] [Created] (FLINK-36520) Flink CDC doesn't support MySQL > 8.0 Jira
• [jira] [Created] (FLINK-36519) Typo in PartitionKeyGenerator java doc Jorick Caberio (Jira)
• [jira] [Created] (FLINK-36518) Paimon Sink support per-table property configuration JunboWang (Jira)
• [jira] [Created] (FLINK-36517) Duplicate commit the same datafile in Paimon Sink JunboWang (Jira)
• [jira] [Created] (FLINK-36516) Migrate deprecated SinkV2 API to new API introduced in FLIP-372 LvYanquan (Jira)
• [jira] [Created] (FLINK-36515) Adds high-precision TIME type support in YAML pipeline yux (Jira)
• [jira] [Created] (FLINK-36514) Unable to override include/exclude schema types in lenient mode yux (Jira)
• [jira] [Created] (FLINK-36513) A lot of CI failures are caused by Install cert-manager Rui Fan (Jira)
• Re: Flink Kubernetes Operator 1.10.0 release planning Őrhidi Mátyás
  • Re: Flink Kubernetes Operator 1.10.0 release planning Rui Fan
• [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Arvid Heise
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Yanquan Lv
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Ahmed Hamdy
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Arvid Heise
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Danny Cranmer
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Ahmed Hamdy
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Arvid Heise
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Arvid Heise
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Matthias Pohl
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Rui Fan
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 Arvid Heise
• [jira] [Created] (FLINK-36512) Make rescale trigger based on failed checkpoints depend on the cause Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36511) FlinkSecurityManager#checkExit StackOverFlow if haltOnSystemExit is enabled Chesnay Schepler (Jira)
• [jira] [Created] (FLINK-36510) Upgrade Pekko from 1.0.1 to 1.1.2 Grace Grimwood (Jira)
• [jira] [Created] (FLINK-36509) Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink. LvYanquan (Jira)
• [jira] [Created] (FLINK-36508) Remove all deprecated methods in `SymbolType ` xuyang (Jira)
• [jira] [Created] (FLINK-36506) Remove all deprecated methods in `ColumnStats` xuyang (Jira)
• [jira] [Created] (FLINK-36507) Remove deprecated method `LogicalTypeParser#parse` xuyang (Jira)
• [jira] [Created] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction` xuyang (Jira)
• [jira] [Created] (FLINK-36503) Remove deprecated method `FunctionDefinitionFactory#createFunctionDefinition` xuyang (Jira)
• [jira] [Created] (FLINK-36504) Remove all deprecated methods `ModuleFactory` xuyang (Jira)
• [jira] [Created] (FLINK-36501) Remove all deprecated methods in `CatalogFactory` xuyang (Jira)
• [jira] [Created] (FLINK-36502) Remove all deprecated methods in `FactoryUtil` xuyang (Jira)
• [jira] [Created] (FLINK-36500) Remove all deprecated methods in `CallExpression` xuyang (Jira)
• [jira] [Created] (FLINK-36499) Remove deprecated method `SupportsProjectionPushDown#applyProjection` xuyang (Jira)
• [jira] [Created] (FLINK-36497) Remove all deprecated methods in `CatalogTable` xuyang (Jira)
• [jira] [Created] (FLINK-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema` xuyang (Jira)
• [jira] [Created] (FLINK-36496) Remove deprecated method `CatalogFunction#isGeneric ` xuyang (Jira)
• [jira] [Created] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema` xuyang (Jira)
• [jira] [Created] (FLINK-36494) Remove deprecated methods `Catalog#getTableFactory` and `Catalog#supportsManagedTable` xuyang (Jira)
• [jira] [Created] (FLINK-36493) Remove all deprecated methods in `MapView` xuyang (Jira)
• [jira] [Created] (FLINK-36492) Remove all deprecated methods in `ListView` xuyang (Jira)
• [jira] [Created] (FLINK-36489) Remove deprecated method `StreamTableEnvironment#toRetractStream` xuyang (Jira)
• [jira] [Created] (FLINK-36491) Remove deprecated method `DataStreamSinkProvider#consumeDataStream` xuyang (Jira)
• [jira] [Created] (FLINK-36490) Remove deprecated method `DataStreamScanProvider#produceDataStream` xuyang (Jira)
• [jira] [Created] (FLINK-36486) Remove deprecated method `StreamTableEnvironment#registerDataStream` xuyang (Jira)
• [jira] [Created] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream` xuyang (Jira)
• [jira] [Created] (FLINK-36485) Remove deprecated method `StreamTableEnvironment#fromDataStream` xuyang (Jira)
• [jira] [Created] (FLINK-36487) Remove deprecated method `StreamTableEnvironment#createTemporaryView` xuyang (Jira)
• [jira] [Created] (FLINK-36484) Remove deprecated method `StreamTableEnvironment#registerFunction` xuyang (Jira)
• [jira] [Created] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` xuyang (Jira)
• [jira] [Created] (FLINK-36483) Remove deprecated method `TableResult#getTableSchema` xuyang (Jira)
• [jira] [Created] (FLINK-36481) Remove deprecated method `TableDescriptor#forManaged` xuyang (Jira)
• [jira] [Created] (FLINK-36480) Remove all deprecated methods in `TableConfig` xuyang (Jira)
• [jira] [Created] (FLINK-36479) Remove deprecated methods `Table#getSchema` and `Table#as` xuyang (Jira)
• [jira] [Created] (FLINK-36478) Remove deprecated methods `EnvironmentSettings#fromConfiguration` and `EnvironmentSettings#toConfiguration` xuyang (Jira)
• [jira] [Created] (FLINK-36477) Remove deprecated method `BaseExpressions#cast` in table-api-java xuyang (Jira)
• [jira] [Created] (FLINK-36476) Remove all deprecated methods under public APIs in table modules xuyang (Jira)
  • Re: [jira] [Created] (FLINK-36476) Remove all deprecated methods under public APIs in table modules Shiwei Wang
• [jira] [Created] (FLINK-36475) YAML Transform supports case-insensitive column names conversion yux (Jira)
• [jira] [Created] (FLINK-36474) YAML Table-merging route should accept more type widening cases yux (Jira)
• [jira] [Created] (FLINK-36473) Operator metrics tests fail intermittently Sam Barker (Jira)
• [jira] [Created] (FLINK-36472) Correlates with UDTF don't handle right-side conditions or projections Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-36471) Flink Operator uses out of date Docker actions. Sam Barker (Jira)
• [jira] [Created] (FLINK-36470) Bump checkstyle to 10+ Sergey Nuyanzin (Jira)
• Resource limits for the k8s Maksym Serhieiev
  • Re: Resource limits for the k8s Mate Czagany
  • Re: Resource limits for the k8s Maksym Serhieiev
• [jira] [Created] (FLINK-36469) Bump commons-io from 2.11.0 to 2.17.0 Siddharth R (Jira)
• [jira] [Created] (FLINK-36468) Use Flink Precondition utils instead of Parquet Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-36467) Bump google-java-format and spotless Mate Czagany (Jira)
• [jira] [Created] (FLINK-36466) Change default value of execution.runtime-mode from STREAMING to AUTOMATIC Wenjun Ruan (Jira)
• [jira] [Created] (FLINK-36465) Bump okhttp from 3.14.9 to 4.12.0 Siddharth R (Jira)
• [jira] [Created] (FLINK-36464) Local artifact fetcher should not require base directory Fabian Paul (Jira)
• [jira] [Created] (FLINK-36463) Disable some debezium options which do not take effect Xiao Huang (Jira)
• [jira] [Created] (FLINK-36462) Revert "remove per-job" xuhuang (Jira)
• [jira] [Created] (FLINK-36461) YAML job failed to schema evolve with unmatched transform tables yux (Jira)
• [jira] [Created] (FLINK-36460) Refactor Kubernetes Operator Edge to Edge test setup Sam Barker (Jira)
• [jira] [Created] (FLINK-36459) Add document to guide user to configure debezium properties LvYanquan (Jira)
• [jira] [Created] (FLINK-36458) Use original 'OceanBaseCEContainer' of testcontainers in testing He Wang (Jira)
• [jira] [Created] (FLINK-36457) Python DataStream API: calling add_jars or add_classpaths results in corrupted execution config Aleksandr Pilipenko (Jira)
• Re: [DISCUSS] FLIP-XXX: Introduce CLI API compatibility guarantees Mate Czagany
• [jira] [Created] (FLINK-36456) Improve Security in DatadogHttpReporterFactory by providing ENV alternative to retrieve API key Raul Garcia (Jira)
• Consequences of removing per-job mode in Flink 2.0 Ferenc Csaky
  • Re: Consequences of removing per-job mode in Flink 2.0 weijie guo
  • Re: Consequences of removing per-job mode in Flink 2.0 Shengkai Fang
  • Re: Consequences of removing per-job mode in Flink 2.0 Ferenc Csaky
  • Re: Consequences of removing per-job mode in Flink 2.0 Shengkai Fang
  • Re: Consequences of removing per-job mode in Flink 2.0 weijie guo
  • Re: Consequences of removing per-job mode in Flink 2.0 Ferenc Csaky
• [jira] [Created] (FLINK-36455) Sink should commit everything on notifyCheckpointCompleted Arvid Heise (Jira)
• [jira] [Created] (FLINK-36454) FlinkContainer always overwrites default config Arvid Heise (Jira)
• [jira] [Created] (FLINK-36453) Backport DBZ-6502 patch to fix Oracle 23.x JDBC driver compatbility yux (Jira)
• [jira] [Created] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading LvYanquan (Jira)
• [jira] [Created] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals xiechenling (Jira)
• [jira] [Created] (FLINK-36450) Exclude log4j from curator-test Siddharth R (Jira)
• [jira] [Created] (FLINK-36449) Bump apache-rat-plugin from 0.12 to 0.16.1 Siddharth R (Jira)
• [jira] [Created] (FLINK-36448) Compilation fails in IntelliJ Kumar Mallikarjuna (Jira)
• [SUMMARY] Flink 2.0 Release Sync 10/09/2024 Xintong Song
• [jira] [Created] (FLINK-36447) Add .java-version(generated by jenv) to git igonre Weijie Guo (Jira)
• [jira] [Created] (FLINK-36446) Refactor Job Submission Process to Use ExecutionPlan Instead of JobGraph Junrui Li (Jira)
• [jira] [Created] (FLINK-36445) Introducing an ExecutionPlan interface Junrui Li (Jira)
• [jira] [Created] (FLINK-36444) unstable test case SimpleRecoveryITCaseBase#testFailedRunThenSuccessfulRun xuhuang (Jira)
• Join to slack community Fabrizzio Chávez Tejada
• [DISCUSS] FLIP-478: Introduce Config Option Scope Junrui Lee
  • Re: [DISCUSS] FLIP-478: Introduce Config Option Scope Zhu Zhu
  • Re: [DISCUSS] FLIP-478: Introduce Config Option Scope Yanquan Lv
  • Re: [DISCUSS] FLIP-478: Introduce Config Option Scope Rui Fan
  • Re: [DISCUSS] FLIP-478: Introduce Config Option Scope Junrui Lee
  • Re: [DISCUSS] FLIP-478: Introduce Config Option Scope Rui Fan
  • Re: [DISCUSS] FLIP-478: Introduce Config Option Scope Junrui Lee
• [jira] [Created] (FLINK-36443) Flaky Test: assertEquals in PushPartitionIntoTableSourceScanRuleTest.testWithUdf William Lin (Jira)
• [jira] [Created] (FLINK-36442) Add option to handle insert-only changeless in Postgres CDC connector Nandor Soma Abonyi (Jira)
• [jira] [Created] (FLINK-36441) Resource leaks in Kafka Tests Arvid Heise (Jira)
• [KINDELY REMINDER] Flink 2.0 Release Sync 10/09/2024 Xintong Song
• [jira] [Created] (FLINK-36440) Bump log4j from 2.17.1 to 2.23.1 Siddharth R (Jira)
• [jira] [Created] (FLINK-36439) Documentation for Disaggregated State Storage and Management Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36438) Bump assertj from 3.23.1 to 3.26.3 Siddharth R (Jira)
• [jira] [Created] (FLINK-36437) Hive connector failed to compile with JDK 11 Xuannan Su (Jira)
• [jira] [Created] (FLINK-36436) Remove legacy APIs with `legacy` package in table modules xuyang (Jira)
• [jira] [Created] (FLINK-36435) Shaded Hadoop S3A with credentials provider end-to-end test failed Weijie Guo (Jira)
• [jira] [Created] (FLINK-36433) non-keyed fullWindowPartition#reduce may throw NPE xuhuang (Jira)
• [jira] [Created] (FLINK-36434) Revise threading model of (KafkaPartition)SplitReader Arvid Heise (Jira)
• [VOTE] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package Zakelly Lan
  • Re: [VOTE] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package Gabor Somogyi
  • Re: [VOTE] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package Yuan Mei
  • Re: [VOTE] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package Rui Fan
  • Re: [VOTE] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package Zakelly Lan
• [jira] [Created] (FLINK-36432) FLIP-438: Amazon SQS Source Connector Saurabh (Jira)
• Re: 2.0 podcast Márton Balassi
• [jira] [Created] (FLINK-36431) Enhancing Flink History Server File Storage and Retrieval with RocksDB Xiaowen Sun (Jira)
• [jira] [Created] (FLINK-36429) Enhancing Flink History Server File Storage and Retrieval with RocksDB Xiaowen Sun (Jira)
• [jira] [Created] (FLINK-36430) Enhancing Flink History Server File Storage and Retrieval with RocksDB Xiaowen Sun (Jira)
• Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Jim Hughes
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Dawid Wysakowicz
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Konstantin Knauf
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Jim Hughes
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re:Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Xuyang
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) David Anderson
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) David Anderson
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Shengkai Fang
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Fabian Hüske
  • RE: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) David Radley
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Fabian Hüske
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
• [jira] [Created] (FLINK-36428) DynamoDb Table API Sink fails when null value in the RowData maoxingda (Jira)
• [jira] [Created] (FLINK-36427) Additional Integration Test cases for KDS source Elphas Toringepi (Jira)
• [jira] [Created] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots RocMarshal (Jira)
• [jira] [Created] (FLINK-36425) Use JobStatus enum for status.job.state Gyula Fora (Jira)
• Flink Slack invite Ralph Bartley
  • Re: Flink Slack invite Gabor Somogyi
  • Re: Flink Slack invite Ralph Bartley
  • Re: Flink Slack invite Gabor Somogyi
• [jira] [Created] (FLINK-36424) Update deprecated YARN RM/NM callback handlers Ferenc Csaky (Jira)

• Later messages