Messages by Thread
-
[jira] [Resolved] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE, TIME or a lower precision returns a wrong value
Ramin Gharib (Jira) via issues
-
[jira] [Assigned] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps
Ramin Gharib (Jira) via issues
-
[jira] [Comment Edited] (FLINK-41329) Restore tests are absent for all seven Python stream ExecNodes, four of them stateful
sepuri sai krishna (Jira) via issues
-
[jira] [Comment Edited] (FLINK-41328) GROUP BY, DISTINCT, UNION and a join on a MAP column split one value into several in streaming mode
sepuri sai krishna (Jira) via issues
-
[jira] [Closed] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41335) Release Testing: Verify FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41334) SQL Gateway JSON results and the JDBC driver cannot return a UUID column
Ramin Gharib (Jira) via issues
-
[jira] [Created] (FLINK-41333) MIN, MAX and streaming COUNT(DISTINCT) reject the UUID type
Ramin Gharib (Jira) via issues
-
Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka]
Efrat19 (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-41014) Add an adaptive retry mode to the native S3 connector
Gabor Somogyi (Jira) via issues
-
[jira] [Updated] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs
Dian Fu (Jira) via issues
-
[jira] [Updated] (FLINK-41245) PyFlink mypy check fails on release-2.3: create_arrow_schema has no allow_nested parameter
Dian Fu (Jira) via issues
-
[jira] [Updated] (FLINK-41196) PyFlink pandas conversions and regular Python UDFs change TIMESTAMP_LTZ instants in non-UTC session time zones
Dian Fu (Jira) via issues
-
[jira] [Updated] (FLINK-34625) TTL doesn't seem to work in pyflink
Dian Fu (Jira) via issues
-
[jira] [Updated] (FLINK-40986) Equal named Rows can have different hash values in PyFlink
Dian Fu (Jira) via issues
-
[jira] [Updated] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches
Dian Fu (Jira) via issues
-
[jira] [Updated] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero
Dian Fu (Jira) via issues
-
[jira] [Updated] (FLINK-41327) Binary IN/NOT IN predicates compare byte arrays by identity in SEARCH point sets
ASF GitHub Bot (Jira) via issues
-
Re: [I] [Tech Debt] [python] Remove setuptools<82 constraint after apache-flink upgrades to apache-beam>=2.66.0 [flink-agents]
HsbcJone (via GitHub) via issues
-
[PR] [FLINK-41297][clients] Close the PackagedProgram of REST run-application submissions [flink]
jagath25 (via GitHub) via issues
-
Re: [I] [Bug][runtime] Durable action-state keys collide for distinct events with identical attributes [flink-agents]
HsbcJone (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-41327) Binary IN/NOT IN predicates compare byte arrays by identity in SEARCH point sets
Luo Zhengjie (Jira) via issues
-
[jira] [Commented] (FLINK-41327) Binary IN/NOT IN predicates compare byte arrays by identity in SEARCH point sets
Luo Zhengjie (Jira) via issues
-
[jira] [Updated] (FLINK-41317) [pipeline-connector/kafka] NullPointerException when serializing REPLACE events in canal-json and debezium-json
ASF GitHub Bot (Jira) via issues
-
[jira] [Commented] (FLINK-40596) Closing metric might lead to a number of test failure
Rui Fan (Jira) via issues
-
[jira] [Assigned] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink
Dian Fu (Jira) via issues
-
[jira] [Commented] (FLINK-40648) PrometheusReporter drops all metrics of a process when two metric group variables sanitise to the same label name
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED
ASF GitHub Bot (Jira) via issues
-
[jira] [Commented] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory)
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-39789) AvroSchemaConverter.convertToDataType(String) ignores local-timestamp-* and timestamp-nanos logical types, silently maps to BIGINT
Rui Fan (Jira) via issues
-
[jira] [Resolved] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-37246) Delegation Token expire after enable delegation token framework
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-37246) Delegation Token expire after enable delegation token framework
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive
Rui Fan (Jira) via issues
-
[PR] [BP-1.20][FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision [flink]
1996fanrui (via GitHub) via issues
-
[jira] [Commented] (FLINK-40477) Partial deletes fail sink NOT NULL enforcement
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-40989) MAP equality compares numeric values by reference
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-40327) ForSt async multiGet leaks a native ReadOptions per read batch
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-41216) Retracting ROW_NUMBER Top-N emits +U before -U for rows moving up, so operators keyed by the input upsert key lose rows
Rui Fan (Jira) via issues
-
[PR] [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision [flink]
1996fanrui (via GitHub) via issues
-
[jira] [Commented] (FLINK-39924) Memory fragmentation from jemalloc misconfiguration
Rui Fan (Jira) via issues
-
[jira] [Created] (FLINK-41326) chore: update JOSDK to v5.6.3
Attila Mészáros (Jira) via issues
-
[jira] [Commented] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore
Jim Hughes (Jira) via issues
-
Re: [PR] [FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink]
argoyal2212 (via GitHub) via issues
-
[PR] Bump io.opentelemetry:opentelemetry-api from 1.62.0 to 1.67.0 [flink-connector-pulsar]
dependabot[bot] (via GitHub) via issues
-
Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink]
argoyal2212 (via GitHub) via issues
-
[PR] [hotfix][ci] Run python doc checks in parallel [flink]
snuyanzin (via GitHub) via issues
-
[jira] [Comment Edited] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed
Rui Fan (Jira) via issues
-
Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink]
spuru9 (via GitHub) via issues
-
Re: [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink]
snuyanzin (via GitHub) via issues
-
[PR] Bump com.google.guava:guava from 33.4.0-jre to 33.7.1-jre [flink-kubernetes-operator]
dependabot[bot] (via GitHub) via issues
-
[PR] [FLINK-41308][runtime-web] Use nettyShuffleMemorySegments fields for the Netty Shuffle Buffers table [flink]
spuru9 (via GitHub) via issues
-
[jira] [Updated] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics
Yuepeng Pan (Jira) via issues
-
[jira] [Assigned] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1)
Samrat Deb (Jira) via issues
-
[jira] [Commented] (FLINK-40812) [Backport][1.20] Backport FLINK-38558 to release-1.20
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-38392) StreamPandasConversionTests failing
Yuepeng Pan (Jira) via issues
-
[jira] [Resolved] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE
Gustavo de Morais (Jira) via issues
-
[jira] [Updated] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-40648) PrometheusReporter drops all metrics of a process when two metric group variables sanitise to the same label name
Yuepeng Pan (Jira) via issues
-
[jira] [Created] (FLINK-41323) Add a binary encoding for a VARIANT column in the raw format
Ramin Gharib (Jira) via issues
-
Re: [PR] [FLINK-40812][state] Backport FLINK-38558 to release-1.20 [flink]
1996fanrui (via GitHub) via issues
-
[jira] [Created] (FLINK-41316) Publish built-in function pages as Markdown with an llms.txt index
Ramin Gharib (Jira) via issues
-
[PR] [FLINK-35335][network] Hold back priority buffers on subpartitions blocked by aligned barriers [flink]
spuru9 (via GitHub) via issues
-
[jira] [Commented] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable
Rui Fan (Jira) via issues
-
[jira] [Commented] (FLINK-38442) ProfilingServiceTest.testRollingDeletion is unstable
Rui Fan (Jira) via issues
-
[jira] [Updated] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e
Sergey Nuyanzin (Jira) via issues
-
[jira] [Commented] (FLINK-41321) A join on an ARRAY<MAP> key returns no rows, although the same two maps compare equal with =
sepuri sai krishna (Jira) via issues
-
Re: [PR] [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.3) [flink]
gustavodemorais (via GitHub) via issues
-
[jira] [Commented] (FLINK-41318) ASCII returns a negative number for characters outside US-ASCII
sepuri sai krishna (Jira) via issues
-
[jira] [Commented] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws
Muhammad (Jira) via issues
-
[jira] [Commented] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code
Purushottam Sinha (Jira) via issues
-
[jira] [Created] (FLINK-41315) Add the page structure for built-in function docs
Ramin Gharib (Jira) via issues
-
Re: [PR] [runtime] Fix action-state key collisions between event occurrences with identical attributes [flink-agents]
Ashfaqbs (via GitHub) via issues
-
[jira] [Updated] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code
ASF GitHub Bot (Jira) via issues
-
[jira] [Closed] (FLINK-41014) Add an adaptive retry mode to the native S3 connector
Samrat Deb (Jira) via issues
-
Re: [PR] [FLINK-41251] Validate the memory configuration when the spec sets memory [flink-kubernetes-operator]
vsantwana (via GitHub) via issues
-
[PR] [BP-2.4][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink]
eskabetxe (via GitHub) via issues
-
[jira] [Created] (FLINK-41325) COMPILE PLAN emits no state array for a temporal join or MATCH_RECOGNIZE, so their TTL cannot be configured as documented
sepuri sai krishna (Jira) via issues
-
[jira] [Commented] (FLINK-41324) COLLECT returns extra multiset entries when mini-batch is enabled, and the result varies between runs
sepuri sai krishna (Jira) via issues
-
[jira] [Created] (FLINK-41324) COLLECT returns extra multiset entries when mini-batch is enabled, and the result varies between runs
sepuri sai krishna (Jira) via issues
-
[jira] [Closed] (FLINK-40943) FileSink state written with flink-s3-fs-hadoop cannot be restored with flink-s3-fs-native (incompatible recoverable serializers, both version 1)
Samrat Deb (Jira) via issues
-
[jira] [Created] (FLINK-41317) [pipeline-connector/kafka] NullPointerException when serializing REPLACE events in canal-json and debezium-json
kim (Jira) via issues
-
[jira] [Commented] (FLINK-41322) JSON_QUOTE does not round-trip a character outside the BMP through JSON_UNQUOTE
sepuri sai krishna (Jira) via issues
-
[jira] [Created] (FLINK-41320) CAST of ARRAY, ROW or MAP to CHAR/VARCHAR(n) returns fewer than n characters and can insert a '?'
sepuri sai krishna (Jira) via issues
-
[jira] [Created] (FLINK-41319) REGEXP_INSTR disagrees with POSITION, LOCATE and INSTR for characters outside the BMP
sepuri sai krishna (Jira) via issues
-
[jira] [Created] (FLINK-41318) ASCII returns a negative number for characters outside US-ASCII
sepuri sai krishna (Jira) via issues
-
Re: [PR] [FLINK-41209][table] Run materialized table jobs in any TableEnvironment [flink]
Timm0 (via GitHub) via issues
-
[jira] [Updated] (FLINK-41274) Release Testing Verify: FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Chanhae Oh (Jira) via issues