issues  

Messages by Thread

• [jira] [Resolved] (FLINK-36503) Remove deprecated method `FunctionDefinitionFactory#createFunctionDefinition` dalongliu (Jira)
• Re: [PR] [FLINK-36741][cdc][transform] Fix the precision of and length of data type has been lost when use transform and support DecimalData [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-36496) Remove deprecated method `CatalogFunction#isGeneric ` dalongliu (Jira)
• Re: [PR] [FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization. [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-36496) Remove deprecated method `CatalogFunction#isGeneric ` dalongliu (Jira)
• Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
  • Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
  • Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
  • Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
  • Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
  • Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
  • Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
  • Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
  • Re: [PR] [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation [flink] via GitHub
• [jira] [Commented] (FLINK-36492) Remove all deprecated methods in `ListView` dalongliu (Jira)
• [jira] [Resolved] (FLINK-36492) Remove all deprecated methods in `ListView` dalongliu (Jira)
• [jira] [Commented] (FLINK-36297) SIGSEGV caused CI failure Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-36493) Remove all deprecated methods in `MapView` dalongliu (Jira)
• [jira] [Commented] (FLINK-36493) Remove all deprecated methods in `MapView` dalongliu (Jira)
• [jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP Zakelly Lan (Jira)
  • [jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP Weijie Guo (Jira)
  • [jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP Weijie Guo (Jira)
  • [jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP Shuai Xu (Jira)
• [jira] [Updated] (FLINK-37128) Skip binlog split reader `shouldEmit` filter when snapshot reader skip backfill JunboWang (Jira)
• [jira] [Updated] (FLINK-37128) Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill JunboWang (Jira)
• [jira] [Updated] (FLINK-37128) Binlog split reader skip `shouldEmit` filter when snapshot reader skip backfill JunboWang (Jira)
• [jira] [Updated] (FLINK-37128) Skip binlog split reader `shouldEmit` filter when skip backfill JunboWang (Jira)
• [jira] [Updated] (FLINK-37129) AbstractSqlGatewayStatementITCaseBase.testFlinkSqlStatements failed on AZP Weijie Guo (Jira)
• [jira] [Updated] (FLINK-37128) Skip binlog split reader should filter when skip backfill JunboWang (Jira)
• [jira] [Created] (FLINK-37129) AbstractSqlGatewayStatementITCaseBase.testFlinkSqlStatements failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-37128) Skip binlog replay filter when skip backfill JunboWang (Jira)
• [jira] [Updated] (FLINK-37127) BuiltInAggregateFunctionTestBase failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-37127) BuiltInAggregateFunctionTestBase failed on AZP Weijie Guo (Jira)
• Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37126) Add Validator for Autoscler yuanfenghu (Jira)
• [jira] [Updated] (FLINK-37092) Enable skewed join optimization in the TPC-DS e2e test. ASF GitHub Bot (Jira)
• [PR] [FLINK-37092][e2e] Add adaptive skewed join optimization to e2e tpc-ds [flink] via GitHub
  • Re: [PR] [FLINK-37092][e2e] Add adaptive skewed join optimization to e2e tpc-ds tests [flink] via GitHub
  • Re: [PR] [FLINK-37092][e2e] Add adaptive skewed join optimization to e2e tpc-ds tests [flink] via GitHub
  • Re: [PR] [FLINK-37092][e2e] Add adaptive skewed join optimization to e2e tpc-ds tests [flink] via GitHub
• [jira] [Resolved] (FLINK-37015) Revise serialization doc to reflect the 2.0 breaking changes properly Weijie Guo (Jira)
• [jira] [Assigned] (FLINK-37015) Revise serialization doc to reflect the 2.0 breaking changes properly Weijie Guo (Jira)
• [jira] [Closed] (FLINK-37083) SqlYARNApplicationITCase.testDeployScriptViaSqlClient failed on AZP Shengkai Fang (Jira)
• [jira] [Updated] (FLINK-36406) MetadataApplier should be closed when the job stop Sergei Morozov (Jira)
• Re: [PR] [FLINK-36086] Set isSnapshotCompleted only immediately after snapshot [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36086] Set isSnapshotCompleted only immediately after snapshot [flink-cdc] via GitHub
• Re: [PR] [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options [flink] via GitHub
• Re: [PR] FLINK-24066 [flink] via GitHub
• Re: [PR] [FLINK-24925] [core] SingleThreadAccessCheckingTypeSerializer#equals() compares different data type. [flink] via GitHub
• Re: [PR] [FLINK-24640][table] CEIL, FLOOR built-in functions for Timestamp should res… [flink] via GitHub
• Re: [PR] [FLINK-15816][k8s] Prevent labels using kubernetes.cluster-id to exceed the limit of 63 characters [flink] via GitHub
• Re: [PR] deserializer.open() method can not pass compile [flink] via GitHub
• Re: [PR] [hotfix][connectors] Kinesalite Container very very rarely fails with ContainerLaunchException [flink] via GitHub
• Re: [PR] [FLINK-24009] Upgrade to Apache pom parent 24 [flink] via GitHub
• Re: [PR] [docs][typos] fix typos that memory is miswritten as jobmanager in st… [flink] via GitHub
• Re: [PR] [FLINK-23861][sql-client]flink sql client support dynamic params [flink] via GitHub
• Re: [PR] [FLINK-24272][Connectors / FileSystem] FileSystem compaction should throw unsupported exception in at-least-once mode [flink] via GitHub
• Re: [PR] [FLINK-23449] [Deployment/YARN] YarnTaskExecutorRunner should contains MapReduce classes [flink] via GitHub
• Re: [PR] [FLINK-20188][Connectors/FileSystem,Documentation] Add Documentation … [flink] via GitHub
• Re: [PR] [FLINK-25310][Documentation] Fix the incorrect description for output network buffers in buffer debloat documenation [flink] via GitHub
• Re: [PR] [hotfix][connectors/opensearch] Refactored to base aws sink to allow for opensearch sink [flink] via GitHub
• Re: [PR] [docs] Tutorial: Write Your First Flink SQL program [flink] via GitHub
• Re: [PR] [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A… [flink] via GitHub
• Re: [PR] [FLINK-24693][docs-zh] Translate "checkpoints" and "checkpointing" page to Chinese [flink] via GitHub
• Re: [PR] [FLINK-14438][core] Fix RowTypeInfo.equals() [flink] via GitHub
• Re: [PR] [FLINK-25138][Table SQL/Client] SQL Client improve completion for com… [flink] via GitHub
• Re: [PR] [hotfix][doc] Remove redundant document description [flink] via GitHub
• Re: [PR] [FLINK-25172][docs] Update docs\content\docs\dev\table\tableApi.md [flink] via GitHub
• Re: [PR] [FLINK-18779][table sql/planner]Support the SupportsFilterPushDown for LookupTableSource [flink] via GitHub
• Re: [PR] Update checkpointing.md [flink] via GitHub
• Re: [PR] [FLINK-25015][Table SQL/Client] job name should not always be `collect` submitted by sql client [flink] via GitHub
• Re: [PR] [FLINK-25164] DogStatsD Metrics Reporter [flink] via GitHub
• Re: [PR] [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph [flink] via GitHub
• Re: [PR] [docs]format doc style of execution_mode.md [flink] via GitHub
• Re: [PR] [FLINK-6573][Connectors/Common ] Flink MongoDB Connector [flink] via GitHub
• Re: [PR] [FLINK-25095][table-planner] Fix generateComparison returnType [flink] via GitHub
• Re: [PR] [FLINK-24908][Table SQL/Client] Improve SQL Error description for SQL Client [flink] via GitHub
• Re: [PR] [FLINK-24941][datadog] Support Boolean gauges [flink] via GitHub
• Re: [PR] added the definition of done to the github templates [flink] via GitHub
• Re: [PR] [FLINK-15825][Table SQL/API] Add renameDatabase() to Catalog [flink] via GitHub
• Re: [PR] [FLINK-24854][tests] StateHandleSerializationTest unit test error [flink] via GitHub
• Re: [PR] [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS [flink] via GitHub
  • Re: [PR] [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS [flink] via GitHub
• Re: [PR] [hotfix][javadocs] Improve JavaDocs of SupportsAggregatePushDown [flink] via GitHub
• Re: [PR] [hotfix] [javadocs] Fix typo in BoundedOutOfOrdernessWatermarksTest [flink] via GitHub
• Re: [PR] [FLINK-23347] [docs] Fix spelling errors in the word "DataStreamStream" [flink] via GitHub
• Re: [PR] [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization [flink] via GitHub
• Re: [PR] FLINK-25029: Hadoop Caller Context Setting in Flink [flink] via GitHub
• Re: [PR] [FLINK-24915] [DataStream] fix StreamElementSerializer#deserialize(reuse, source) forgets to handle tag == TAG_STREAM_STATUS. [flink] via GitHub
• Re: [PR] [FLINK-23305][table]Support semi/anti interval joins [flink] via GitHub
• Re: [PR] [docs][typos] Fix typos in fault_tolerance.md [flink] via GitHub
• Re: [PR] [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese [flink] via GitHub
• Re: [PR] [FLINK-24957][runtime]show host:port information in subtasks tab [flink] via GitHub
• Re: [PR] [FLINK-24712] [Library/CEP] NFATest#testSimpleNFA: fix test flaxiness [flink] via GitHub
• Re: [PR] [FLINK-24879][core] All ReducingStateDescriptor constructor should check reduceFunction is not a richFunction. [flink] via GitHub
• Re: [PR] [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog [flink] via GitHub
• Re: [PR] [FLINK-23972][CLI] Allow configurable classpath for command-line client [flink] via GitHub
• Re: [PR] [FLINK-24750][table][docs] Code blocks to prevent sql quotes convertion [flink] via GitHub
• Re: [PR] [FLINK-24247][TableAPI/SQL] Uniformly limit the value of ABS(offset) … [flink] via GitHub
• Re: [PR] [hotfix][docs] Add link from README.md to 'Building Flink from Source' [flink] via GitHub
• Re: [PR] [FLINK-9465][Runtime/Checkpointing] Specify a separate savepoint timeout option via CLI and REST API [flink] via GitHub
• Re: [PR] [FLINK-22240][runtime] Cleanup logs in ExternalResourceUtils [flink] via GitHub
• Re: [PR] [FLINK-24479][State Backends]Bug fix RocksIteratorWrapper#seekToLast method [flink] via GitHub
• Re: [PR] Update window-agg.md [flink] via GitHub
  • Re: [PR] Update window-agg.md [flink] via GitHub
• Re: [PR] [hotfix] [docs-zh] Add auxiliary words to make the sentence flow smoothly [flink] via GitHub
• Re: [PR] [FLINK-24614][Connectors/PARQUET] Add Complex types support for parquet reader [flink] via GitHub
• Re: [PR] [FLINK-24709]Fix the interval join java case in the official document… [flink] via GitHub
• Re: [PR] FLINK SQL checkpoint不生效 [flink] via GitHub
• Re: [PR] [FLINK-24680][runtime/coordinator] Use UserCodeClassLoader when closing coordinator and register hook in ClassLoader to prevent releasing before coordinator close [flink] via GitHub
• Re: [PR] [FLINK-24122][history] Add support to do clean in history server [flink] via GitHub
• Re: [PR] [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!=' [flink] via GitHub
• Re: [PR] [FLINK-24510][Deployment/Scripts]Fix the duplicate log output of libraries/connectors，when logback is used [flink] via GitHub
• Re: [PR] [hotfix][flink-yarn] Fix typo in YarnConfigOptions.java [flink] via GitHub
• Re: [PR] [FLINK-24547][Table SQL / Planner]A function named row_kind() can get… [flink] via GitHub
• Re: [PR] Update hive_functions.md [flink] via GitHub
• Re: [PR] Update kafka.md [flink] via GitHub
• Re: [PR] [FLINK-24398][connectors/kafka] KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible [flink] via GitHub
  • Re: [PR] [FLINK-24398][connectors/kafka] KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible [flink] via GitHub
• Re: [PR] [FLINK-23378][flink-streaming-java] ContinuousProcessingTimeTrigger can't triger the last fireTimestamp [flink] via GitHub
• Re: [PR] [FLINK-11470][runtime] Pass configurations to filesystems when executing in LocalStreamEnvironment [flink] via GitHub
• Re: [PR] [FLINK-18592][Connectors/FileSystem] StreamingFileSink fails due to truncating HDFS file failure [flink] via GitHub
• Re: [PR] [FLINK-24146][doc]Translate "CREATE Statements" page of "SQL" into Ch… [flink] via GitHub
• Re: [PR] [hotfix][docs] Fix the outdated upgrading instruction for Kafka Connector [flink] via GitHub
• Re: [PR] Update generating_watermarks.md [flink] via GitHub
  • Re: [PR] Update generating_watermarks.md [flink] via GitHub
• Re: [PR] [hotfix] Fixed Savepoint Documentation Typo [flink] via GitHub
• Re: [PR] [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source) [flink] via GitHub
• Re: [PR] [hotfix] Datasteam Typo [flink] via GitHub
• Re: [PR] [FLINK-15532][rocksdb] Enable strict capacity limit for memory usage for RocksDB [flink] via GitHub
• Re: [PR] [FLINK-24610][table-planner] Support sql projection common expression… [flink] via GitHub
• Re: [PR] [FLINK-24598][table-runtime] Fix test problem that the current IT cas… [flink] via GitHub
• Re: [PR] [hotfix][docs] Translate cep.md [flink] via GitHub
• Re: [PR] [FLINK-23953] In the AvroSerializerSnapshot set the serializer compatibility to 'AS IS' in case when underlying Avro schemas are compatible [flink] via GitHub
• Re: [PR] [FLINK-24546][docs]Add description for acknowledgement [flink] via GitHub
• Re: [PR] Update schema_evolution.md [flink] via GitHub
• Re: [PR] [FLINK-22246]when use HiveCatalog create table , can't set Table owne… [flink] via GitHub
• Re: [PR] [FLINK-23748][tests] Testing window TVF session window [flink] via GitHub
• Re: [PR] [FLINK-23425][streaming-java] The impact of cpu cores on test results… [flink] via GitHub
• Re: [PR] [FLINK-24093] Supports setting the percentage of kubernetes Request resources [flink] via GitHub
• Re: [PR] [hotfix][docs] Fix Blob Server configuration doc [flink] via GitHub
• Re: [PR] [FLINK-24142]Fix Document DataStream Connectors File Sink ORC Format … [flink] via GitHub
• Re: [PR] [FLINK-23935][docs] Fix unexpected page scrolling when click tabs [flink] via GitHub
• Re: [PR] Update data_stream_api.md, correct example results [flink] via GitHub
• Re: [PR] [FLINK-23397] Fix task_failure_recovery page return 404 [flink] via GitHub
• Re: [PR] [FLINK-23583][table-common] Introduce SubRowData [flink] via GitHub
• Re: [PR] [FLINK-23727][core] Skip null values in SimpleStringSchema#deserialize [flink] via GitHub
• Re: [PR] [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese [flink] via GitHub
• Re: [PR] [FLINK-23763][Deployment/YARN]Use yarn config in sql but not yarn mag… [flink] via GitHub
• Re: [PR] [FLINK-23786]avoid multiple authentications [flink] via GitHub
• Re: [PR] [hotfix][docs] Fix typo issue in time.md [flink] via GitHub
• Re: [PR] [FLINK-23229][docs-zh] Translate "Timely Stream Processing" page into Chinese [flink] via GitHub
• Re: [PR] [FLINK-20518][rest] Add decoding characters for MessageQueryParameter [flink] via GitHub
• Re: [PR] [FLINK-23602][table-runtime] Fix comparison between Decimal and string literal [flink] via GitHub
• Re: [PR] Fixed small typo in tableApi.md [flink] via GitHub
• Re: [PR] [FLINK-23198][Documentation] Fix the demo of ConfigurableRocksDBOptionsFactory in Documentation. [flink] via GitHub
• Re: [PR] [FLINK-23158] Add source transformations to the list when adding sources [flink] via GitHub
• Re: [PR] [FLINK-23501][GCP PubSub] add table source API for GCP PubSub [flink] via GitHub
• Re: [PR] [FLINK-23163][Kubernetes]Add debug log to flink kubeclient [flink] via GitHub
• Re: [PR] [FLINK-18464][Runtime] when namespaceSerializer is different, forbid getPartitionedState from different namespace [flink] via GitHub
• Re: [PR] [FLINK-23495] [Connectors / Google Cloud PubSub] Make checkpoint optional for preview/staging mode [flink] via GitHub
• Re: [PR] [FLINK-11622][chinese-translation,Documentation]Translate the "Command-Line Interface" page into Chinese [flink] via GitHub
• Re: [PR] [FLINK-23139][state] Add TaskStateRegistry [flink] via GitHub
  • Re: [PR] [FLINK-23139][state] Add TaskStateRegistry [flink] via GitHub
• Re: [PR] [hotfix][connector/kafka] fix missing nullable annotion in createKafkaTableSink function [flink] via GitHub
  • Re: [PR] [hotfix][connector/kafka] fix missing nullable annotion in createKafkaTableSink function [flink] via GitHub
• Re: [PR] fix md link [flink] via GitHub
• Re: [PR] [FLINK-23441] Remove CheckpointOptions from Snapshotable#snapshot [flink] via GitHub
• Re: [PR] [hotfix] Finalize SeqNo for Change Log [flink] via GitHub
• Re: [PR] Update flink-operations-playground.md [flink] via GitHub
• Re: [PR] [FLINK-18464][Runtime] add the readonly method for flink to read state in different namespace [flink] via GitHub
• Re: [PR] Draft Materialization master [flink] via GitHub
• Re: [PR] provide the timeout option for kafka admin client [flink] via GitHub
• Re: [PR] [FLINK-35067][cdc-connector][postgres] Adding metadata 'row_kind' for Postgres CDC Connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35067][cdc-connector][postgres] Adding metadata 'row_kind' for Postgres CDC Connector. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35067][cdc-connector][postgres] Adding metadata 'row_kind' for Postgres CDC Connector. [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException sehaj pal singh sandhu (Jira)
• [jira] [Updated] (FLINK-37076) Support PTF skeleton in planner ASF GitHub Bot (Jira)
• [PR] [FLINK-37076][table-planner] Make table arguments explicit in logical plans [flink] via GitHub
  • Re: [PR] [FLINK-37076][table-planner] Make table arguments explicit in logical plans [flink] via GitHub
  • Re: [PR] [FLINK-37076][table-planner] Make table arguments explicit in logical plans [flink] via GitHub
  • Re: [PR] [FLINK-37076][table-planner] Make table arguments explicit in logical plans [flink] via GitHub
• Re: [PR] [FLINK-21108][rest-client] Add basic & digest auth support to rest client [flink] via GitHub
• Re: [PR] [FLINK-22178][csv] Support ignore-first-line option in new csv format [flink] via GitHub
• Re: [PR] [FLINK-20952][json] Changelog json formats should support inherit options from JSON format [flink] via GitHub
• Re: [PR] [FLINK-23000] Add log bundler to collect and compress logs [flink] via GitHub
• Re: [PR] [FLINK-21440][doc] translate content.zh/docs/try-flink/table_api.md and correct spelling mistake content/docs/try-flink/table_api.md [flink] via GitHub
• Re: [PR] [FLINK-21364][connector] piggyback finishedSplitIds in RequestSplitEv… [flink] via GitHub
• Re: [PR] [FLINK-20416][flink-table-api-java] Add Generic Cached Catalog [flink] via GitHub
• Re: [PR] [FLINK-20219][coordination] Shutdown cluster externally should only clean up the HA data if all the jobs have finished [flink] via GitHub

• Earlier messages
• Later messages