issues  

Messages by Thread

• Re: [PR] Update flink-operations-playground.md for a typo [flink] via GitHub
• Re: [PR] [FLINK-30400][docs] Add some notes about changes for flink-connector-base dependency in externalized connectors [flink] via GitHub
• Re: [PR] [FLINK-35598][sql-parser] Fix error comparison type ExtendedSqlRowTypeNameSpec#equalsDeep [flink] via GitHub
• Re: [PR] Documentation typo [flink] via GitHub
• Re: [PR] [FLINK-32562][connectors/filesystem] Handle concatenable compressed streams correctly in FileCompactor [flink] via GitHub
• Re: [PR] [FLINK-XXX][planner] Support custom shuffle for lookup join [flink] via GitHub
• [PR] [BP-2.0][FLINK-37609][format] Bump parquet to 1.15.1 [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37609][format] Bump parquet to 1.15.1 [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37609][format] Bump parquet to 1.15.1 [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37609][format] Bump parquet to 1.15.1 [flink] via GitHub
• [jira] [Commented] (FLINK-37618) Support PTFs INTERVAL argument juntaozhang (Jira)
• [jira] [Updated] (FLINK-37618) Support PTFs INTERVAL argument ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-37618) Support PTFs INTERVAL argument juntaozhang (Jira)
• [jira] [Created] (FLINK-37618) Support PTFs INTERVAL argument juntaozhang (Jira)
• [PR] [FLINK-37618][table-planner] Fix PTFs INTERVAL argument [flink] via GitHub
  • Re: [PR] [FLINK-37618][table-planner] Fix PTFs INTERVAL argument [flink] via GitHub
  • Re: [PR] [FLINK-37618][table-planner] Fix PTFs INTERVAL argument [flink] via GitHub
  • Re: [PR] [FLINK-37618][table-planner] Fix PTFs INTERVAL argument [flink] via GitHub
• [PR] [BP-1.19] Bump parquet to 1.15.1 [flink] via GitHub
  • Re: [PR] [BP-1.19] Bump parquet to 1.15.1 [flink] via GitHub
  • Re: [PR] [BP-1.19][FLINK-37609][format] Bump parquet to 1.15.1 [flink] via GitHub
  • Re: [PR] [BP-1.19][FLINK-37609][format] Bump parquet to 1.15.1 [flink] via GitHub
• [PR] [BP-1.20] Bump parquet to 1.15.1 [flink] via GitHub
  • Re: [PR] [BP-1.20] Bump parquet to 1.15.1 [flink] via GitHub
  • Re: [PR] [BP-1.20] Bump parquet to 1.15.1 [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-37609][format] Bump parquet to 1.15.1 [flink] via GitHub
• [jira] [Updated] (FLINK-23900) Migrate to ClusterActorRefProvider Weijie Guo (Jira)
• [jira] [Updated] (FLINK-32184) Use revision version property Weijie Guo (Jira)
• Re: [PR] [FLINK-23378][flink-streaming-java] ContinuousProcessingTimeTrigger can't triger the last fireTimestamp [flink] via GitHub
• [jira] [Created] (FLINK-37547) Add initial document for PTFs Timo Walther (Jira)
• [jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module Weijie Guo (Jira)
• [jira] [Updated] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase Weijie Guo (Jira)
• [jira] [Created] (FLINK-37539) performance optimization in Paimon Sink to reduce end-to-end checkpoint time Yanquan Lv (Jira)
• Re: [PR] [FLINK-24546][docs]Add description for acknowledgement [flink] via GitHub
• Re: [PR] [FLINK-14990][Table-Api]Add bit function inncluding bitand bitor bitnot bitxor [flink] via GitHub
• [jira] [Updated] (FLINK-35326) Implement lineage interface for hive connector Weijie Guo (Jira)
• [jira] [Updated] (FLINK-37525) Introduce overload findModuleFactory to improve the performance of installModules ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-13665][flink-planner] Use of decimal(p, s) where p is less tha… [flink] via GitHub
• Re: [PR] [FLINK-36648] Bump Flink version to Flink 2.0.0 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-36648] Bump Flink version to Flink 2.0.0 [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade Weijie Guo (Jira)
• [jira] [Updated] (FLINK-32444) Enable object reuse for Flink SQL jobs by default Weijie Guo (Jira)
• Re: [PR] [hotfix][docs] Remove the redundant punctuation in dev/training/index.md [flink] via GitHub
• Re: [PR] [hotfix] Preconditions.checkState should follows the Flink code style [flink] via GitHub
• Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally Weijie Guo (Jira)
• [jira] [Updated] (FLINK-34033) flink json supports raw type Weijie Guo (Jira)
• [jira] [Updated] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish Weijie Guo (Jira)
• [jira] [Updated] (FLINK-37568) Improve the method flatten of class GlobalConfiguration Jiaan Geng (Jira)
• [jira] [Updated] (FLINK-34604) Migrate BatchPhysicalCalcRule Weijie Guo (Jira)
• [jira] [Updated] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown Weijie Guo (Jira)
• [jira] [Updated] (FLINK-30738) Disable verbose mode Weijie Guo (Jira)
• [jira] [Updated] (FLINK-16126) Translate all connector related pages into Chinese Weijie Guo (Jira)
• [jira] [Updated] (FLINK-37572) Shuffle Event by bucket and tableid to avoid data skew Leonard Xu (Jira)
• Re: [PR] [FLINK][docs] fix rescaling operator description error [flink] via GitHub
  • Re: [PR] [FLINK][docs] fix rescaling operator description error [flink] via GitHub
• [jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved Weijie Guo (Jira)
• [jira] [Updated] (FLINK-26927) Improve FlinkContainers to better support JM restarting Weijie Guo (Jira)
• [jira] [Updated] (FLINK-29551) Improving adaptive hash join by using sort merge join strategy per partition instead of all partitions Weijie Guo (Jira)
• Re: [PR] [FLINK-12491][docs][configuration] Fix incorrect javadoc for path sep… [flink] via GitHub
• [jira] [Resolved] (FLINK-37358) Support pass format options to kafka pipeline sink Leonard Xu (Jira)
• Re: [PR] [FLINK-11746][thrift] Add thrift format support in Flink [flink] via GitHub
• [jira] [Updated] (FLINK-12590) Replace http links in documentation Weijie Guo (Jira)
• [jira] [Updated] (FLINK-36988) Migrate LogicalCorrelateToJoinFromTemporalTableFunctionRule Weijie Guo (Jira)
• [jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor Weijie Guo (Jira)
• [jira] [Commented] (FLINK-28639) Preserve distributed consistency of OperatorEvents from subtasks to OperatorCoordinator Yunfeng Zhou (Jira)
• [jira] [Updated] (FLINK-32537) Add compatibility annotation for REST API classes Weijie Guo (Jira)
• [jira] [Updated] (FLINK-35327) SQL Explain show push down condition Weijie Guo (Jira)
• [jira] [Updated] (FLINK-34609) Migrate BatchPhysicalScriptTransformRule Weijie Guo (Jira)
• [jira] [Updated] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join Weijie Guo (Jira)
• Re: [PR] [FLINK-11799][Connectors]Make KryoSerializer aware of exceptions occu… [flink] via GitHub
• [PR] Added Confluent to Vendor Solutions section [flink] via GitHub
• Re: [PR] [FLINK-21278][streaming-java] NullpointExecption error is reported wh… [flink] via GitHub
• [jira] [Created] (FLINK-37485) StarRocks Pipeline connector supports TIME type mapping yux (Jira)
• [jira] [Updated] (FLINK-20484) Improve hive temporal table exception Weijie Guo (Jira)
• [jira] [Updated] (FLINK-37463) Make ForStMapState Serializer ThreadLocal Weijie Guo (Jira)
• Re: [PR] [minor] Fix type error [flink] via GitHub
• Re: [PR] [FLINK-37557] Fix ResolvedSchema#getPrimaryKeyIndexes [flink] via GitHub
• Re: [PR] [FLINK-22411][docs]Add documentation about create directories on the Docker host machine in Flink Operations Playground [flink] via GitHub
• [jira] [Commented] (FLINK-37605) SinkWriter may incorrectly infer end of input during rescale Arvid Heise (Jira)
• [jira] [Updated] (FLINK-21126) Reconsider FLINK_PROPERTIES Weijie Guo (Jira)
• [jira] [Updated] (FLINK-29003) sqlServerDialect should support limit clause Weijie Guo (Jira)
• [jira] [Updated] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes Weijie Guo (Jira)
• Re: [PR] [FLINK-34596][table] Migrate RemoveRedundantLocalHashAggRule to java [flink] via GitHub
• [jira] [Updated] (FLINK-33950) Update max aggregate functions to new type system Weijie Guo (Jira)
• [PR] [FLINK-37601] migrate unirest-java to unirest-java-core [flink] via GitHub
  • Re: [PR] [FLINK-37601] migrate unirest-java to unirest-java-core [flink] via GitHub
  • Re: [PR] [FLINK-37601] migrate unirest-java to unirest-java-core [flink] via GitHub
  • Re: [PR] [FLINK-37601] migrate unirest-java to unirest-java-core [flink] via GitHub
  • Re: [PR] [FLINK-37601] migrate unirest-java to unirest-java-core [flink] via GitHub
  • Re: [PR] [FLINK-37601] migrate unirest-java to unirest-java-core [flink] via GitHub
  • Re: [PR] [FLINK-37601] Remove Unirest dependency in PrometheusReporterTest [flink] via GitHub
  • Re: [PR] [FLINK-37601] migrate unirest-java to unirest-java-core [flink] via GitHub
  • Re: [PR] [FLINK-37601] migrate unirest-java to unirest-java-core [flink] via GitHub
  • Re: [PR] [FLINK-37601] Remove Unirest dependency in PrometheusReporterTest [flink] via GitHub
  • Re: [PR] [FLINK-37601] Remove Unirest dependency in PrometheusReporterTest [flink] via GitHub
• Re: [PR] [FLINK-12819][sql-client] Reuse TableEnvironment between different SQ… [flink] via GitHub
• [jira] [Updated] (FLINK-34605) Migrate BatchPhysicalDistributionRule Weijie Guo (Jira)
• [jira] [Updated] (FLINK-32603) Avoid consuming twice when two pipelines have the same table source Weijie Guo (Jira)
• Re: [PR] [hotfix][docs] Translate cep.md [flink] via GitHub
• Re: [PR] [FLINK-34366][table] Add support to group rows by column ordinals [flink] via GitHub
• [jira] [Updated] (FLINK-35007) Update Flink Kafka connector to support 1.19 Arvid Heise (Jira)
• [jira] [Created] (FLINK-37500) CLONE - Publish the Dockerfiles for the new release Weijie Guo (Jira)
• [jira] [Updated] (FLINK-28109) Delete useful code in the row emitter. Weijie Guo (Jira)
• [jira] [Updated] (FLINK-24666) Add job level "table.exec.state-stale.error-handling" option and apply to related stateful stream operators Weijie Guo (Jira)
• [jira] [Comment Edited] (FLINK-37481) Multi way join operator Timo Walther (Jira)
• Re: [PR] [hotfix][docs] Typo in Chinese doc dev/execution/parallel.md [flink] via GitHub
• [jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs Weijie Guo (Jira)
• Re: [PR] [FLINK-23786]avoid multiple authentications [flink] via GitHub
• [PR] Adding Elasticsearch Connector v3.1.0 [flink-web] via GitHub
  • Re: [PR] Adding Elasticsearch Connector v3.1.0 [flink-web] via GitHub
• [jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status Weijie Guo (Jira)
• Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink] via GitHub
  • Re: [PR] [FLINK-37522][docs] Add description for the config about file system connection limit [flink] via GitHub
• [jira] [Updated] (FLINK-29058) Analyze table xxx For columns will thrown error while encounter String type column with null value Weijie Guo (Jira)
• [jira] [Updated] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework Weijie Guo (Jira)
• Re: [PR] [FLINK-37412] Add MIN_RESOURCES TaskManagerLoadBalanceMode to maximize TM usage [flink] via GitHub
• [jira] [Updated] (FLINK-29240) Unify the ClassLoader in StreamExecutionEnvironment and TableEnvironment Weijie Guo (Jira)
• [jira] [Updated] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream` Weijie Guo (Jira)
• Re: [PR] [FLINK-15532][rocksdb] Enable strict capacity limit for memory usage for RocksDB [flink] via GitHub
• Re: [PR] [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory. [flink] via GitHub
• [jira] [Updated] (FLINK-37589) Job submission via REST API is not thread safe Ilya Soin (Jira)
  • [jira] [Updated] (FLINK-37589) Job submission via REST API is not thread safe Ilya Soin (Jira)
• Re: [PR] [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink [flink] via GitHub
• [jira] [Updated] (FLINK-24901) Some further improvements of the pluggable shuffle framework Weijie Guo (Jira)
• [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] via GitHub
  • Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] via GitHub
  • Re: [PR] [FLINK-37375][checkpointing] Checkpoint supports the Operator to cust… [flink] via GitHub
• [jira] [Closed] (FLINK-37475) Drop ChangelogNormalize for piping from upsert source to sink Dawid Wysakowicz (Jira)
• [jira] [Updated] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory Weijie Guo (Jira)
• Re: [PR] [FLINK-33784][table] Support Configuring CatalogStoreFactory via StreamExecutionEnvironment [flink] via GitHub
• [jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error Weijie Guo (Jira)
• [jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection Weijie Guo (Jira)
• [jira] [Updated] (FLINK-30292) Better support for conversion between DataType and TypeInformation Weijie Guo (Jira)
• [jira] [Updated] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client Weijie Guo (Jira)
• [jira] [Updated] (FLINK-30821) The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-30821) The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected Weijie Guo (Jira)
• [jira] [Created] (FLINK-37528) Protobuf Format (proto3): Handle default values for optional primitive types and primitive types in one of fields Sai Sharath Dandi (Jira)
• [jira] [Commented] (FLINK-37551) Improve the state compatibility of ForStKeyeStateBackend and ForStSyncKeyeStateBackend Zakelly Lan (Jira)
• [jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen Weijie Guo (Jira)
• [PR] [FLINK-37557][bp-1.20] Fix ResolvedSchema#getPrimaryKeyIndexes [flink] via GitHub
• [jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously Weijie Guo (Jira)
• [jira] [Created] (FLINK-37538) Get Schame fail if tables.exclude contain them linqigeng (Jira)
• Re: [PR] [FLINK-37493][release] Update japicmp configuration for 2.0.0 [flink] via GitHub
• [jira] [Updated] (FLINK-24237) Consider disabling or lowering DNS caching timeout in docker image Weijie Guo (Jira)
• Re: [PR] [FLINK-29061][Table/Planner] Cleanup unused code in StringCallGen [flink] via GitHub
  • Re: [PR] [FLINK-29061][Table/Planner] Cleanup unused code in StringCallGen [flink] via GitHub
• [jira] [Updated] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb Weijie Guo (Jira)
• Re: [PR] [FLINK-26565][TABLE][TRIGGER]use later trigger for delay window when laterTrigger is not null [flink] via GitHub
  • Re: [PR] [FLINK-26565][TABLE][TRIGGER]use later trigger for delay window when laterTrigger is not null [flink] via GitHub
• [jira] [Updated] (FLINK-35688) Add materialized table develop guide docs Weijie Guo (Jira)
• Re: [PR] [FLINK-18592][Connectors/FileSystem] StreamingFileSink fails due to truncating HDFS file failure [flink] via GitHub
• [jira] [Comment Edited] (FLINK-37535) [Metrics] Add InfluxDB v3 Metrics Reporter Michael Koepf (Jira)
• [jira] [Comment Edited] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL Shengkai Fang (Jira)
• [jira] [Updated] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective Weijie Guo (Jira)
• [jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent Weijie Guo (Jira)
• Re: [PR] [Flink-15873] [cep] fix matches result not returned when existing earlier partial matches [flink] via GitHub
• [jira] [Updated] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts Weijie Guo (Jira)
• [jira] [Updated] (FLINK-14879) Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client Weijie Guo (Jira)
• [jira] [Updated] (FLINK-28516) UI is misleading when source doesn't emit watermark due to misconfigured idleness Weijie Guo (Jira)
• Re: [PR] [Flink 29627][streaming][test] Adding new test to SinkITCase.java that will test SinkV1 architecture with Cluster recovery scenario. [flink] via GitHub
  • Re: [PR] [Flink 29627][streaming][test] Adding new test to SinkITCase.java that will test SinkV1 architecture with Cluster recovery scenario. [flink] via GitHub
• [jira] [Updated] (FLINK-30399) Enable connectors to use config docs generator Weijie Guo (Jira)
• [jira] [Updated] (FLINK-27080) Enable builds for pull requests Weijie Guo (Jira)
• Re: [PR] [FLINK-16491][formats] Add compression support for ParquetAvroWriters [flink] via GitHub
  • Re: [PR] [FLINK-16491][formats] Add compression support for ParquetAvroWriters [flink] via GitHub
• [jira] [Updated] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed Weijie Guo (Jira)
• Re: [PR] [FLINK-36684][cdc-connector][mysql] Support read changelog as append only mode [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36684][cdc-connector][mysql] Support read changelog as append only mode [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-32682) Introduce option for choosing time function evaluation methods Weijie Guo (Jira)
• [jira] [Updated] (FLINK-37103) The argument lists of the method FactoryUtil.createDynamicTableSink are inconsistent. Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-37103) The argument lists of the method FactoryUtil.createDynamicTableSink are inconsistent. Weijie Guo (Jira)
• [jira] [Updated] (FLINK-14934) Remove error log statement in ES connector Weijie Guo (Jira)
• Re: [PR] [hotfix] Rename the variable `result` to `config` [flink] via GitHub
  • Re: [PR] [hotfix] Rename the variable `result` to `config` [flink] via GitHub
• [jira] [Updated] (FLINK-25350) Verify stability guarantees of annotated classes Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-25350) Verify stability guarantees of annotated classes Weijie Guo (Jira)
• Re: [PR] Add support to pass Datadog API Key as environment variable [flink] via GitHub
• [jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing Weijie Guo (Jira)
• Re: [PR] [FLINK-13194][docs] Add explicit clarification about thread-safety of state [flink] via GitHub
• [jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED Weijie Guo (Jira)
• Re: [PR] [FLINK-34620][formats][protobuf] add support of recursive schemas to PbToRowTypeUtil [flink] via GitHub
• [jira] [Updated] (FLINK-37032) Prepare Flink 2.0 Release Xintong Song (Jira)
  • [jira] [Updated] (FLINK-37032) Prepare Flink 2.0 Release Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-37550) Add 2.0 to PreviousDocs list Weijie Guo (Jira)
• [jira] [Updated] (FLINK-34612) Migrate StreamPhysicalValuesRule Weijie Guo (Jira)
• Re: [PR] [FLINK-23583][table-common] Introduce SubRowData [flink] via GitHub
• [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling [flink-connector-aws] via GitHub
• [jira] [Updated] (FLINK-36443) Flaky Test: assertEquals in PushPartitionIntoTableSourceScanRuleTest.testWithUdf ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-33402] 2 CONTINUED [flink] via GitHub
• [jira] [Updated] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer Weijie Guo (Jira)

• Earlier messages
• Later messages