Open Hub
Black Duck Open Hub

 Settings |  Report Duplicate

9
I Use This!
Very High Activity

Commits : Listings

Analyzed about 16 hours ago. based on code collected 2 days ago.
Apr 14, 2023 — Apr 14, 2024
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
[FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework
Zakelly
More... 5 days ago
[hotfix][doc] Generate and use docs of RpcOptions instead of AkkaOptions (#24629)
Zakelly
More... 5 days ago
[FLINK-35015][formats] allow passing hadoop config into parquet reader (#24623)
Peter Huang
More... 6 days ago
[FLINK-35023][tests] Use surefire.module.config in yarn-test
Ryan Skraba
More... 6 days ago
[FLINK-34250][docs] add new option for avro format docs
Zhenqiu Huang
More... 6 days ago
[FLINK-35069][API/DataStream]ContinuousProcessingTimeTrigger avoids registering timers at the end of the window
Jinzhong Li
More... 7 days ago
fixup! [FLINK-19010][metric] Introduce subtask level restore metric
Piotr Nowojski
More... 7 days ago
[FLINK-28440][State/changelog] Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization
fredia
More... 7 days ago
[FLINK-34649][table] Migrate PushFilterIntoLegacyTableSourceScanRule to java
Jacky Lau
More... 8 days ago
[FLINK-34161][table] Migration of RewriteMinusAllRule to java
Sergey Nuyanzin
More... 8 days ago
[FLINK-34556][table] Migrate EnumerableToLogicalTableScan to java
Jacky Lau
More... 8 days ago
[FLINK-34159][table] Migrate ConstantRankNumberColumnRemoveRule to java
Sergey Nuyanzin
More... 8 days ago
[FLINK-34162][table] Migrate LogicalUnnestRule to java
Sergey Nuyanzin
More... 8 days ago
[FLINK-35044][state] Init flink-statebackend-forst module
Hangxiang Yu
More... 8 days ago
[FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0
lincoln lee
More... 9 days ago
[FLINK-34986][Runtime/State] More tests for reference counting of ContextStateFutureImpl
Zakelly
More... 9 days ago
[FLINK-24939][table] Support `SHOW CREATE CATALOG` syntax
Yubin Li
More... 9 days ago
[FLINK-35011][tests] Change MockDeserializationSchema's visibility back to public to prevent compilation failure in external connectors
Jiabao Sun
More... 10 days ago
[FLINK-34657] add lineage provider API (#24619)
Peter Huang
More... 11 days ago
[FLINK-35021] AggregateQueryOperations produces wrong asSerializableString representation (#24624)
Dawid Wysakowicz
More... 11 days ago
[hotfix] Log Job ID when task is failed externally
Roman Khachatryan
More... 11 days ago
[FLINK-34025] Add data skew metric endpoint and UI
Emre Kartoglu
More... 12 days ago
[FLINK-35000][build] Updates link to test code convention in pull request template
Matthias Pohl
More... 13 days ago
[FLINK-34986][Runtime/State] Basic implementation of AEC, RecordContext and reference counting
Zakelly
More... 13 days ago
[FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner
Xuyang
More... 13 days ago
[hotfix] Log JobID in checkpoint abort message if available
Roman Khachatryan
More... 13 days ago
[FLINK-34994][tests] Ignore unknown task checkpoint confirmation log in JobIDLoggingITCase
Roman Khachatryan
More... 13 days ago
[FLINK-34988][build] Fix the reflection issue of ExecutionEnvironmentImpl for JDK17
Weijie Guo
More... 13 days ago
[FLINK-34955] Upgrade commons-compress to 1.26.0. (#24580)
slfan1989
More... 14 days ago
[FLINK-35065][metrics] Add numFiredTimers and numFiredTimersPerSecond
Piotr Nowojski
More... 14 days ago