The Wayback Machine - https://web.archive.org/web/20211222195006/https://github.com/apache/flink/pulls
Skip to content
New pull request New
771 Open 17,399 Closed
771 Open 17,399 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Milestones
Filter by milestone
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
[hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
#18183 opened Dec 22, 2021 by WTZ468071157
3
[FLINK-25341][table-planner] Add StructuredToStringCastRule to support user POJO toString implementation component=TableSQL/Planner
#18182 opened Dec 22, 2021 by slinkydeveloper
2
[FLINK-25414][metrics] Provide metrics to measure how long task has been blocked component=Runtime/Metrics component=Runtime/Task
#18181 opened Dec 22, 2021 by pnowojski
2
[hotfix][doc] Fix ambiguous 'Not that' word as 'Note that'
#18180 opened Dec 22, 2021 by hackergin
9
[FLINK-8518][Table SQL / API] Add support for extract Epoch component=API/TableSQL
#18179 opened Dec 22, 2021 by snuyanzin
4
[FLINK-5080][connectors/cassandra] Cassandra connector ignores saveAsync result onSuccess. component=Connectors/Cassandra
#18178 opened Dec 22, 2021 by RocMarshal
2
[hotfix][connector-files][connector-hive] Move Hive specific configs out of FileSystemConnectorOptions
#18177 opened Dec 22, 2021 by slinkydeveloper
3
[FLINK-20286][connector-files] Support directory watching in filesystem table source component=Connectors/FileSystem component=TableSQL/Ecosystem
#18176 opened Dec 22, 2021 by slinkydeveloper
3
Update generating_watermarks.md
#18175 opened Dec 22, 2021 by wangzhuoz
3
[FLINK-23687][table-planner] Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys component=TableSQL/Planner
#18174 opened Dec 22, 2021 by beyond1920
2
[FLINK-25407][network] Fix the deadlock issue caused by LocalBufferPool#reserveSegments component=Runtime/Network
#18173 opened Dec 22, 2021 by wsry
5
[hotfix][doc]update doc variable name reference error
#18172 opened Dec 22, 2021 by sky-walking
4
[hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
#18171 opened Dec 22, 2021 by WTZ468071157
6
[Flink-24912][state-processor-api]Migrate State Processor API to DataStream API component=API/StateProcessor
#18170 opened Dec 21, 2021 by qinjunjerry
3
add shutdown hook
#18169 opened Dec 21, 2021 by metaswirl • Draft
2
[FLINK-25375] [BP-1.13] Update log4j2 dependency to 2.17.0 to address component=<none>
#18168 opened Dec 21, 2021 by knaufk
4
[FLINK-25375] [BP-1.14] Update log4j2 dependency to 2.17.0 to address component=<none>
#18167 opened Dec 21, 2021 by knaufk
4
[FLINK-25375] [BP-1.12] Update log4j2 dependency to 2.17.0 to address component=<none>
#18166 opened Dec 21, 2021 by knaufk
4
[FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat… component=Connectors/Kinesis component=Documentation
#18165 opened Dec 21, 2021 by CrynetLogistics
15
[FLINK-25404] Let blob.storage.directory default to <WORKING_DIR>/blobStorage component=Runtime/Coordination
#18164 opened Dec 21, 2021 by tillrohrmann
2
[FLINK-25187][table-planner] Apply padding when CASTing to BINARY(<length>) component=<none>
#18162 opened Dec 21, 2021 by matriv • Changes requested
8
[FLINK-21186][network] Wrap IOException in UncheckedIOException in RecordWriterOutput component=Runtime/Task
#18159 opened Dec 21, 2021 by pnowojski
2
[FLINK-25398] Show complete stacktrace when requesting thread dump component=<none>
#18158 opened Dec 21, 2021 by zuston
2
[FLINK-17808] Rename checkpoint meta file to "_metadata" until it has… component=Runtime/Checkpointing
#18157 opened Dec 21, 2021 by zuston • Draft
3
[hotfix][connectors][docs] Use big M letters for month in date format
#18155 opened Dec 20, 2021 by snuyanzin
3
ProTip! Filter pull requests by the default branch with base:master.