dev  

Messages by Thread

• [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)
• [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)
• [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)
• [jira] [Created] (FLINK-36423) Support RichMapPartitionFunction on KyedPartitionWindowedStream xuhuang (Jira)
• 2.0 podcast Rich Bowen
  • Re: 2.0 podcast Márton Balassi
• [jira] [Created] (FLINK-36422) Broken PyFlink jar download link for Kafka connector Aleksandr Pilipenko (Jira)
• Slack access Tom Cooper
  • Re: Slack access Shengbo
  • Slack Access Justin Ngai
• [jira] [Created] (FLINK-36421) Missing fsync in FsCheckpointStreamFactory Marc Aurel Fritz (Jira)
• [jira] [Created] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4 Danny Cranmer (Jira)
• Flink Kubernetes Operator 1.10.0 release planning Gyula Fóra
  • Re: Flink Kubernetes Operator 1.10.0 release planning Őrhidi Mátyás
  • Re: Flink Kubernetes Operator 1.10.0 release planning Őrhidi Mátyás
  • Re: Flink Kubernetes Operator 1.10.0 release planning Rui Fan
• [jira] [Created] (FLINK-36419) Consider scaling in case of no input records on a source operator with long running job Sergey Kononov (Jira)
• [jira] [Created] (FLINK-36418) Update Control Flow page with latest developments Gyula Fora (Jira)
• [jira] [Created] (FLINK-36417) STATE_TTL doesn't work with WatermarkAssigner Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36416) Enable splittable timers for temporal join, temporal sort and windowed aggregation in SQL/Table API Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-36415) ProjectWatermarkAssignerTransposeRule can generate extra casts which do not make sense Sergey Nuyanzin (Jira)
• [RESULT][VOTE] FLIP-477: Amazon SQS Source Connector Saurabh Singh
• [jira] [Created] (FLINK-36414) NoSuchMethodError while trying flink cdc Yang Hua Jie (Jira)
• [jira] [Created] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated. LvYanquan (Jira)
• [jira] [Created] (FLINK-36412) Retry strategies on Kinesis Sink Ed Berezitsky (Jira)
• Re: Question around Flink's AdaptiveBatchScheduler Venkatakrishnan Sowrirajan
• [jira] [Created] (FLINK-36411) Allow configuring job vertex throughput limits for auto scaler Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-36410) Improve Lineage Info Collection for flink app Zhenqiu Huang (Jira)
• [jira] [Created] (FLINK-36409) Publish some autoscaler metrics during stabilisation period Gyula Fora (Jira)
• [jira] [Created] (FLINK-36408) MySQL pipeline connector could not work with FLOAT type with precision yux (Jira)
• [jira] [Created] (FLINK-36407) SchemaRegistry doesn't shutdown its underlying ExecutorService upon closing Sergei Morozov (Jira)
• [jira] [Created] (FLINK-36406) MetadataApplier should be closed when the job stop Sergei Morozov (Jira)
• Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package Zakelly Lan
  • Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package Gabor Somogyi
• [jira] [Created] (FLINK-36405) Fix startup issues on kerberos clusters Chenyu Zheng (Jira)
• [jira] [Created] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail Lorenzo Nicora (Jira)
• [jira] [Created] (FLINK-36403) K8s native mode Use ConfigMap to get a better experience gaoyan (Jira)
• [jira] [Created] (FLINK-36402) Improper variable naming altenchen (Jira)
• [jira] [Created] (FLINK-36401) PR ci failed xuhuang (Jira)
• [jira] [Created] (FLINK-36400) 403 and 404 responses should be fatal Lorenzo Nicora (Jira)
• [jira] [Created] (FLINK-36399) cast result is incorrect Jacky Lau (Jira)
• [jira] [Created] (FLINK-36398) Provide tools for users to obtain Schema mapping JunboWang (Jira)
• Kafka connector releases Arvid Heise
  • Re: Kafka connector releases David Radley
  • Re: Kafka connector releases Arvid Heise
  • Re: Kafka connector releases Qingsheng Ren
  • Re: Kafka connector releases Leonard Xu
  • Re: Kafka connector releases Arvid Heise
  • Re: Kafka connector releases Danny Cranmer
  • Re: Kafka connector releases Arvid Heise
  • RE: Kafka connector releases David Radley
  • FW: RE: Kafka connector releases David Radley
  • Re: Kafka connector releases Yanquan Lv
  • Re: Kafka connector releases Arvid Heise
  • Re: Kafka connector releases Leonard Xu
  • Re: Kafka connector releases Arvid Heise
  • Re: Kafka connector releases Yanquan Lv
  • Re: Kafka connector releases Arvid Heise
• [jira] [Created] (FLINK-36397) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics. Zhongmin Qiao (Jira)
• Join Us for Flink Forward Asia 2024 in Shanghai (Nov 29-30) & Jakarta (Dec 5)! Xintong Song
• [jira] [Created] (FLINK-36396) Remove dependency flink-java in all flink-table-api-xxx module xuyang (Jira)
• [jira] [Created] (FLINK-36394) Configure Init Metaspace size by default JieTan (Jira)
• [jira] [Created] (FLINK-36393) Flink Operator uses out of date GitHub actions. Sam Barker (Jira)
• [jira] [Created] (FLINK-36392) Varying the Java version in the Operator CI has no effect Sam Barker (Jira)
• [jira] [Created] (FLINK-36391) Remove dependency flink-java in flink-table-runtime module xuyang (Jira)
• [jira] [Created] (FLINK-36390) Remove deprecate RichFunction#open(Configuration) Weijie Guo (Jira)
• [jira] [Created] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled Archit Goyal (Jira)
• [jira] [Created] (FLINK-36388) Truncate failure labels on web interface Panagiotis Garefalakis (Jira)
• [jira] [Created] (FLINK-36387) Remove dependency flink-java in flink-table-planner module xuyang (Jira)
• [jira] [Created] (FLINK-36386) Remove dependency flink-java in flink-table-planner-loader and flink-table-planner-loader-bundle module xuyang (Jira)
• [jira] [Created] (FLINK-36385) Remove dependency flink-java in flink-sql-gateway module xuyang (Jira)
• [jira] [Created] (FLINK-36384) Remove dependency flink-java in flink-sql-client module xuyang (Jira)
• [jira] [Created] (FLINK-36383) Remove dependency flink-java in flink-sql-jdbc-driver and flink-sql-jdbc-driver-bundle module xuyang (Jira)
• [jira] [Created] (FLINK-36382) Remove dependency flink-java in flink-table-test-utils module xuyang (Jira)
• [jira] [Created] (FLINK-36381) Remove skip tag in python module caused by deprecating legacy csv source xuyang (Jira)
• [jira] [Created] (FLINK-36380) Cannot determine simple type name "org" mumu (Jira)
• [jira] [Created] (FLINK-36379) Improve (Global)Committer with UC disabled Arvid Heise (Jira)
• [jira] [Created] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal Jacky Lau (Jira)
• [jira] [Created] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data Yang Li (Jira)
• [jira] [Created] (FLINK-36376) More friendly error or warn message for misconfigured statebackend with async state processing Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36375) Missing default value in AddColumnEvent linqigeng (Jira)
• [jira] [Created] (FLINK-36374) Bundle forst statebackend in flink-dist and provide shortcut to enable Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36373) Support distribute state requests in task thread Yanfei Lei (Jira)
• [jira] [Created] (FLINK-36372) Can not insert data to sink with reserved keywords column name Tan Nguyen (Jira)
• [jira] [Created] (FLINK-36371) Field BinaryStringData as keySelector would lead the same records hash shuffle into different tumble windows Eason Ye (Jira)
• [jira] [Created] (FLINK-36370) Flink 1.18 fails with Empty server certificate chain when High Availability and mTLS both enabled Aniruddh J (Jira)
• [jira] [Created] (FLINK-36369) Move deprecated user-visible classes in table modules to the legacy package to make it easier to delete them later xuyang (Jira)
• [SUMMARY] Flink 2.0 Sync 09/25/2024 Xintong Song
• [jira] [Created] (FLINK-36368) Fix subtask management in CommittableCollector Arvid Heise (Jira)
• [jira] [Created] (FLINK-36367) Use RexNormalize in EquivalentExprShuttle Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36366) Remove deprecate API in flink-core exclude connector and state part Weijie Guo (Jira)
• [jira] [Created] (FLINK-36365) The fetchsize parameter of flink-sql-connector-mysql-cdc-3.2.0 does not take effect zhanghuaibei (Jira)
• [jira] [Created] (FLINK-36364) Do not reuse serialized key in Forst map state and/or other namespaces Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36363) Remove references to scala-relate api in tests among table modules xuyang (Jira)
• [jira] [Created] (FLINK-36362) Remove dependency about `flink-java` in table module xuyang (Jira)
• [jira] [Created] (FLINK-36361) Do not use StringBuilder for EquivalentExprShuttle Sergey Nuyanzin (Jira)
• Re: [DISCUSS]: Flink code generation porting to Calcite James Duong
• Re: Request to make ContinuousFileReaderOperator public Darin Amos
• [KINDELY REMINDER] Flink 2.0 Release Sync 09/25/2024 Xintong Song
• [jira] [Created] (FLINK-36360) Prepare release process and Scripts for the preview release Xintong Song (Jira)
• [jira] [Created] (FLINK-36359) IT case for DDB Streams connector Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-36358) to_timestamp result is not correct when the string precision is long than date format Jacky Lau (Jira)
• [jira] [Created] (FLINK-36357) SDK retry for KDS connector Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-36356) HadoopRecoverableWriterTest.testRecoverWithState due to IOException Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36355) Remove deprecate API in flink-runtime related to api and runtime Weijie Guo (Jira)
• [jira] [Created] (FLINK-36354) Enable FORSTDB_BACKEND in async releated tests lincoln lee (Jira)
• [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Jim Hughes
  • 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

• Earlier messages
• Later messages