issues  

Messages by Thread

• Re: [PR] [FLINK-32564][table]bytes-to-number & number-to-bytes [flink] via GitHub
• Re: [PR] [FLINK-32954][Metrics] Metrics expose number of heap timer [flink] via GitHub
• Re: [PR] Refactor @Test(expected) with assertThrows [flink] via GitHub
• Re: [PR] [hotfix][docs] Update the parameter types of StreamGraph#addOperator in javadocs [flink] via GitHub
• Re: [PR] [FLINK-32910][build] Set default parameters for curl and wget [flink] via GitHub
• Re: [PR] [FLINK-32908][state-changelog] Fix wrong materialization id setting w… [flink] via GitHub
• Re: [PR] [FLINK-32763] [SocketSource] Catch exceptions for retry code to work [flink] via GitHub
• Re: [PR] [FLINK-32897][table-runtime]Fix RowToRowCastRule get wrong result error while cast Array(Row()) type [flink] via GitHub
• Re: [PR] [FLINK-32176][config] create default option for scheduler-mode [flink] via GitHub
• Re: [PR] [FLINK-32887][connector/common] ExecutorNotifier#notifyReadyAsync wil… [flink] via GitHub
• Re: [PR] Update local_installation.md [flink] via GitHub
• Re: [PR] [FLINK-32753] Print JVM flags on AZP [flink] via GitHub
  • Re: [PR] [FLINK-32753] Print JVM flags on AZP [flink] via GitHub
• Re: [PR] [FLINK-32873][table] - Add config to allow disabling QUERY hints [flink] via GitHub
  • Re: [PR] [FLINK-32873][table] - Add config to allow disabling QUERY hints [flink] via GitHub
• Re: [PR] [BP-1.17][FLINK-32564][table]bytes-to-number & number-to-bytes [flink] via GitHub
• Re: [PR] [FLINK-32866][Tests] Enable the TestLoggerExtension for all junit5 tests [flink] via GitHub
• Re: [PR] [FLINK-32658][checkpoint] allowNonRestoredState is compatible with the scene where the state in the Operator is removed [flink] via GitHub
• Re: [PR] [FLINK-31238] [WIP] Use IngestDB to speed up Rocksdb rescaling recovery [flink] via GitHub
  • Re: [PR] [FLINK-31238] [WIP] Use IngestDB to speed up Rocksdb rescaling recovery [flink] via GitHub
• Re: [PR] [FLINK-32776][flink-metrics]Add HTTP basic authentication support to PrometheusPushGatewayReporter [flink] via GitHub
• Re: [PR] [FLINK-32740][core] added literal null value support for flink-conf [flink] via GitHub
• Re: [PR] [BP-1.17][FLINK-32259][table] Add built-in ARRAY_JOIN function. [flink] via GitHub
• Re: [PR] [BP-1.17][FLINK-32260][table] Add built-in ARRAY_SLICE function. [flink] via GitHub
• [jira] [Updated] (FLINK-36578) Fixed bug when converting json type data to string Leonard Xu (Jira)
• [jira] [Updated] (FLINK-36578) Fixed inconsistent format when converting json type data to string Leonard Xu (Jira)
  • [jira] [Updated] (FLINK-36578) Fixed inconsistent format when converting json type data to string Lee SeungMin (Jira)
  • [jira] [Updated] (FLINK-36578) Fixed inconsistent format when converting json type data to string Lee SeungMin (Jira)
  • [jira] [Updated] (FLINK-36578) Fixed inconsistent format when converting json type data to string Lee SeungMin (Jira)
• [jira] [Resolved] (FLINK-36578) Fixed bug when converting json to string Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-36578) Fixed bug when converting json to string Leonard Xu (Jira)
• [jira] [Commented] (FLINK-37076) Support PTF skeleton in planner Timo Walther (Jira)
  • [jira] [Commented] (FLINK-37076) Support PTF skeleton in planner Timo Walther (Jira)
• [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
  • Re: [PR] [FLINK-34865][pipeline-connector/mysql] Support sync table comment in binlog phase [flink-cdc] via GitHub
• Re: [PR] [FLINK-37152][build] Update Flink version to 1.20 [flink-cdc] via GitHub
• Re: [PR] [hotfix][doc] Fix link display. [flink] via GitHub
• Re: [PR] [FLINK-37103] The parameters passed when calling method FactoryUtil.createDynamicTableSource are inconsistent [flink] via GitHub
• Re: [PR] [FLINK-37093][table] store catalog in catalogStoreHolder should after initCatalog and open when createCatalog [flink] via GitHub
• [jira] [Commented] (FLINK-37154) Support reading binary data from Kafka Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-37154) Support reading binary data from Kafka Dian Fu (Jira)
  • [jira] [Commented] (FLINK-37154) Support reading binary data from Kafka Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-37154) Support reading binary data from Kafka Chris Teoh (Jira)
• [jira] [Resolved] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1. Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector. Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector. Leonard Xu (Jira)
• [jira] [Updated] (FLINK-37154) Support reading binary data from Kafka Dian Fu (Jira)
• [jira] [Created] (FLINK-37154) Support reading binary data from Kafka Dian Fu (Jira)
• [jira] [Updated] (FLINK-37152) Update Flink version to 1.20 in Flink CDC ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-37152) Update Flink version to 1.20 in Flink CDC Ruan Hang (Jira)
  • [jira] [Updated] (FLINK-37152) Update Flink version to 1.20 in Flink CDC Ferenc Csaky (Jira)
  • [jira] [Updated] (FLINK-37152) Update Flink version to 1.20 in Flink CDC Ferenc Csaky (Jira)
• [jira] [Resolved] (FLINK-36913) Add an option in Kafka Sink to manual map table to topic name. Leonard Xu (Jira)
• [jira] [Updated] (FLINK-4946) Load jar files from subdirectories of lib ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-4946] [scripts] Load jar files from subdirectories of lib [flink] via GitHub
• Re: [PR] [FLINK-32454] deserializeStreamStateHandle of checkpoint read byte in… [flink] via GitHub
• [jira] [Updated] (FLINK-37153) Monitor late event count in temporal join ASF GitHub Bot (Jira)
• [PR] [FLINK-37153] Monitor late event count in temporal join [flink] via GitHub
  • Re: [PR] [FLINK-37153] Monitor late event count in temporal join [flink] via GitHub
  • Re: [PR] [FLINK-37153] Monitor late event count in temporal join [flink] via GitHub
  • Re: [PR] [FLINK-37153] Monitor late event count in temporal join [flink] via GitHub
  • Re: [PR] [FLINK-37153] Monitor late event count in temporal join [flink] via GitHub
• Re: [PR] [FLINK-32720][table] Add built-in GENERATE_SERIES function [flink] via GitHub
• Re: [PR] [BP-1.17][FLINK-30629][Client/Job Submission] Increase clientHeartbeatTimeout … [flink] via GitHub
• Re: [PR] [FLINK-32665][format] Support reading null value for csv format [flink] via GitHub
• Re: [PR] Explanation of Asynchronous Problem in Querying Data from HBase [flink] via GitHub
• Re: [PR] [FLINK-32711][planner] Fix the type mismatch when proctime() used as … [flink] via GitHub
• Re: [PR] [WIP] support flush [flink] via GitHub
• Re: [PR] [hotfix] [docs] Fix to remove .all from java opts under application profiling [flink] via GitHub
• Re: [PR] [docs] kafka.md Fromat adjustment [flink] via GitHub
• Re: [PR] [FLINK-32667][dispatcher] Do not save job without restart strategy to job writer and store [flink] via GitHub
  • Re: [PR] [FLINK-32667][dispatcher] Do not save job without restart strategy to job writer and store [flink] via GitHub
• Re: [PR] [FLINK-7129]Support dynamically changing CEP patterns [flink] via GitHub
• Re: [PR] [FLINK-32471][table]Add is_not_null to join push rule [flink] via GitHub
• Re: [PR] fix(sec): upgrade com.google.guava:guava to 32.0.0-jre [flink] via GitHub
• Re: [PR] [FLINK-32565][table] Support Cast From NUMBER to BYTES [flink] via GitHub
• Re: [PR] [FLINK-32508][metrics][prometheus] Add support for native counters an… [flink] via GitHub
• Re: [PR] Bump word-wrap from 1.2.3 to 1.2.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] [FLINK-32418][formats-protobuf] Fix ClassNotFoundException when using protobuf in SQL-Client [flink] via GitHub
• Re: [PR] [FLINK-32627] Add support for dynamic time window function [flink] via GitHub
• Re: [PR] [FLINK-32564][table] Support Cast From BYTES to NUMBER [flink] via GitHub
• Re: [PR] [FLINK-32649][runtime/Metrics] fix the dimension order for promethues reporter [flink] via GitHub
• Re: [PR] [FLINK-32573][docs-content.zh] Translate "Custom Serialization for Ma… [flink] via GitHub
• Re: [PR] [FLINK-32603] Avoid consuming twice when two planners have the same table source [flink] via GitHub
• Re: [PR] [FLINK-32132][table-planner] Cast function CODEGEN does not work as e… [flink] via GitHub
  • Re: [PR] [FLINK-32132][table-planner] Cast function CODEGEN does not work as e… [flink] via GitHub
• Re: [PR] FLINK-28171 enable add appProtocol via the configuration [flink] via GitHub
• Re: [PR] [WIP]Flush module [flink] via GitHub
• Re: [PR] [FLINK-32525][Deployment/YARN] Remove dependency convergence line for commons-beanutils [flink] via GitHub
• Re: [PR] [FLINK-32594][runtime]Support EndOfStreamTrigger and isOutputOnEOF operator attribute to optimize task deployment [flink] via GitHub
• Re: [PR] Bump stylelint from 14.8.5 to 15.10.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] Bump okio from 1.17.2 to 3.4.0 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] via GitHub
• Re: [PR] [FLINK-32575] add jobmanager cpu configuration [flink] via GitHub
• Re: [PR] [FLINK-32509][core] Avoid using skip in InputStreamFSInputWrapper [flink] via GitHub
• Re: [PR] [FLINK-32476][runtime] Support configuring object-reuse for internal operators [flink] via GitHub
• Re: [PR] [FLINK-32530][table] Fix array_position return null value semantic, w… [flink] via GitHub
• Re: [PR] [hotfix] Improve error message when config serialization fails [flink] via GitHub
  • Re: [PR] [hotfix] Improve error message when config serialization fails [flink] via GitHub
• Re: [PR] [FLINK-32281][table-planner] Enable two-phase HashAgg default when all aggregate functions in query support adaptive local HashAgg [flink] via GitHub
• Re: [PR] [FLINK-32488][REST] Introduce separate configuration to control expiry of E… [flink] via GitHub
• Re: [PR] [FLINK-32485][state-backends] Support build flink-state-backend-changelog test-jar [flink] via GitHub
• Re: [PR] [WIP] Don't merge, just for CI test [flink] via GitHub
• Re: [PR] [FLINK-32435][runtime][test] Merges different test implementations of LeaderContender into a single generic one [flink] via GitHub
• Re: [PR] [FLINK-32422][test] Adds test to cover the issue of forwarding the revoke event immediately to the contender for the EmbeddedLeaderService [flink] via GitHub
• Re: [PR] [hotfix] Fix typo in setMaxParallelism() when create iteration sink [flink] via GitHub
• Re: [PR] kafka.md Format adjustment [flink] via GitHub
• Re: [PR] [FLINK-32263]-table-Add-ELT-function [flink] via GitHub
• Re: [PR] [FLINK-32253][runtime] Update pending resource requests on nodes unblocked. [flink] via GitHub
• Re: [PR] [FLINK-32264][table] Add-built-in FIELD-function. [flink] via GitHub
• Re: [PR] [FLINK-30093][protobuf] Fix compile errors for google.protobuf.Timestamp type [flink] via GitHub
• Re: [PR] [FLINK-17224][table] Support precision for TIME [flink] via GitHub
• Re: [PR] [Hotfix] Fix NPE in print sink writer [flink] via GitHub
• Re: [PR] [FLINK-32006] Harden and speed up AsyncWaitOperatorTest#testProcessingTimeAlwaysTimeoutFunctionWithRetry [flink] via GitHub
• Re: [PR] [FLINK-32305] [History Server] Add number of workers to parallelize job archive processing [flink] via GitHub
• Re: [PR] [FLINK-32188][Table SQL / Planner] Support to "where" query and simplify condition for an array-type filed of temporary table. [flink] via GitHub
• Re: [PR] [FLINK-32159] AbstractColumnReader throws NPE [flink] via GitHub
• Re: [PR] [FLINK-32216][table-planner] Delete the redundant else statement in SetOperationParseStrategy [flink] via GitHub
• Re: [PR] [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document. [flink] via GitHub
  • Re: [PR] [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document. [flink] via GitHub
• Re: [PR] A few documentation fixes [flink] via GitHub
• Re: [PR] [FLINK-24696][docs-zh]Translate how to configure unaligned checkpoints into Chinese [flink] via GitHub
• Re: [PR] [FLINK-32198][runtime] Enforce single maxExceptions query parameter [flink] via GitHub
• Re: [PR] [FLINK-32203] Remove monitoringInterval to reduce probability of ClassLoader memory leak [flink] via GitHub
• Re: [PR] [FLINK-23190][runtime] Make schedulers allocate slots more evenly [flink] via GitHub
• Re: [PR] KafkaSource: disable setting client id prefix if client.id is set [flink] via GitHub
• Re: [PR] [FLINK-32044][table-api] Validate catalog name when listFunctions in FunctionCatalog [flink] via GitHub
• Re: [PR] [FLINK-32122] Update the Azure Blob Storage document to assist in configuring the MSI provider with a shaded class name [flink] via GitHub
• Re: [PR] [FLINK-31947] enable stdout for flink-console.sh [flink] via GitHub
• Re: [PR] Updating docs on how to upgrade kafka connectors [flink] via GitHub
• Re: [PR] [FLINK-31951][format] Mix schema record source creates corrupt record [flink] via GitHub
• Re: [PR] [FLINK-32039][test] Adds graceful shutdown to TestExecutorExtension and TestExecutorResource [flink] via GitHub
• Re: [PR] [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator [flink] via GitHub
• Re: [PR] [FLINK-31928][build] Upgrade okhttp3 to 4.11.0 [flink] via GitHub
  • Re: [PR] [FLINK-31928][build] Upgrade okhttp3 to 4.11.0 [flink] via GitHub
• Re: [PR] [FLINK-31883] Using the unboxed types that prevent nullability issues [flink] via GitHub
• Re: [PR] [FLINK-31689][flink-connector-files] Check expired file state before … [flink] via GitHub
• Re: [PR] [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8 [flink] via GitHub
• Re: [PR] [FLINK-31828][planner] Use the inner serializer for RawType when doin… [flink] via GitHub
• Re: [PR] [FLINK-31875][filesystems] Override the flink-parent dependencyManagement definition for hadoop-common of OSS [flink] via GitHub
• Re: [PR] [hotfix] [docs] Fix documentation hyperlink to table formats (to master) [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix documentation hyperlink to table formats (to master) [flink] via GitHub
• Re: [PR] [FLINK-31863]kubernetes] Add Hostname enum val to kubernetes NodeAddress type [flink] via GitHub
• Re: [PR] [hotfix][doc] fix typo in mysql db prompt [flink] via GitHub
• [jira] [Resolved] (FLINK-35600) Data read duplication during the full-to-incremental conversion phase Leonard Xu (Jira)
• Re: [PR] [FLINK-35600] Add timestamp for low and high watermark [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35600] Add timestamp for low and high watermark [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-35802) Deadlock may happen after adding new tables Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-35802) Deadlock may happen after adding new tables Leonard Xu (Jira)
• [jira] [Closed] (FLINK-36333) FLIP-475: Support Adaptive Skewed Join Optimization Junrui Lee (Jira)
• [jira] [Closed] (FLINK-37092) Enable skewed join optimization in the TPC-DS e2e test. Junrui Lee (Jira)
• [jira] [Assigned] (FLINK-36351) Doris pipeline sink does not support Flink TIME type Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-36351) Doris pipeline sink does not support Flink TIME type Leonard Xu (Jira)
• Re: [PR] [FLINK-36351][pipeline-connector/doris] support the conversion of Flink TIME type to Doris String type [flink-cdc] via GitHub
• Re: [PR] [hotfix][test] Make pipeline migration tests more robust [flink-cdc] via GitHub
  • Re: [PR] [hotfix][test] Make pipeline migration tests more robust [flink-cdc] via GitHub
• Re: [PR] [FLINK-36913][pipeline-connector][kafka] Add sink.table.mapping option to allow user to define a custom map for upstream TableId to downstream topic name. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36913][pipeline-connector][kafka] Add sink.table.mapping option to allow user to define a custom map for upstream TableId to downstream topic name. [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37153) Monitor late event count in temporal join Jira
• Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-37132) Add schema validation in Multi Transform ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37152) Update Flink version to 1.20 in Flink CDC Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-35405) Add buffer size/in-flight records metrics for AsyncExecutionController ASF GitHub Bot (Jira)
• [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink] via GitHub
  • Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink] via GitHub
  • Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink] via GitHub
  • Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink] via GitHub
  • Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink] via GitHub
  • Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink] via GitHub
  • Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink] via GitHub
• Re: [PR] [FLINK-36406][cdc-runtime] Close MetadataApplier when the job stops [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36406][cdc-runtime] Close MetadataApplier when the job stops [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36406][cdc-runtime] Close MetadataApplier when the job stops [flink-cdc] via GitHub
• [jira] [Comment Edited] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats Leonard Xu (Jira)
  • [jira] [Resolved] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats Leonard Xu (Jira)
• [jira] [Reopened] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats Leonard Xu (Jira)
• Re: [PR] [FLINK-36620][cdc-dist] Add support for specifying the --flink-home command line parameter with an '=' character [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36620][cdc-dist] Add support for specifying the --flink-home command line parameter with an '=' character [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats Leonard Xu (Jira)
• [PR] [FLINK-37151][runtime-web] Remove redundant testing dependencies and files [flink] via GitHub
  • Re: [PR] [FLINK-37151][runtime-web] Remove redundant testing dependencies and files [flink] via GitHub
  • Re: [PR] [FLINK-37151][runtime-web] Remove redundant testing dependencies and files [flink] via GitHub
  • Re: [PR] [FLINK-37151][runtime-web] Remove redundant testing dependencies and files [flink] via GitHub
  • Re: [PR] [FLINK-37151][runtime-web] Remove redundant testing dependencies and files [flink] via GitHub
• [jira] [Resolved] (FLINK-36224) Add the version mapping between pipeline connectors and flink Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-36224) Add the version mapping between pipeline connectors and flink Leonard Xu (Jira)
• [PR] Support mysql pipline rate [flink-cdc] via GitHub
  • Re: [PR] Support mysql pipline rate [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-37151) Remove redundant testing dependencies of Flink UI Ao Yuchen (Jira)
  • [jira] [Updated] (FLINK-37151) Remove redundant testing dependencies of Flink UI ASF GitHub Bot (Jira)

• Earlier messages
• Later messages