Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / apache/flink issues and pull requests

#15033 - [FLINK-19396][Connectors/Kafka]fix properties type cast error

Pull Request - State: closed - Opened by zhangmeng0426 over 3 years ago - 3 comments
Labels: review=description?, component=Connectors/Kafka

#14588 - [FLINK-20899][table-planner-blink] Fix ClassCastException when calculating cost in HepPlanner

Pull Request - State: open - Opened by godfreyhe almost 4 years ago - 3 comments
Labels: review=description?, component=TableSQL/Planner

#14588 - [FLINK-20899][table-planner-blink] Fix ClassCastException when calculating cost in HepPlanner

Pull Request - State: open - Opened by godfreyhe almost 4 years ago - 3 comments
Labels: review=description?, component=TableSQL/Planner

#14531 - [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disable for bounded mode

Pull Request - State: closed - Opened by xiaoHoly almost 4 years ago - 18 comments
Labels: review=description?, component=Connectors/Kafka

#14364 - [FLINK-20473][web]when get metrics option, its hard to see the full name unless u choosed

Pull Request - State: closed - Opened by zlzhang0122 almost 4 years ago - 3 comments
Labels: review=description?, component=Runtime/WebFrontend

#14291 - [FLINK-20431][connector/kafka] Fix the offsets commit in KafkaSourceReader when the SplitFetcher shuts down.

Pull Request - State: closed - Opened by becketqin almost 4 years ago - 3 comments
Labels: review=description?, component=Connectors/Kafka

#13890 - [FLINK-19931] Do not emit intermediate results for reduce operation BATCH execution mode

Pull Request - State: closed - Opened by dawidwys about 4 years ago - 2 comments
Labels: review=description?, component=API/DataStream

#13470 - [FLINK-19396][Connectors/Kafka]fix properties type cast error

Pull Request - State: closed - Opened by zhangmeng0426 about 4 years ago - 7 comments
Labels: review=description?, component=Connectors/Kafka

#13377 - [FLINK-18592] bugfix for StreamingFileSink

Pull Request - State: open - Opened by wangjian2019 about 4 years ago - 7 comments
Labels: review=description?, component=Connectors/FileSystem

#13118 - [FLINK-18729][Connectors / Kafka] Make flink streaming kafka producer auto discovery partition

Pull Request - State: closed - Opened by shengjk over 4 years ago - 4 comments
Labels: review=description?, component=Connectors/Kafka

#12754 - [FLINK-5717][streaming] Fix NPE on SessionWindows with ContinuousProc…

Pull Request - State: closed - Opened by wanglijie95 over 4 years ago - 9 comments
Labels: review=description?, component=API/DataStream

#12568 - [FLINK-18231] fix kafka connector the same quanlified class name conf…

Pull Request - State: closed - Opened by liuyongvs over 4 years ago - 4 comments
Labels: review=description?, component=Connectors/Kafka

#12428 - [FLINK-18049] the AvroRowDeserializationSchema can not read the avro …

Pull Request - State: open - Opened by openinx over 4 years ago - 2 comments
Labels: review=description?, component=Formats

#12356 - [FLINK-17916][API] Provide API to separate KafkaShuffle's Producer and Consumer to different environments

Pull Request - State: closed - Opened by curcur over 4 years ago - 3 comments
Labels: review=description?, component=API/DataStream, component=Connectors/Kafka

#12289 - [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

Pull Request - State: closed - Opened by cyq89051127 over 4 years ago - 3 comments
Labels: review=description?, component=Connectors/HBase

#12286 - [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

Pull Request - State: closed - Opened by becketqin over 4 years ago - 6 comments
Labels: review=description?, component=Tests, component=Connectors/Kafka

#11968 - [FLINK-12675][Connectors/Kafka] Event time synchronization in Kafka consumer

Pull Request - State: closed - Opened by akshay-aggarwal over 4 years ago - 3 comments
Labels: review=description?, component=Connectors/Kafka

#11715 - [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

Pull Request - State: closed - Opened by zhengcanbin over 4 years ago - 5 comments
Labels: review=description?, component=Deployment/Kubernetes

#11535 - [FLINK-16175][table sql/ api][WIP]Add config option to switch case sensitive for column names in SQL

Pull Request - State: closed - Opened by leonardBang over 4 years ago - 2 comments
Labels: review=description?, component=TableSQL/API

#11431 - [FLINK-16482][Connectors / Kafka]Flink Job throw CloseException when …

Pull Request - State: closed - Opened by ghkang98 over 4 years ago - 4 comments
Labels: review=description?, component=Connectors/Kafka

#10905 - run e2e test for pr 15637

Pull Request - State: closed - Opened by klion26 almost 5 years ago - 5 comments
Labels: review=description?

#10354 - [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource

Pull Request - State: closed - Opened by fangpengcheng95 almost 5 years ago - 7 comments
Labels: review=description?, component=Connectors/Kafka

#10344 - [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

Pull Request - State: closed - Opened by klion26 almost 5 years ago - 12 comments
Labels: review=description?, component=Runtime/StateBackends, component=Runtime/REST

#10344 - [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

Pull Request - State: closed - Opened by klion26 almost 5 years ago - 12 comments
Labels: review=description?, component=Runtime/StateBackends, component=Runtime/REST

#9388 - [FLINK-13230] [pubsub] Add retry mechanism to acknowledging pubsub me…

Pull Request - State: closed - Opened by Xeli over 5 years ago - 5 comments
Labels: review=description?, component=Connectors/GoogleCloudPubSub

#9224 - [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc…

Pull Request - State: closed - Opened by becketqin over 5 years ago - 7 comments
Labels: review=description?, component=Connectors/Kafka

#8532 - [FLINK-12541][REST] Support to submit Python Table API jobs via REST API

Pull Request - State: open - Opened by dianfu over 5 years ago - 25 comments
Labels: review=description?, component=API/Python, component=Runtime/REST

#8193 - [hotfix] load globalConfiguration from configurationDir

Pull Request - State: closed - Opened by Tom-Goong over 5 years ago - 1 comment
Labels: review=description?

#8193 - [hotfix] load globalConfiguration from configurationDir

Pull Request - State: closed - Opened by Tom-Goong over 5 years ago - 1 comment
Labels: review=description?

#8146 - [FLINK-11799][Connectors]Make KryoSerializer aware of exceptions occu…

Pull Request - State: open - Opened by liyafan82 over 5 years ago - 2 comments
Labels: review=description?

#7013 - [FLINK-5601][Checkpointing] Watermark checkpointing

Pull Request - State: open - Opened by Jiayi-Liao about 6 years ago - 5 comments
Labels: component=Runtime/Checkpointing

#6571 - [FLINK-10119] [table] Add failure handlers for JsonRowDeserializationSchema

Pull Request - State: open - Opened by Jiayi-Liao over 6 years ago - 2 comments
Labels: component=Formats

#5639 - [FLINK-8862] [HBase] Support HBase snapshot read

Pull Request - State: closed - Opened by neoremind over 6 years ago - 5 comments
Labels: component=Connectors/HBase