issues  

Messages by Thread

• • [jira] [Updated] (FLINK-24125) Rethink relationship between DeclarativeSlotPool and *Bridge Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-14867) Move TextInputFormat & TextOutputFormat to flink-core Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-26963) Allow HeapBackend creation customization Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-26963) Allow HeapBackend creation customization Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23997) Improvement for SQL windowing table-valued function Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23997) Improvement for SQL windowing table-valued function Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-34134) Add tracing for restored state size and locations Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34134) Add tracing for restored state size and locations Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34134) Add tracing for restored state size and locations Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-38942) Add documentation for async python scalar function Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-38942) Add documentation for async python scalar function Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-38942) Add documentation for async python scalar function Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-26081) Update document,becasue of add maven wrapper. Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-26081) Update document,becasue of add maven wrapper. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36843) Remove deprecated method in flink-table-planner Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36843) Remove deprecated method in flink-table-planner Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36843) Remove deprecated method in flink-table-planner Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36851) Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36851) Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36851) Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-30578) Publish SBOM artifacts Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-30578) Publish SBOM artifacts Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-28071) Support missing built-in functions in Table API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-28071) Support missing built-in functions in Table API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery Yuepeng Pan (Jira) via issues
  • [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery Yuepeng Pan (Jira) via issues
  • [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level. Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level. Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-29813) Remove deprecated Curator API usages Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-29813) Remove deprecated Curator API usages Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34974) FLIP-424: Asynchronous State APIs Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34974) FLIP-424: Asynchronous State APIs Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34974) FLIP-424: Asynchronous State APIs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-32437) Determine and set correct maxParallelism for operator chains Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-32437) Determine and set correct maxParallelism for operator chains Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-26964) Notify CheckpointStrategy about checkpoint completion/abortion Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-26964) Notify CheckpointStrategy about checkpoint completion/abortion Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36881) Introduce GroupTableAggFunction in GroupTableAggregate with Async State API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36881) Introduce GroupTableAggFunction in GroupTableAggregate with Async State API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36881) Introduce GroupTableAggFunction in GroupTableAggregate with Async State API Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-34064) FLIP-417: Expose JobManagerOperatorMetrics via REST API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34064) FLIP-417: Expose JobManagerOperatorMetrics via REST API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34064) FLIP-417: Expose JobManagerOperatorMetrics via REST API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23589) Support Avro Microsecond precision Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23589) Support Avro Microsecond precision Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34004) TestingCheckpointIDCounter can easily lead to NPEs Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34004) TestingCheckpointIDCounter can easily lead to NPEs Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34004) TestingCheckpointIDCounter can easily lead to NPEs Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE Martijn Visser (Jira)
• [jira] [Updated] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-34255) FLIP-406: Reorganize State & Checkpointing & Recovery Configuration Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34255) FLIP-406: Reorganize State & Checkpointing & Recovery Configuration Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-34255) FLIP-406: Reorganize State & Checkpointing & Recovery Configuration Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-26945) Add DATE_SUB supported in SQL & Table API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-26945) Add DATE_SUB supported in SQL & Table API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23900) Migrate to ClusterActorRefProvider Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23900) Migrate to ClusterActorRefProvider Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-26968) Bump CopyOnWriteStateMap entry version before write Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-26968) Bump CopyOnWriteStateMap entry version before write Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-32181) Drop support for Maven 3.2.5 Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-32181) Drop support for Maven 3.2.5 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36882) Introduce MiniBatchGroupAggFunction in GroupAggregate with Async State API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36882) Introduce MiniBatchGroupAggFunction in GroupAggregate with Async State API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36882) Introduce MiniBatchGroupAggFunction in GroupAggregate with Async State API Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-23623) Over expression should allow to order by any fields in batch mode Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Yuepeng Pan (Jira) via issues
  • [jira] [Updated] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-20518) WebUI should escape characters in metric names Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-27603) Hive dialect supports "reload function" Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-27603) Hive dialect supports "reload function" Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-26949) Add NVL supported in SQL & Table API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-26949) Add NVL supported in SQL & Table API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-32179) Handle more repo names for automatic dist discovery Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-32179) Handle more repo names for automatic dist discovery Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-41273) Allow UNION, INTERSECT and EXCEPT on unbounded tables in the Table API Timo Theusner (Jira)
• [jira] [Updated] (FLINK-22926) IDLE FLIP-27 source should go ACTIVE when registering a new split Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22926) IDLE FLIP-27 source should go ACTIVE when registering a new split Yuepeng Pan (Jira)
• Re: [PR] [FLINK-40002][table-planner] Keep metadata column references out of physical filter push-down [flink] via GitHub
• Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] eskabetxe (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] gaborgsomogyi (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] eskabetxe (via GitHub) via issues
  • Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
• [jira] [Updated] (FLINK-22553) Improve error reporting on TM connection failures Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22553) Improve error reporting on TM connection failures Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23412) Improve sourceSink description Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23412) Improve sourceSink description Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21784) Allow HeapBackend RestoreOperation customization Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20578) Cannot create empty array using ARRAY[] Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22240) Sanity/phrasing pass for ExternalResourceUtils Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22240) Sanity/phrasing pass for ExternalResourceUtils Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23379) interval left join null value result out of order Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23379) interval left join null value result out of order Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23445) Separate data and timer connection into different channels for Python Table API operators Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23445) Separate data and timer connection into different channels for Python Table API operators Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22237) Flamegraph component calls draw method from template Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22237) Flamegraph component calls draw method from template Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22594) Report oom killed pod in k8s resource manager Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23000) Allow downloading all Flink logs from the UI Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23000) Allow downloading all Flink logs from the UI Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21649) Allow extension of CopyOnWrite state classes Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23855) Table API & SQL Configuration Not displayed on flink dashboard Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23855) Table API & SQL Configuration Not displayed on flink dashboard Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22975) Specify port or range for k8s service Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22975) Specify port or range for k8s service Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23752) Add document for using HiveSource API Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23752) Add document for using HiveSource API Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-23403) Decrease default values for heartbeat timeout and interval Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-23403) Decrease default values for heartbeat timeout and interval Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22371) Chinese grammatical error Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22371) Chinese grammatical error Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked Yuepeng Pan (Jira)

• Later messages