ASF Git Repos - flink.git/search

2022-05-19	zhangzhengqi3	[FLINK-27174][connector/kafka] Fix checking of bootstrapServ...	commit \| commitdiff \| tree
2022-05-10	Fabian Paul	[FLINK-27487][kafka] Only forward measurable Kafka...	commit \| commitdiff \| tree
2022-05-09	Fabian Paul	[FLINK-27480][kafka] Explain possible metrics InstanceAlread...	commit \| commitdiff \| tree
2022-05-05	Fabian Paul	[FLINK-27486][tests] Fix archunit test violations in...	commit \| commitdiff \| tree
2022-05-05	Fabian Paul	[FLINK-27486][hybrid] Make hybrid source building blocks...	commit \| commitdiff \| tree
2022-05-05	Fabian Paul	[FLINK-27486][core] Mark documentation formatting tools...	commit \| commitdiff \| tree
2022-05-03	Alexander Fedulov	[FLINK-27066][tests][connectors/elasticsearch] Remove...	commit \| commitdiff \| tree
2022-05-03	Alexander Fedulov	[FLINK-27066][tests][connectors/elasticsearch] Reintroduce...	commit \| commitdiff \| tree
2022-04-28	Alexander Fedulov	[hotfix][test][formats] Detach TableCsvFormatITCase...	commit \| commitdiff \| tree
2022-04-20	snuyanzin	[hotfix][docs] Misprint in types.md	commit \| commitdiff \| tree
2022-04-07	Alexander Preuß	[FLINK-26810][connectors/elasticsearch] Use local timezone...	commit \| commitdiff \| tree
2022-03-22	Alexander Preuß	[FLINK-26638][connectors/elasticsearch] Update docs...	commit \| commitdiff \| tree
2022-03-22	Alexander Preuß	[FLINK-26638][connectors/elasticsearch] Revert Table...	commit \| commitdiff \| tree
2022-03-21	unknown	[FLINK-26642][connector/pulsar] Fix support for non...	commit \| commitdiff \| tree
2022-03-21	realdengziqi	[FLINK-26334][datastream] Modified getWindowStartWithOffset...	commit \| commitdiff \| tree
2022-03-21	Fabian Paul	[FLINK-26633][elasticsearch] Add recordSend metric...	commit \| commitdiff \| tree
2022-03-21	Fabian Paul	[hotfix][elasticsearch] Make TestEmitter#createIndexRequest...	commit \| commitdiff \| tree
2022-03-16	Fabian Paul	[FLINK-26613][streaming] Use Flink 1.13 sink committer...	commit \| commitdiff \| tree
2022-03-16	Fabian Paul	[FLINK-26613][streaming] Allow setting operator uid...	commit \| commitdiff \| tree
2022-03-16	Alexander Preuß	[FLINK-26281][connectors/elasticsearch] setting default...	commit \| commitdiff \| tree
2022-03-15	Yufan Sheng	[FLINK-26177][Connector/pulsar] Use mocked pulsar runtime...	commit \| commitdiff \| tree
2022-03-10	Jing Ge	[FLINK-26492][kinesis] deprecate numRecordsOutErrorsCounter...	commit \| commitdiff \| tree
2022-03-10	Jing Ge	[FLINK-26492][firehose] deprecate numRecordsOutErrorsCounter...	commit \| commitdiff \| tree
2022-03-10	Jing Ge	[FLINK-26492][kafka] deprecate numRecordsOutErrorsCounter...	commit \| commitdiff \| tree
2022-03-10	Jing Ge	[FLINK-26492][metric] deprecate numRecordsOutErrorsCounter...	commit \| commitdiff \| tree
2022-03-07	Jing Ge	[FLINK-26126][test] migrate KafkaWriterITCase to AssertJ	commit \| commitdiff \| tree
2022-03-07	Jing Ge	[FLINK-26126][kafka] develop record out error counter...	commit \| commitdiff \| tree
2022-03-07	Jing Ge	[FLINK-26126][kafka] use record/byte send counter metrics...	commit \| commitdiff \| tree
2022-03-07	Jing Ge	[FLINK-26126][metrics] Introduce new counter metrics...	commit \| commitdiff \| tree
2022-03-07	Fabian Paul	[FLINK-26453][clients] Prevent program configurations...	commit \| commitdiff \| tree
2022-03-02	Alexander Preuß	[FLINK-26191][connectors/elasticsearch] Revert Elasticsearch...	commit \| commitdiff \| tree
2022-03-02	Alexander Preuß	[FLINK-26387][connectors/kafka] Disable testBrokerFailure...	commit \| commitdiff \| tree
2022-03-01	Sergey	[hotfix][docs][table] Fix docs for SHA1	commit \| commitdiff \| tree
2022-02-28	Jing Ge	[FLINK-26357][avro-parquet] make AvroParquetRecordFormat...	commit \| commitdiff \| tree
2022-02-28	Jing Ge	[FLINK-26357][avro-parquet] add FLINK API annotations	commit \| commitdiff \| tree
2022-02-25	Qingsheng Ren	[FLINK-25249][connector/kafka] Use 1 broker in Kafka...	commit \| commitdiff \| tree
2022-02-25	Qingsheng Ren	[FLINK-26143][connector/kafka] Temporarily disable...	commit \| commitdiff \| tree
2022-02-25	Qingsheng Ren	[FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironm...	commit \| commitdiff \| tree
2022-02-25	Sergey Nuyanzin	[typos] Typos in PULL_REQUEST_TEMPLATE.md	commit \| commitdiff \| tree
2022-02-25	Alexander Fedulov	[FLINK-25927][docs][formats] Add DataStream documentation...	commit \| commitdiff \| tree
2022-02-25	Jing Ge	[FLINK-26186][test] Allow caller annotated with @VisibleForT...	commit \| commitdiff \| tree
2022-02-25	Jing Ge	[FLINK-26186][test] use reside in shaded package filter	commit \| commitdiff \| tree
2022-02-24	Yufei Zhang	[FLINK-26160][pulsar][doc] update the doc of setUnboundedSto...	commit \| commitdiff \| tree
2022-02-24	Yufei Zhang	[FLINK-26159][doc] add description for MAX_FETCH_RECORD...	commit \| commitdiff \| tree
2022-02-23	jinfeng	[FLINK-24571][connectors/elasticsearch] Supports a...	commit \| commitdiff \| tree
2022-02-22	Fabian Paul	[FLINK-25941][streaming] Only emit committables with...	commit \| commitdiff \| tree
2022-02-17	Alexander Preuß	[FLINK-26185] Update Elasticsearch7SinkExample to use...	commit \| commitdiff \| tree
2022-02-17	Alexander Preuß	[FLINK-26185] Update Elasticsearch6SinkExample to use...	commit \| commitdiff \| tree
2022-02-16	Jing Ge	[FLINK-25701][kafka] reduce architectural violation	commit \| commitdiff \| tree
2022-02-16	Jing Ge	[FLINK-25701][kafka] Add Flink API annotation to all...	commit \| commitdiff \| tree
2022-02-16	hongshuboy	[FLINK-25980][datastream] remove unnecessary condition	commit \| commitdiff \| tree
2022-02-16	Alexander Fedulov	[FLINK-25571] Update Elasticsearch Sink to use decomposed...	commit \| commitdiff \| tree
2022-02-16	Yufan Sheng	[FLINK-26038][connector/pulsar] Support delay message...	commit \| commitdiff \| tree
2022-02-16	Yufan Sheng	[FLINK-26026][connector/pulsar] Create unit tests for...	commit \| commitdiff \| tree
2022-02-16	Yufan Sheng	[FLINK-26025][connector/pulsar] Replace MockPulsar...	commit \| commitdiff \| tree
2022-02-16	Yufan Sheng	[FLINK-26022][connector/pulsar] Implement at-least...	commit \| commitdiff \| tree
2022-02-16	Yufan Sheng	[FLINK-26024][connector/pulsar] Create a PulsarSerialization...	commit \| commitdiff \| tree
2022-02-16	Yufan Sheng	[FLINK-26023][connector/pulsar] Create a Pulsar sink...	commit \| commitdiff \| tree
2022-02-16	Yufan Sheng	[FLINK-26021][connector/pulsar] Add the ability to...	commit \| commitdiff \| tree
2022-02-16	Yufan Sheng	[FLINK-26020][connector/pulsar] Unified Pulsar Connector...	commit \| commitdiff \| tree
2022-02-16	Yufan Sheng	[FLINK-24246][connector/pulsar] Bump PulsarClient version...	commit \| commitdiff \| tree
2022-02-15	Jing Ge	[FLINK-25906][streaming] check explicit env allowed...	commit \| commitdiff \| tree
2022-02-15	Fabian Paul	[FLINK-25574][connectors/async] Migrate AsyncSink connectors...	commit \| commitdiff \| tree
2022-02-14	Jing Ge	[hotfix][datastream] bug fix	commit \| commitdiff \| tree
2022-02-14	Jing Ge	[hotfix][datastream] move the change and restore of...	commit \| commitdiff \| tree
2022-02-14	Etienne Chauchot	[FLINK-21407][docs][formats] Remove MongoDb connector...	commit \| commitdiff \| tree
2022-02-04	Fabian Paul	[FLINK-25578][core] Graduate and deprecate unified...	commit \| commitdiff \| tree
2022-02-04	Fabian Paul	[FLINK-25725][table][tests] Use GlobalCommitter for...	commit \| commitdiff \| tree
2022-02-04	Fabian Paul	[FLINK-25726][streaming] Add Global Committer as post...	commit \| commitdiff \| tree
2022-02-04	Fabian Paul	[FLINK-25726][streaming] Check committer existence...	commit \| commitdiff \| tree
2022-02-04	Fabian Paul	[FLINK-25573][kafka] Migrate KafkaSink to SinkV2	commit \| commitdiff \| tree
2022-02-04	Fabian Paul	[FLINK-25573][table] Add SinkV2Provider to execute...	commit \| commitdiff \| tree
2022-02-03	slinkydeveloper	[hotfix][table-planner] Use jdk 8 and java time modules...	commit \| commitdiff \| tree
2022-02-03	slinkydeveloper	[hotfix][docs][connector/files] Fix directory watching...	commit \| commitdiff \| tree
2022-02-03	slinkydeveloper	[FLINK-19845][connector-files] Prune FileSystemFormatFactory	commit \| commitdiff \| tree
2022-02-03	Fabian Paul	[FLINK-25206][clients] Make prevention of configurations...	commit \| commitdiff \| tree
2022-02-02	Fabian Paul	[FLINK-25575][streaming] Switch the implementation...	commit \| commitdiff \| tree
2022-02-02	Fabian Paul	[FLINK-25575][table][test] Ignore CompactManagedTableITCase...	commit \| commitdiff \| tree
2022-02-02	Fabian Paul	[FLINK-25575][streaming] Add SinkV1Adapter that simulates...	commit \| commitdiff \| tree
2022-02-02	Fabian Paul	[FLINK-25575][streaming] Scope batch exchanges in PartitionT...	commit \| commitdiff \| tree
2022-02-02	Fabian Paul	[FLINK-25575][streaming] Expose transformations currently...	commit \| commitdiff \| tree
2022-02-02	Fabian Paul	[FLINK-25575][streaming] Add data structure to collect...	commit \| commitdiff \| tree
2022-02-01	Mika Naylor	[FLINK-25041][e2e] Improve error handling for missing...	commit \| commitdiff \| tree
2022-01-31	Etienne Chauchot	[FLINK-25771][connectors][Cassandra][test] Add a test...	commit \| commitdiff \| tree
2022-01-31	Etienne Chauchot	[FLINK-25771][connectors][Cassandra][test] Raise all...	commit \| commitdiff \| tree
2022-01-31	Etienne Chauchot	[FLINK-25147][connectors][Cassandra][test] Use parent...	commit \| commitdiff \| tree
2022-01-28	Hang Ruan	[FLINK-25753][tests] Fix KafkaTableITCase.testStartFromGroup...	commit \| commitdiff \| tree
2022-01-27	Alexander Fedulov	[FLINK-24703][connectors][format] Add CSV File System...	commit \| commitdiff \| tree
2022-01-27	Alexander Fedulov	[FLINK-24703][connectors][format] Adds CSV File System...	commit \| commitdiff \| tree
2022-01-26	martijnvisser	[FLINK-25818][Docs][Kafka] Add explanation how Kafka...	commit \| commitdiff \| tree
2022-01-26	dengziming	[hotfix] fix a typo in KafkaTestBase	commit \| commitdiff \| tree
2022-01-26	dengziming	[FLINK-25368][connectors/kafka] Substitute KafkaConsumer...	commit \| commitdiff \| tree
2022-01-25	mans2singh	[FLINK-25763][match-recognize][docs] Updated docs to...	commit \| commitdiff \| tree
2022-01-21	martijnvisser	[FLINK-20188][Connectors][Docs][FileSystem] Added documentat...	commit \| commitdiff \| tree
2022-01-21	Yufei Zhang	[FLINK-23944][test][pulsar] 1. change the Matcher to...	commit \| commitdiff \| tree
2022-01-20	Hang Ruan	[FLINK-24697][flink-connectors-kafka] add auto.offset...	commit \| commitdiff \| tree
2022-01-17	Fabian Paul	[FLINK-24858][release][docs] Recommend users to upgrade...	commit \| commitdiff \| tree
2022-01-17	Yuhao Bi	[FLINK-25589][docs][connectors] Update Chinese version...	commit \| commitdiff \| tree
2022-01-14	Arvid Heise	[FLINK-25570][streaming] Add topology extension points...	commit \| commitdiff \| tree
2022-01-14	Fabian Paul	[FLINK-25570][tests] Ignore TypeSerializer tests for...	commit \| commitdiff \| tree
next

Apache Flink

RSS Atom