dev  

Messages by Thread

• [jira] [Created] (FLINK-40535) Standalone session clusters are redeployed instead of scaled in-place Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-40534) Memory tuning config overrides are computed before the ScalingExecutorPlugin chain and persisted unchanged when a plugin modifies the scaling decision Shubhankar Sunil Unhale (Jira)
• [DISCUSS] Flink Kubernetes Operator support for the Flink 2.3 application layer James Kan via dev
• [jira] [Created] (FLINK-40531) K8s Operator Autoscaler Parallelism overrides serialized in standard-YAML format break the deployed job Juliusz Nadberezny (Jira)
• [jira] [Created] (FLINK-40533) Upgrade Flink CDC dependency to Flink 2.3 Xiqian Yu (Jira)
• [jira] [Created] (FLINK-40532) [DOC] Remove experimental warning from scan.parse.online.schema.changes.enabled VISHAL B (Jira)
• [jira] [Created] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response Archit Goyal (Jira)
• [jira] [Created] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Deepyaman Datta (Jira)
• [RESULT][VOTE] Release flink-shaded 22.0, release candidate #1 Sergey Nuyanzin
• [jira] [Created] (FLINK-40528) Codegen should be tolerate to partial deletes Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40527) Update flink-shaded to 22.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40515) Extend BinaryVariant to support UUID (Code 20) Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40523) NetworkActionsLogger.tracePersist unconditionally builds the buffer debug string Rui Fan (Jira)
• [jira] [Created] (FLINK-40526) Checkpointing-during-recovery crashes a recovering RemoteInputChannel when announcing a stashed timeoutable-aligned barrier Rui Fan (Jira)
• [jira] [Created] (FLINK-40525) RecoveredInputChannel.finishReadRecoveredState holds receivedBuffers across notifyChannelNonEmpty, risking an ABBA deadlock Rui Fan (Jira)
• [jira] [Created] (FLINK-40524) LocalInputChannel.getNextBuffer takes the recoveredBuffers monitor on every buffer even when the channel never needed recovery Rui Fan (Jira)
• [jira] [Created] (FLINK-40522) Deduplicate the RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel Rui Fan (Jira)
• [jira] [Created] (FLINK-40521) Potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery Rui Fan (Jira)
• [jira] [Created] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain Rui Fan (Jira)
• [jira] [Created] (FLINK-40519) Checkpoint-during-recovery barrier is not delivered to a credited remote reader while the subpartition is blocked Rui Fan (Jira)
• [jira] [Created] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled Rui Fan (Jira)
• [jira] [Created] (FLINK-40517) Checkpointing-during-recovery drops cross-channel watermark / watermark-status aggregation on fan-in rescale Rui Fan (Jira)
• [jira] [Created] (FLINK-40516) Needed to support network policy in Jobmanager and Task Manager Taranpreet Kaur (Jira)
• [jira] [Created] (FLINK-40514) [Docs] Doris pipeline connector option table does not match implementation Rango (Jira)
• [jira] [Created] (FLINK-40513) Validate forward routing and optimize Fluss sink writer with bucket affinity Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40512) PostgreSQL source emits relation schema events for tables outside the configured table list Hongshun Wang (Jira)
• [jira] [Created] (FLINK-40511) Track and speed up slow integration tests (KafkaSinkITCase and friends) Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• [ANNOUNCE] New Apache Flink Committer: Samrat Deb Robert Metzger
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Roman Khachatryan
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Poorvank Bhatia
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Ahmed Hamdy
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Weiqing Yang
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Peter Huang
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Sergey Nuyanzin
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Santwana Verma via dev
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Aleksandr Iushmanov
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Swapnal Varma
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Efrat Levitan
  • Re: [ANNOUNCE] New Apache Flink Committer: Samrat Deb Samrat Deb
• [jira] [Created] (FLINK-40509) Move operator defaults out of the Helm chart so config.yaml carries only user-supplied content Gerk Elznik (Jira)
• [jira] [Created] (FLINK-40508) Support DB2 pipeline connector suntectec (Jira)
• [jira] [Created] (FLINK-40507) upgrade paimon to 2.0.0 peiyu (Jira)
• [jira] [Created] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40503) WatermarksWithIdleness effective timeout is idleTimeout plus up to 2× the periodic probe interval, contradicting the withIdleness documentation Martijn Visser (Jira)
• [jira] [Created] (FLINK-40505) SourceCoordinator never removes failed or reset subtasks from watermark-alignment aggregation Martijn Visser (Jira)
• [jira] [Created] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Martijn Visser (Jira)
• [jira] [Created] (FLINK-40501) WatermarkStatus overtakes queued watermarks in AsyncWaitOperator, causing watermark loss downstream Martijn Visser (Jira)
• [jira] [Created] (FLINK-40502) scan.watermark.idle-timeout is silently ignored for connectors without watermark pushdown; SOURCE_WATERMARK() ignores idle-timeout entirely Martijn Visser (Jira)
• [jira] [Created] (FLINK-40500) DataStream V2 idleness detection is not backpressure-aware - FLIP-471 was never applied to ExtractEventTimeProcessFunction Martijn Visser (Jira)
• [jira] [Created] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE Martijn Visser (Jira)
• [jira] [Created] (FLINK-40498) Adjust tests to call SNAPSHOT without TABLE keyword Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE ignores query column position, silently producing a schema whose column order disagrees with the query (ALTER ... AS is correct) Arvid Heise (Jira)
• [jira] [Created] (FLINK-40495) Limit concurrent shared-state disposal to prevent JobManager I/O starvation Tianji Li (Jira)
• [jira] [Created] (FLINK-40485) FLIP 604: Complete VARIANT primitive coverage with UUID and timestamps Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40486) Introduce the UUID logical type Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40487) CAST between UUID and STRING / BINARY(16) Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40494) Document UUID and extended VARIANT type Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40493) VARIANT CAST for UUID (code 20) Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40492) VARIANT CAST for TIME and nanosecond timestamps (17-19) Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40491) Decode/accessor support in BinaryVariant for codes 17-20 Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40490) Runtime serialization and codegen for UUID Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40489) Add UUID_V4() & UUID_V7() functions Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40488) Comparison and ordering for UUID Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler Rui Fan (Jira)
• [jira] [Created] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER() Timo Theusner (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #3 Gyula Fóra
• [jira] [Created] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished Rui Fan (Jira)
• [jira] [Created] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past Arvid Heise (Jira)
• [DISCUSS] Planning Flink 2.4 Mika Naylor
  • Re: [DISCUSS] Planning Flink 2.4 Yuepeng Pan
  • Re: [DISCUSS] Planning Flink 2.4 Chanhae Oh
  • Re: [DISCUSS] Planning Flink 2.4 Rui Fan
  • Re: [DISCUSS] Planning Flink 2.4 Mika Naylor
  • Re: [DISCUSS] Planning Flink 2.4 주수민
  • Re: [DISCUSS] Planning Flink 2.4 Mika Naylor
  • Re: [DISCUSS] Planning Flink 2.4 Rui Fan
• [jira] [Created] (FLINK-40480) [doc] CDC Yaml supports fluss source. Hongshun Wang (Jira)
• [RESULT][VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
• [jira] [Created] (FLINK-40479) FROM_CHANGELOG accepts error_handling but still fails the job on unmapped op codes Rango (Jira)
• [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Xintong Song
  • Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Zhe Wang
  • Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Ramin Gharib
  • Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Gustavo de Morais
  • Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Efrat Levitan
  • Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Jark Wu
  • Re:Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Xuyang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Sergey Nuyanzin
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Yuepeng Pan
  • RE: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang David Radley
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Weiqing Yang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Peter Huang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Hao Li
  • RE: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang wenjin
  • Re: [ANNOUNCE] New Apache Flink Committer - Weiqing Yang Samrat Deb
• [DISCUSS] Cluster overhead/waste in large shared Flink clusters Yanis Djeridi via dev
  • Re: [DISCUSS] Cluster overhead/waste in large shared Flink clusters Dennis-Mircea Ciupitu
  • RE: Re: [DISCUSS] Cluster overhead/waste in large shared Flink clusters Yanis Djeridi via dev
• [jira] [Created] (FLINK-40478)  HistoryServer  should log its effective configuration at startup Archit Goyal (Jira)
• [jira] [Created] (FLINK-40477) Partial deletes fail sink NOT NULL enforcement Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40476) Clarify that the Changelog state backend requires CLAIM restore mode (NO_CLAIM unsupported) Santwana Verma (Jira)
• [jira] [Created] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
• [VOTE] FLIP-595: Differentiate monotonic and non-monotonic counters in Flink metrics Efrat Levitan
  • Re: [VOTE] FLIP-595: Differentiate monotonic and non-monotonic counters in Flink metrics Rui Fan
• [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions Mika Naylor
  • Re: [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions Zander Matheson
  • Re: [DISCUSS] FLIP-609: Type Inference for Python User Defined Functions Timo Theusner via dev
• [jira] [Created] (FLINK-40474) Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-40473) YARN application mode fails to locate flink-cdc-dist jar when the jar name carries a Flink version suffix XiaodongHuan (Jira)
• [jira] [Created] (FLINK-40472) Add Arrow-native vectorized UDF support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40471) Add per-UDF concurrency and batch size support Liu Liu (Jira)
• [jira] [Created] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails hyeon kim (Jira)
• [jira] [Created] (FLINK-40468) Partial deletes cause NPE if value type is declared as NOT NULL Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40469) DynamicKafkaSource can lose splits when checkpointing during recovery reassignment Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy Josh Keegan (Jira)
• [jira] [Created] (FLINK-40466) Refactor defining table arguments in PTF Test Harness builder for more complex table arguments Mika Naylor (Jira)
• [jira] [Created] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator Mate Czagany (Jira)
• [jira] [Created] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014 Florian Vazelle (Jira)
• [jira] [Created] (FLINK-40461) Add config option for labels on operator generated events Jira
• [jira] [Created] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support Chris Johnson (Jira)
• [jira] [Created] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found) Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40460) Upgrade archive-producing Maven plugins to reproducible-capable versions Martijn Visser (Jira)
• [VOTE] Release flink-shaded 22.0, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Mate Czagany
  • Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Leonard Xu
  • Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Yuepeng Pan
  • Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Samrat Deb
  • Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Rui Fan
  • Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Martijn Visser
  • Re: [VOTE] Release flink-shaded 22.0, release candidate #1 Sergey Nuyanzin
• [jira] [Created] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
• [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
  • Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Timo Walther
  • Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Gustavo de Morais
  • Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Sergey Nuyanzin
  • Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps David Anderson
  • Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Mate Czagany
  • Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Jingsong Li
  • Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Moritz Manner
  • Re: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Leonard Xu
  • RE: [VOTE] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Moritz Manner
• [jira] [Created] (FLINK-40458) Shade commons-lang and commons-lang3 in flink-sql-connector-hive liting liu (Jira)
• [DISCUSS] FLIP-XXX : Remote Artifact Fetch for Session-Mode Job Submission Dale Lane
• [jira] [Created] (FLINK-40457) Bump pekko to 1.7.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40454) java.lang.NoSuchMethodError: '...Configuration.getInteger(..)' in FlinkConfigManager Vladislav Keda (Jira)
• [jira] [Created] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Weiqing Yang
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Mate Czagany
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Samrat Deb
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Dennis-Mircea Ciupitu
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #2 Gyula Fóra
• [jira] [Created] (FLINK-40455) Decoupling Autotuning from the Autoscaling logic Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter YangyangHu (Jira)
• [jira] [Created] (FLINK-40452) Cap exception fetching by size, not line count Robert Metzger (Jira)
• [jira] [Created] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40446) UnalignedCheckpointRescaleWithMixedExchangesITCase is unstable: @TempDir cleanup races with post-cancel async checkpoint Rui Fan (Jira)
• [jira] [Created] (FLINK-40450) Planner tests miss direct flink-table-code-splitter test dependency Shekhar Prasad Rajak (Jira)
• [jira] [Created] (FLINK-40449) Reject non-temporal streaming sort during planning instead of at job submission Martijn Visser (Jira)
• [jira] [Created] (FLINK-40448) Pin resolved address during operator artifact fetch to prevent DNS rebinding Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40447) Keyless upsert sink can silently drop retract semantics when upsert-key metadata is empty or mixed Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40445) Autoscaler: integration test for Kafka/Pulsar source partition-metric detection Purushottam Sinha (Jira)
• [DISCUSS] Splitting FLINK-37357 / PR #26201 into smaller migration tasks Hirson Zhang
• [jira] [Created] (FLINK-40444) OBJECT_UPDATE returns incorrect results for some structured types sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40443) Harden autoscaler metrics name parsing against complex regex Robert Metzger (Jira)
• [jira] [Created] (FLINK-40442) State Processor API re-derives a key's key-group from hashCode() instead of reusing the one it read the key from — breaks reading old state after any hashCode() change Grzegorz Liter (Jira)
• [jira] [Created] (FLINK-40441) Shade com.zaxxer (HikariCP) for pg pipeline connector to avoid cross-connector conflicts Zhuojun Jiang (Jira)
• [flink-connector-kafka] CI rerun and merge permissions for PR #267 Hi, jigar bhati
• [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
  • Re: [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Robert Metzger
  • Re: [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Zhe Wang
  • Re: [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Mate Czagany
  • Re: [DISCUSS] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
• [jira] [Created] (FLINK-40440) Add LLM prediction support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40439) Add model provider management to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40438) Add DataFrame inspection and rich display APIs Liu Liu (Jira)
• [jira] [Created] (FLINK-40437) Add iteration and bounded retrieval to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40435) Add explode support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40436) Add UDAF support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40434) Add flat_map support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40432) Parallel snapshot/CDC split by long handle space is skewed for AUTO_INCREMENT PKs and can OOM lifulong (Jira)
• [jira] [Created] (FLINK-40433) Add map and map_batches support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40431) Add UDF support to PyFlink DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40429) Add StatementSet support for multi-sink DataFrame writes Liu Liu (Jira)
• [jira] [Created] (FLINK-40430) Add configuration support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40428) Remove Calcite's LogicalSnapshot Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40427) Add catalog management and catalog table I/O to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40426) Add Parquet and JSON filesystem I/O APIs to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40424) Add windowing TVF support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40425) Add OVER window aggregation support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40423) Add Top-N support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40422) Add slicing APIs to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40421) Support sorting in DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40420) Add set operations to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40419) Add regular join support to DataFrame API Liu Liu (Jira)
• [jira] [Created] (FLINK-40418) Support attribute-based column access on DataFrame Liu Liu (Jira)
• [jira] [Created] (FLINK-40417) Add remaining basic functionality to DataFrame API Liu Liu (Jira)

• Earlier messages