Messages by Thread
-
[jira] [Updated] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37952] Skip compressing built python wheels by hand in Nightly workflow [flink]
via GitHub
-
Re: [PR] [FLINK-20628] RabbitMQ Connector using FLIP-27 Source API [flink-connector-rabbitmq]
via GitHub
-
[jira] [Created] (FLINK-37952) Do not tar python wheel packages in GH Nightly workflow
Ferenc Csaky (Jira)
-
[PR] [FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend [flink]
via GitHub
-
[jira] [Created] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2
Xuannan Su (Jira)
-
[jira] [Commented] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule
Gustavo de Morais (Jira)
-
[I] [Feature] Support DataStream / Table as input / output of Flink Agents in Python [flink-agents]
via GitHub
-
[I] [Feature] Introduce Workflow, Event, Action & Callable in the Python Workflow Plan [flink-agents]
via GitHub
-
[I] [Feature] Support converting between Java & Python Workflow Plans [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-37950) MongoDB connector should support ordered option
Jacob Jona Fahlenkamp (Jira)
-
[I] [Feature][runtime] Deploy workflow as a Flink job into a Flink cluster [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-37950) MongoDB connector should support ordered option
Jacob Jona Fahlenkamp (Jira)
-
[jira] [Commented] (FLINK-37894) Introduce Index in CatalogTable
Xuyang Zhong (Jira)
-
[I] [Feature] Introduce Python API for Workflow, Event and Action [flink-agents]
via GitHub
-
[I] [Feature] Introduce Workflow, Event, Action & Callable in the Java Workflow Plan [flink-agents]
via GitHub
-
[I] [Tech Debt] Document how-to-contribute in README [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule
Gustavo de Morais (Jira)
-
[jira] [Closed] (FLINK-37894) Introduce Index in CatalogTable
Xuyang Zhong (Jira)
-
[I] [Feature] Introduce API for Workflow, Event and Action [flink-agents]
via GitHub
-
[I] [Feature] Support DataStream / Table as input / output of Flink Agents [flink-agents]
via GitHub
-
[jira] [Assigned] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline
Zakelly Lan (Jira)
-
[jira] [Closed] (FLINK-37536) Improve SQL gateway documentation
Shengkai Fang (Jira)
-
[jira] [Updated] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline
dalongliu (Jira)
-
[I] [Feature][runtime] Implement a Flink operator that executes the given workflow plan [flink-agents]
via GitHub
-
[I] [Feature] Introduce Java API for Workflow, Event and Action [flink-agents]
via GitHub
-
[I] [Feature] Support DataStream / Table as input / output of Flink Agents in Java [flink-agents]
via GitHub
-
[jira] [Resolved] (FLINK-37933) Move TransformationScan/SinkProvider out of planner
Arvid Heise (Jira)
-
[I] [Feature] Introduce the fundamental concepts: Workflow, Event, Action & Callable [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-37536) Improve SQL gateway documentation
Shengkai Fang (Jira)
-
[jira] [Commented] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join
Xuyang Zhong (Jira)
-
Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents]
via GitHub
-
[jira] [Comment Edited] (FLINK-36303) PostgreSQL timestamp precision 0 not supported
Rui Fan (Jira)
-
[jira] [Created] (FLINK-37949) FlinkKinesisConsumer on EFO mode runs into Netty deadlock on client close during stop-with-savepoint
Keith Lee (Jira)
-
[jira] [Created] (FLINK-37947) Add sql hint to enable this optimization
Shuai Xu (Jira)
-
[PR] [FLINK-37945][table] Add StreamPhysicalMultiJoin to inference program [flink]
via GitHub
-
[jira] [Updated] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram
ASF GitHub Bot (Jira)
-
[jira] [Commented] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline
dalongliu (Jira)
-
[PR] [FLINK-12130][clients] : Allow dynamic loading of kerberos keytab from client end [flink]
via GitHub
-
[PR] [FLINK-37799][model][docs] Add document for OpenAI Model Function [flink]
via GitHub
-
[jira] [Updated] (FLINK-37770) FLIP-518: Introduce a community review process
david radley (Jira)
-
[jira] [Assigned] (FLINK-37916) Add StreamPhysicalMultiJoin physical node
Timo Walther (Jira)
-
[jira] [Closed] (FLINK-37916) Add StreamPhysicalMultiJoin physical node
Timo Walther (Jira)
-
[jira] [Commented] (FLINK-37933) Move TransformationScan/SinkProvider out of planner
Arvid Heise (Jira)
-
[jira] [Closed] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join
Xuyang Zhong (Jira)
-
[jira] [Assigned] (FLINK-37898) Implement delta join operator
Xuyang Zhong (Jira)
-
Re: [PR] [FLINK-37660] Reenable Kryo serializer upgrade tests [flink]
via GitHub
-
Re: [PR] [FLINK-35458][test][type] Add serializer upgrade test for set serializer [flink]
via GitHub
-
[jira] [Assigned] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend
Zakelly Lan (Jira)
-
Re: [PR] [FLINK-37156] [cdc-composer/cli] pipeline supports collecting data once and writing it to multiple sinks. [flink-cdc]
via GitHub
-
[jira] [Commented] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner
CaoZhen (Jira)
-
[jira] [Updated] (FLINK-37737) Add support for GaussDB database type
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-37737] Add support for GaussDB database type [flink-connector-jdbc]
via GitHub
-
[jira] [Closed] (FLINK-35018) ML_EVALUATE function
Hao Li (Jira)
-
[jira] [Commented] (FLINK-33536) Flink Table API CSV streaming sink fails with "IOException: Stream closed"
sigalit (Jira)
-
[jira] [Closed] (FLINK-35017) ML_PREDICT function
Hao Li (Jira)
-
[jira] [Closed] (FLINK-35020) Model Catalog implementation in Hive etc
Hao Li (Jira)
-
[PR] [FLINK-37946][doc] fix sql syntax of page Table API & SQL EXPLAIN [flink]
via GitHub
-
[jira] [Updated] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN
slankka (Jira)
-
[jira] [Commented] (FLINK-37928) Forbid cdc-stream for ML_PREDICT
Shengkai Fang (Jira)
-
[jira] [Commented] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend
Jufang He (Jira)
-
[PR] [hotfix][table] Fix StreamExecMLPredictTableFunction doesn't respect … [flink]
via GitHub
-
[jira] [Closed] (FLINK-37928) Forbid cdc-stream for ML_PREDICT
Shengkai Fang (Jira)
-
[PR] Add templates for Github Issues and PRs [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-37944) New test harness for KeyedProcessFunction using State V2
Zakelly Lan (Jira)
-
Re: [PR] [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink [flink-connector-aws]
via GitHub
-
[PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator
Gustavo de Morais (Jira)
-
[jira] [Commented] (FLINK-37943) mongo cdc bug can not read stream data
sunshuxian (Jira)
-
[jira] [Updated] (FLINK-37943) mongo cdc bug can not read stream data
sunshuxian (Jira)
-
[jira] [Created] (FLINK-37943) mongo cdc bug can not read stream data
sunshuxian (Jira)
-
[jira] [Updated] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:1.20.1-scala_2.12-java8
guoqinglong (Jira)
-
[jira] [Created] (FLINK-37942) The rest.path configuration invalid in docker apache/flink:2.0-scala_2.12-java11
guoqinglong (Jira)
-
[PR] [FLINK-37877][table] Add the key ordered operator in table runtime for key ordered async lookup join [flink]
via GitHub
-
[jira] [Closed] (FLINK-37903) Support runtime config for ML_PREDICT
Shengkai Fang (Jira)
-
[jira] [Commented] (FLINK-37903) Support runtime config for ML_PREDICT
Shengkai Fang (Jira)
-
Re: [PR] Aec pr for diff [flink]
via GitHub
-
[jira] [Closed] (FLINK-37876) Introduce key ordered component in runtime
Xuyang Zhong (Jira)
-
[jira] [Commented] (FLINK-37876) Introduce key ordered component in runtime
Xuyang Zhong (Jira)
-
[jira] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17
Jira
-
[jira] [Commented] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version
Jira
-
[jira] [Updated] (FLINK-27549) Inconsistent bytecode version when enable jdk11 or higher version
Jira
-
[jira] [Created] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE
Xuyang Zhong (Jira)
-
[jira] [Commented] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE
Xuyang Zhong (Jira)
-
[jira] [Updated] (FLINK-37941) EXCLUDING PARTITIONS doesn't work when using CREATE TABLE LIKE
Xuyang Zhong (Jira)
-
[jira] [Comment Edited] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle
Jiangjie Qin (Jira)
-
[jira] [Created] (FLINK-37940) Support retry for ML_PREDICT
Shengkai Fang (Jira)
-
[jira] [Resolved] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle
Jiangjie Qin (Jira)
-
[jira] [Assigned] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle
Jiangjie Qin (Jira)
-
[jira] [Comment Edited] (FLINK-37548) FLIP-507 : Add Model DDL methods in TABLE API
dalongliu (Jira)
-
[jira] [Closed] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci
dalongliu (Jira)
-
[jira] [Created] (FLINK-37939) Metrics for ml predict function
Hao Li (Jira)
-
[jira] [Created] (FLINK-37938) ml evaluate implementation for different task types
Hao Li (Jira)
-
[jira] [Commented] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch
Matt Cuento (Jira)
-
[jira] [Updated] (FLINK-37795) Physical rewrite for ml_evaluate
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function [flink]
via GitHub
-
[PR] [hotfix] Remove isUnalignedCheckpointsInterruptibleTimersEnabled config [flink]
via GitHub
-
[PR] Bump org.apache.kafka:kafka-clients from 3.9.0 to 3.9.1 [flink-connector-kafka]
via GitHub
-
Re: [PR] Bump org.apache.kafka:kafka-clients from 3.4.0 to 3.7.1 [flink-connector-kafka]
via GitHub
-
[PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 3.9.1 in /flink-end-to-end-tests/flink-sql-client-test [flink]
via GitHub
-
[PR] [FLINK-37916][table] Add StreamPhysicalMultiJoin [flink]
via GitHub
-
[PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink]
via GitHub
-
[PR] [FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink]
via GitHub
-
[PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink]
via GitHub