-
Notifications
You must be signed in to change notification settings - Fork 13.3k
Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-35282][FLINK-35520] PyFlink Support for Apache Beam > 2.49
component=BuildSystem/CI
#24908
opened Jun 7, 2024 by
snuyanzin
Loading…
[FLINK-13258] Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator
component=TableSQL/Runtime
review=description?
#9110
opened Jul 15, 2019 by
tsreaper
Loading…
[FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics
component=TableSQL/Planner
review=description?
#10174
opened Nov 13, 2019 by
tsreaper
Loading…
[FLINK-28961][python][docs] Add the doc how to support third party connector in Python DataStream API
component=API/Python
component=Documentation
#20576
opened Aug 15, 2022 by
HuangXingBo
Loading…
[FLINK-13259] Fix typo about "access"
component=API/TypeSerializationSystem
review=description?
#9111
opened Jul 15, 2019 by
tsreaper
Loading…
[FLINK-12259][flink-clients]Improve debuggability of method invocatio…
component=CommandLineClient
review=description?
#8220
opened Apr 19, 2019 by
liyafan82
Loading…
[FLINK-7009] dogstatsd mode in statds reporter
component=Runtime/Metrics
#4188
opened Jun 26, 2017 by
dbrinegar
Loading…
[FLINK-7050][table] Add support of RFC compliant CSV parser for Table Source
component=TableSQL/Ecosystem
#4660
opened Sep 8, 2017 by
uybhatti
Loading…
[FLINK-5944] Support reading of Snappy files
component=Connectors/HadoopCompatibility
#4683
opened Sep 19, 2017 by
mlipkovich
Loading…
[FLINK-9078][E2ETests] Add test that verifies correct avro behaviour
component=Formats
component=Tests
#5762
opened Mar 26, 2018 by
florianschmidt1994
Loading…
[FLINK-9407] [hdfs connector] Support orc rolling sink writer
component=Connectors/FileSystem
#6075
opened May 25, 2018 by
rice668
Loading…
[FLINK-9598] Refine java-doc about the min pause between checkpoints
component=Runtime/Checkpointing
#6346
opened Jul 17, 2018 by
Myasuka
Loading…
[FLINK-9907] [table] Add CRC32 support
component=TableSQL/API
#6382
opened Jul 22, 2018 by
xueyumusic
Loading…
[FLINK-9931][ui] watermark display bug.
component=Runtime/WebFrontend
post-ui-rework
PRs that should be delayed until the new WebUI (#7086) was merged.
#6400
opened Jul 24, 2018 by
luojiangyu
Loading…
Fixed Flaky test in org.apache.flink.table.planner.plan.hints.stream.StateTtlHintTest#testStateTtlHintWithJoinHint
#25454
opened Oct 4, 2024 by
Mukta13
Loading…
[FLINK-10152] [table] Add reverse function in Table API and SQL
component=TableSQL/API
#6773
opened Sep 28, 2018 by
Guibo-Pan
Loading…
[FLINK-8482][DataStream] Allow users to choose from different timestamp strategies for interval join
component=API/DataStream
#6843
opened Oct 15, 2018 by
florianschmidt1994
Loading…
[FLINK-8483][DataStream] Implement and expose outer joins
component=API/DataStream
#6874
opened Oct 18, 2018 by
florianschmidt1994
Loading…
[FLINK-10604] Add REMAINDER math function supported in Table API and SQL
component=TableSQL/API
#6914
opened Oct 24, 2018 by
Tmin10
Loading…
[FLINK-10842][E2E tests] fix broken waiting loops in common.sh
component=TestInfrastructure
#7220
opened Dec 3, 2018 by
azagrebin
Loading…
[hotfix][tableApi] Fix the description information of intersect in tableApi docs
#7248
opened Dec 6, 2018 by
maqingxiang
Loading…
[FLINK-11196] Extend S3 EntropyInjector to use key replacement (instead of key removal) when creating checkpoint metadata files.
component=FileSystems
#7333
opened Dec 18, 2018 by
markcho
Loading…
[FLINK-8302] [table] Add SHIFT_LEFT and SHIFT_RIGHT
component=TableSQL/API
#6445
opened Jul 28, 2018 by
xueyumusic
Loading…
Previous Next
ProTip!
Mix and match filters to narrow down what you’re looking for.