-
Notifications
You must be signed in to change notification settings - Fork 13.7k
Insights: apache/flink
Overview
-
0 Active issues
-
- 3 Merged pull requests
- 11 Open pull requests
- 0 Closed issues
- 0 New issues
Could not load contribution data
Please try again later
3 Pull requests merged by 3 people
-
[FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging
#26803 merged
Jul 23, 2025 -
[FLINK-38114][runtime] Allow asynchronous offloading of TaskRestore
#26821 merged
Jul 23, 2025 -
[hotfix] ELEMENT should throw TableRuntimeException
#26719 merged
Jul 22, 2025
11 Pull requests opened by 8 people
-
[FLINK-32695] [Tests] Replace NonSerializableTupleSource with DataGeneratorSource V2 API
#26818 opened
Jul 22, 2025 -
[FLINK-32695] [Tests] Migrate CoGroupJoinITCase new Source/Sink V2
#26819 opened
Jul 22, 2025 -
[hotfix][runtime] Fix typo in methods/parameters naming for ResourceProfileInfo.java
#26820 opened
Jul 22, 2025 -
[FLINK-32695] [Tests] Removed SourceFunction Dependency from YarnTestCacheJob.
#26822 opened
Jul 23, 2025 -
[FLINK-38135][table] Fix call to non-existent method for RAW type hashing
#26823 opened
Jul 23, 2025 -
[FLINK-38136][table] Add restore tests for PTFs
#26825 opened
Jul 23, 2025 -
[FLINK-38138] Fix OOB error in ColumnarArrayData
#26826 opened
Jul 23, 2025 -
[FLINK-35855][table] Upgrade Calcite to 1.36.0
#26827 opened
Jul 23, 2025 -
[FLINK-32695] [Tests] Migrated SimpleStringGenerator to DataGeneratorSource
#26828 opened
Jul 24, 2025 -
[FLINK-38093][k8s] Bump Fabric8 version to 7.3.1
#26829 opened
Jul 24, 2025 -
[FLINK-38140] Changes AsyncScalarFunction config from buffer-capacity to max-concurrent-operations
#26830 opened
Jul 24, 2025
110 Unresolved conversations
Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.
-
[FLINK-37914][table] Add built-in OBJECT_UPDATE function
#26806 commented on
Jul 24, 2025 • 17 new comments -
[FLINK-37865] Adds documentation for AsyncTableFunction
#26611 commented on
Jul 25, 2025 • 10 new comments -
[FLINK-38109] [flink-runtime] Fix BlobClient address when bindhost is set
#26811 commented on
Jul 24, 2025 • 3 new comments -
[FLINK-34094] Adds documentation for AsyncScalarFunction
#26610 commented on
Jul 25, 2025 • 1 new comment -
[FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN
#26809 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Fix invalid comments in Committer
#26578 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend
#26538 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37730][rest] Add client method for getting JM exception history
#26525 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37746] Added serialVersionUID in MapTypeInfo class
#26515 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source
#26514 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37722] Eliminate redundant field initialization of PojoSerializer
#26513 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Avoid duplicate operation !
#26512 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-36659][docs] Update Kafka connector docs for 4.0.0
#26501 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph
#26500 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot
#26498 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37711] Remove unused getJobGraph from PipelineExecutorUtils
#26493 commented on
Jul 23, 2025 • 0 new comments -
[hotfix] Rename SessionDispatcherFactory to DefaultDispatcherFactory
#26490 commented on
Jul 23, 2025 • 0 new comments -
[FLINK-37308] Support pauseOrResumeSplits in HybridSource
#26483 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37698] Rename fromSchedulerNg to fromWithinExecutionGraph
#26482 commented on
Jul 23, 2025 • 0 new comments -
[FLINK-37689] Improve the comments and variable names for TaskMailbox
#26469 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Avoid invalid thread for state reader
#26465 commented on
Jul 25, 2025 • 0 new comments -
[FLINK-37521][table] Implement Proc/RowTimeIntervalJoin with async state
#26463 commented on
Jul 25, 2025 • 0 new comments -
[FLINK-37666]: Address CWE-378: Creation of Temporary File With Insec…
#26450 commented on
Jul 25, 2025 • 0 new comments -
[FLINK-37661] Remove Kryo serializer reference data from version 1.x
#26444 commented on
Jul 25, 2025 • 0 new comments -
[FLINK-37655][runtime] Convert WindowStagger into an interface
#26441 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-35466][table] Implement star expansion in function calls in SE…
#26438 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-35571][test] Can pass global test
#26431 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Rename loadJarFile to checkJarFile
#26427 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37637] Avoid dead lock for Configuration's addAll
#26426 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Remove the redundant config for execution target
#26425 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-38044][runtime-web] update angular to v20
#26805 commented on
Jul 23, 2025 • 0 new comments -
[FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL
#26802 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-38044][runtime-web] update angular to v19
#26801 commented on
Jul 24, 2025 • 0 new comments -
Add Kafka-to-Kafka SQL Example to Documentation
#26789 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-38089] Avoid pushing down non-deterministic filter in FILTER_RULES
#26783 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage
#26781 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.
#26777 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception
#26776 commented on
Jul 24, 2025 • 0 new comments -
[hotfix][docs] Update build documentation to require Java 17
#26773 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Adds Override annotation
#26772 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-38050][UI] Correct Flink UI Dropdown Width
#26768 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-38057][runtime] Fix the error value between getting and using idleStartTime in source reader metric group
#26761 commented on
Jul 24, 2025 • 0 new comments -
Update nightly-trigger.yml
#26754 commented on
Jul 24, 2025 • 0 new comments -
Enhance Javadoc documentation for WordCount Tokenizer class
#26751 commented on
Jul 24, 2025 • 0 new comments -
Add input validation to WordCount Tokenizer for robustness
#26750 commented on
Jul 24, 2025 • 0 new comments -
Use isEmpty() instead of length() > 0 in WordCount Tokenizer
#26749 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-36540][Runtime] Add Support for Hadoop Caller Context when using Flink to operate hdfs.
#26681 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function
#26667 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry
#26662 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend
#26651 commented on
Jul 24, 2025 • 0 new comments -
Fix documentation issue regarding to createTemporalTableFunction params
#26645 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader
#26640 commented on
Jul 24, 2025 • 0 new comments -
[hotfix]Adds Override annotation
#26604 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37840] [table] Row writer should honor null uncompact BigDecimal and Timestamp
#26594 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37827][table] Fix use `SHOW CREATE TABLE` for MATERIALIZED_TABLE
#26584 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Unify the name for the collection of SlotOffer with slotOffers
#26418 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37162][hotfix][docs] Update some inaccurate descriptions.
#26223 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java`
#26219 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese
#26196 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37329][table-planner] Skip Source Stats Collection When table.optimizer.source.report-statistics-enabled is False
#26162 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37315][table-planner] Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type
#26155 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37245] Prevent masking null values in BinaryRowData
#26100 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-31275] extend lineage listener with QueryOperationEvent
#26089 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors
#26029 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37121][docs] Fix syntax and examples in create table statement doc
#25982 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37088][k8s]support flink applicaton taskmanager log mounting
#25944 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37593][table] Add some Reduce Expression Rules
#25825 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-36664][Window]Window with offset need deal offset when cal nextTriggerWatermark.
#25629 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-30284][flink-metrics] Adding datacenter url property to datadog
#25592 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-36161][docs]Update Integration Test Example with Sink API.
#25590 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module
#25528 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-33391][runtime] Support tasks balancing at TM level for Adaptive Scheduler.
#25517 commented on
Jul 22, 2025 • 0 new comments -
[FLINK-33390][runtime] Support slot balancing at TM level for Adaptive Scheduler
#25510 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler
#25504 commented on
Jul 24, 2025 • 0 new comments -
add array aggregate function
#25275 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-34440][formats][protobuf-confluent] Protobuf confluent dynamic format
#25114 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions
#24826 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-34587][table] Introduce MODE aggregate function
#24443 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-33449][table]Support array_contains_seq function
#23656 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-30284][flink-metrics] Modify configuration of DataDog http reporter url.
#23610 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-32738][formats] PROTOBUF format supports projection push down
#23323 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] [docs] fix scala code
#21760 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] [docs] fix link URL to DataStream operators
#21285 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Rename registeredSlots to allocatedSlots
#26417 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37618][table-planner] Fix PTFs INTERVAL argument
#26410 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37541][table-planner] Deprecate getTargetColumns in DynamicTableSink.Context
#26381 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37581] Avoid duplicate calculation for total Flink memory
#26373 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Simplify the calling on addShutdownHook
#26363 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Rename prefix to tag for FileChannelManagerImpl
#26362 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37546] Use DefaultInstantiatorStrategy for FlinkScalaKryoInstantiator
#26357 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37549][table][docs]: Fix some scala and markdown syntax errors in tableApi page
#26341 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] change bytesReceivedPerInterface to AtomicLongArray for thread safety
#26332 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37375][checkpointing] Checkpoint supports the Operator to cust…
#26330 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37525] Introduce a overload findModuleFactory to improve the performance of installModules
#26329 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37522][docs] Add description for the config about file system connection limit
#26326 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] Correct the comments for FlinkSecurityManager
#26325 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows
#26319 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37502][docs] Translate documentation for Disaggregated State Management into Chinese
#26312 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37501][runtime/web] Fix incorrect job ID in url for logs in history server
#26311 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-36245][FOLLOWUP] Remove the @Deprecated for ArrowSourceFunction and SinkFunction
#26297 commented on
Jul 24, 2025 • 0 new comments -
Aec pr for diff
#26288 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37443] Add returns() method to DataStream V2 API for specifying output types with lambda expressions
#26284 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37441] Rename `factoryHierarchy` to `typeHierarchy` for `TypeExtractor`
#26278 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37440] Fix the bug that parallelism.default do not always adopts 1 as the default value.
#26277 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37431]We should use guava Lists instead of curator shade Lists…
#26263 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37427] Fix incorrect NPE message in StandaloneHaServices constructor
#26258 commented on
Jul 24, 2025 • 0 new comments -
[hotfix] make previousCpuTicks and previousProcCpuTicks volatile to increase visibility for all threads
#26257 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37422][docs] Fix typo in streaming analytics zh document
#26249 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-37403] Convert interval join to regular join for updating source
#26230 commented on
Jul 24, 2025 • 0 new comments -
[FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire
#26229 commented on
Jul 24, 2025 • 0 new comments