issues  

Messages by Thread

• • Re: [PR] [FLINK-38992] Expire associated state together for non-time over windows [flink] via GitHub
  • Re: [PR] [FLINK-38992] Expire associated state together for non-time over windows [flink] via GitHub
  • Re: [PR] [FLINK-38992] Expire associated state together for non-time over windows [flink] via GitHub
  • Re: [PR] [FLINK-38992] Expire associated state together for non-time over windows [flink] via GitHub
  • Re: [PR] [FLINK-38992] Expire associated state together for non-time over windows [flink] via GitHub
  • Re: [PR] [FLINK-38992] Expire associated state together for non-time over windows [flink] via GitHub
• [jira] [Created] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Bonnie Varghese (Jira)
• [jira] [Updated] (FLINK-37351) Ensure writer and committer are colocated ASF GitHub Bot (Jira)
• [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
  • Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
  • Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
  • Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
  • Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
• [jira] [Assigned] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. Matyas Orhidi (Jira)
• [jira] [Assigned] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Matyas Orhidi (Jira)
• [jira] [Created] (FLINK-38991) MySQL CDC fails to detect online schema changes with custom gh-ost or pt-osc table naming Vishal P R (Jira)
• Re: [D] Planning Flink Agents 0.2 [flink-agents] via GitHub
• [jira] [Closed] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently Ferenc Csaky (Jira)
• [jira] [Assigned] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently Ferenc Csaky (Jira)
• [jira] [Assigned] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently Ferenc Csaky (Jira)
• [jira] [Closed] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently Ferenc Csaky (Jira)
• Re: [PR] [FLINK-38908] Fix flaky ExecutionPartitionLifecycleTest [flink] via GitHub
• [PR] [hotfix] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Fix Debezium schema generation for complex types (ARRAY, MAP, ROW) [flink-cdc] via GitHub
• [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
  • Re: [PR] Announce Flink Agents 0.2.0 [flink-web] via GitHub
• Re: [PR] [FLINK-38831][route] The route configuration supports matching the first one [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38990) Support configurable initial delay for first checkpoint trigger Liu (Jira)
  • [jira] [Updated] (FLINK-38990) Support configurable initial delay for first checkpoint trigger ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
  • Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
  • Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• Re: [PR] [FLINK-37722] Eliminate redundant field initialization of PojoSerializer [flink] via GitHub
  • Re: [PR] [FLINK-37722] Eliminate redundant field initialization of PojoSerializer [flink] via GitHub
  • Re: [PR] [FLINK-37722] Eliminate redundant field initialization of PojoSerializer [flink] via GitHub
  • Re: [PR] [FLINK-37722] Eliminate redundant field initialization of PojoSerializer [flink] via GitHub
• [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] via GitHub
  • Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] via GitHub
  • Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] via GitHub
  • Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] via GitHub
• [jira] [Created] (FLINK-38990) Support configurable initial delay for first checkpoint trigger Liu (Jira)
• [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
  • Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
  • Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
  • Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
  • Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
  • Re: [PR] [FLINK-38988][Table SQL/API] Support INET_ATON and INET_NTOA functions for IP address conversion [flink] via GitHub
• [jira] [Closed] (FLINK-38812) Log PYFLINK_CYTHON_ENABLED to show whether cython optimization is enabled Dian Fu (Jira)
• [PR] [doc] Fix typos in documentation [flink-agents] via GitHub
  • Re: [PR] [doc] Fix typos in documentation [flink-agents] via GitHub
  • Re: [PR] [doc] Fix typos in documentation [flink-agents] via GitHub
• [PR] [FLINK-38965][cdc][postgres] Fix LIKE wildcard matching issue for similar table names in PostgreSQL CDC connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38965][cdc][postgres] Fix LIKE wildcard matching issue for similar table names in PostgreSQL CDC connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38965][cdc][postgres] Fix LIKE wildcard matching issue for similar table names in PostgreSQL CDC connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38965][cdc][postgres] Fix LIKE wildcard matching issue for similar table names in PostgreSQL CDC connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38965][cdc][postgres] Fix LIKE wildcard matching issue for similar table names in PostgreSQL CDC connector [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38989) Support resetting backlog status Shuai Xu (Jira)
  • [jira] [Updated] (FLINK-38989) Support resetting backlog status Shuai Xu (Jira)
  • [jira] [Updated] (FLINK-38989) Support resetting backlog status Shuai Xu (Jira)
  • [jira] [Updated] (FLINK-38989) Support resetting backlog status Shuai Xu (Jira)
• [PR] [doc] Update Java vs Python API choice details [flink-agents] via GitHub
  • Re: [PR] [doc] Update Java vs Python API choice details [flink-agents] via GitHub
  • Re: [PR] [doc] Update Java vs Python API choice details [flink-agents] via GitHub
  • Re: [PR] [doc] Update Java vs Python API choice details [flink-agents] via GitHub
• [jira] [Closed] (FLINK-38628) Add document for FLIP-542: Make materialized table DDL consistent with regular tables Ruan Hang (Jira)
• [jira] [Created] (FLINK-38989) Support resetting backlog status Shuai Xu (Jira)
• Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
  • Re: [PR] support mcp without list_prompts interface [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38951) Upgrade pemja to 0.5.6 Xuannan Su (Jira)
• Re: [I] [Bug] Flink Agents Example Fails with 'ModuleNotFoundError: No module named 'encodings'' in YARN Cluster Mode [flink-agents] via GitHub
  • Re: [I] [Bug] Flink Agents Example Fails with 'ModuleNotFoundError: No module named 'encodings'' in YARN Cluster Mode [flink-agents] via GitHub
• Re: [I] [Feature] Support Configuring Event Logger via Configuration System [flink-agents] via GitHub
  • Re: [I] [Feature] Support Configuring Event Logger via Configuration System [flink-agents] via GitHub
• [PR] [hotfix] Fix errors in mcp docs [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix errors in mcp docs [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion Liu (Jira)
  • [jira] [Updated] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion Liu (Jira)
  • [jira] [Updated] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion Liu (Jira)
• [jira] [Resolved] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-38889) YAML Kafka sink connector supports serializing complex types Yanquan Lv (Jira)
• [jira] [Closed] (FLINK-38691) Support for Transaction Boundary Events in Flink CDC Connector Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38987) Add RRSA (RAM Roles for Service Accounts) support for Flink OSS FileSystem yunjiong zhao (Jira)
• [jira] [Comment Edited] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Swapna Marru (Jira)
• [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Swapna Marru (Jira)
  • [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Imre Balassa (Jira)
  • [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Yaroslav (Jira)
  • [jira] [Commented] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-38986) SSL connection failures in BlobClientSslTest / NettyClientServerSslTest with latest JDK versions Swapna Marru (Jira)
• Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
• [jira] [Closed] (FLINK-38867) FlinkBlueGreenDeployment: savepointRedeployNonce does not respect user-provided initialSavepointPath Gyula Fora (Jira)
• Re: [PR] [FLINK-38867] FlinkBlueGreenDeployment used initialSavepointPath on restartSavepointNonce [flink-kubernetes-operator] via GitHub
• [PR] [FLINK-38913][table-planner][BP-2.1] ArrayIndexOutOfBoundsException unparsing CAST. [flink] via GitHub
  • Re: [PR] [FLINK-38913][table-planner][BP-2.1] ArrayIndexOutOfBoundsException unparsing CAST. [flink] via GitHub
  • Re: [PR] [FLINK-38913][table-planner][BP-2.1] ArrayIndexOutOfBoundsException unparsing CAST. [flink] via GitHub
• [PR] [FLINK-38913][table-planner][BP-2.2] ArrayIndexOutOfBoundsException unparsing CAST [flink] via GitHub
  • Re: [PR] [FLINK-38913][table-planner][BP-2.2] ArrayIndexOutOfBoundsException unparsing CAST [flink] via GitHub
  • Re: [PR] [FLINK-38913][table-planner][BP-2.2] ArrayIndexOutOfBoundsException unparsing CAST [flink] via GitHub
  • Re: [PR] [FLINK-38913][table-planner][BP-2.2] ArrayIndexOutOfBoundsException unparsing CAST [flink] via GitHub
• [PR] [hotfix] git ignore .metals and .bloop [flink] via GitHub
  • Re: [PR] [hotfix] git ignore .metals and .bloop [flink] via GitHub
  • Re: [PR] [hotfix] git ignore .metals and .bloop [flink] via GitHub
  • Re: [PR] [hotfix] git ignore .metals and .bloop [flink] via GitHub
• [PR] [minor][docs] add jdk baseline version and remove useless code [flink-cdc] via GitHub
  • Re: [PR] [minor][docs] add jdk baseline version and remove useless code [flink-cdc] via GitHub
  • Re: [PR] [minor][docs] add jdk baseline version and remove useless code [flink-cdc] via GitHub
  • Re: [PR] [minor][docs] add jdk baseline version and remove useless code [flink-cdc] via GitHub
  • Re: [PR] [minor][docs] add jdk baseline version and remove useless code [flink-cdc] via GitHub
  • Re: [PR] [minor][docs] add jdk baseline version and remove useless code [flink-cdc] via GitHub
  • Re: [PR] [minor][docs] add jdk baseline version and remove useless code [flink-cdc] via GitHub
• [PR] [release] Add scripts for generating contributor list [flink-agents] via GitHub
  • Re: [PR] [release] Add scripts for generating contributor list [flink-agents] via GitHub
  • Re: [PR] [release] Add scripts for generating contributor list [flink-agents] via GitHub
• Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-38984) Python interpreter not found when using thread mode (pemja) Dian Fu (Jira)
• [jira] [Commented] (FLINK-38984) Python interpreter not found when using thread mode (pemja) raoraoxiong (Jira)
  • [jira] [Commented] (FLINK-38984) Python interpreter not found when using thread mode (pemja) Dian Fu (Jira)
• [jira] [Updated] (FLINK-38984) Python interpreter not found when using thread mode (pemja) raoraoxiong (Jira)
• [jira] [Created] (FLINK-38985) [Doc] Add document for VARIANT type and related functions Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38984) Python interpreter not found when using thread mode (pemja) raoraoxiong (Jira)
• Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.23.1 to 2.25.3 [flink-connector-kudu] via GitHub
• [jira] [Updated] (FLINK-38691) Support for Transaction Boundary Events in Flink CDC Connector ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-38691] [cdc connector mysql] Support for MySQL Transaction Boundary Events in Flink CDC Connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38691] [cdc connector mysql] Support for MySQL Transaction Boundary Events in Flink CDC Connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38691] [cdc connector mysql] Support for MySQL Transaction Boundary Events in Flink CDC Connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38691] [cdc connector mysql] Support for MySQL Transaction Boundary Events in Flink CDC Connector [flink-cdc] via GitHub
• [PR] [doc] Update document for chat model. [flink-agents] via GitHub
  • Re: [PR] [doc] Update document for chat model. [flink-agents] via GitHub
  • Re: [PR] [doc] Update document for chat model. [flink-agents] via GitHub
• [PR] [hotfix] Update Flink versions in GitHub PR CI [flink-connector-kudu] via GitHub
  • Re: [PR] [hotfix] Update Flink versions in GitHub PR CI [flink-connector-kudu] via GitHub
• [PR] [Hotfix] [Build] Update flink-connector-kafka to 4.0.1-2.0 [flink] via GitHub
  • Re: [PR] [Hotfix] [Build] Update flink-connector-kafka to 4.0.1-2.0 [flink] via GitHub
  • Re: [PR] [Hotfix] [Build] Update flink-connector-kafka to 4.0.1-2.0 [flink] via GitHub
  • Re: [PR] [Hotfix] [Build] Update flink-connector-kafka to 4.0.1-2.0 [flink] via GitHub
  • Re: [PR] [Hotfix] [Build] Update flink-connector-kafka to 4.0.1-2.0 [flink] via GitHub
  • Re: [PR] [Hotfix] [Build] Update flink-connector-kafka to 4.0.1-2.0 [flink] via GitHub
• [PR] [release] Auto update documentation build ci when creating a new release branch [flink-agents] via GitHub
  • Re: [PR] [release] Auto update documentation build ci when creating a new release branch [flink-agents] via GitHub
• [PR] [hotfix] Fix errors in sensory_and_short_term_memory [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix errors in sensory_and_short_term_memory [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix errors in sensory_and_short_term_memory [flink-agents] via GitHub
  • Re: [PR] [hotfix] Fix errors in sensory_and_short_term_memory [flink-agents] via GitHub
• [PR] [hotfix][release] Build 0.2 docs in GitHub Action [flink-agents] via GitHub
  • Re: [PR] [hotfix][release] Build 0.2 docs in GitHub Action [flink-agents] via GitHub
  • Re: [PR] [hotfix][release] Build 0.2 docs in GitHub Action [flink-agents] via GitHub
  • Re: [PR] [hotfix][release] Build 0.2 docs in GitHub Action [flink-agents] via GitHub
• [PR] [doc] Update the documents in the get-started section [flink-agents] via GitHub
  • Re: [PR] [doc] Update the documents in the get-started section [flink-agents] via GitHub
  • Re: [PR] [doc] Update the documents in the get-started section [flink-agents] via GitHub
  • Re: [PR] [doc] Update the documents in the get-started section [flink-agents] via GitHub
  • Re: [PR] [doc] Update the documents in the get-started section [flink-agents] via GitHub
  • Re: [PR] [doc] Update the documents in the get-started section [flink-agents] via GitHub
• [PR] [doc] Update document for embedding model. [flink-agents] via GitHub
  • Re: [PR] [doc] Update document for embedding model. [flink-agents] via GitHub
  • Re: [PR] [doc] Update document for embedding model. [flink-agents] via GitHub
• Re: [PR] [FLINK-38510][table-planner] Remove targetColumns from the digest generation in SinkReuser [flink] via GitHub
• [jira] [Updated] (FLINK-38982) [JUnit5 Migration] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-38983) [JUnit5 Migration] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module Yuepeng Pan (Jira)
• [PR] [FLINK-38983][test] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module [flink] via GitHub
  • Re: [PR] [FLINK-38983][test] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module [flink] via GitHub
  • Re: [PR] [FLINK-38983][test] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module [flink] via GitHub

• Earlier messages
• Later messages