epiphanous / flinkrunner

52%

master: 33%

LAST BUILD ON BRANCH v4.0.0

branch: v4.0.0

CHANGE BRANCH

x

Reset

• v4.0.0
• add-broadcast-pattern
• add-custom-bucketer
• add-kinesis-serdes
• add-percentage-aggregate
• allow-tombstones
• avro-json-file-encoder-fix
• avro-serialization-fix
• avro-support
• bug/fix-schema-reg-config
• bug/format-instant-to-string
• check-config-improvements
• clean-up-build
• dstreams
• event-serializer-fix
• feat/avro-jdbc-support
• feat/better-uuid-support
• feat/jdbc-conn-provider
• feat/timescale
• feature/add-kafka-info-headers
• feature/coverage-support
• feature/kinesis-firehose
• feature/kinesisRegistrationStrategy
• feature/map_json
• feature/parallelism
• fix-aggregates
• fix-arg-parsing
• fix-avro-file-deser-for-mapwrapper
• fix-bad-package
• fix-closed-json-file-sink-stream
• fix-confluent-avro-deserializer
• fix-droppingTable-json
• fix-elastic-transports
• fix-embeddedavroinstance
• fix-generic
• fix-keyed-serialization
• fix-kinesis-serdes
• fix-log4j-vulnerabilities
• fix-sbf
• fix/avro-deserializer-array
• fix/avro-serde
• fix/timescale-create-table
• iceberg-sink
• improve-arg-parsing
• improve-kinesis-source-config
• jdbc-integration-fixes
• kafka-src-sink-builder
• ldonoughe/test-json
• ldonoughe/testing-batch-inserts-to-snowflake
• main
• marquis-list-state
• master
• mdsol-FR
• mdsol-flinkrunner
• msdol-fr
• refactor-fromkv
• refactor-runner-factory
• release-4.4.0
• release-4.6.1
• release/4.4.0
• release/v4.5.0
• test/string-interpolation
• update-readme
• update-versions
• upgrade-flink
• v1.5.2
• v1.5.3
• v1.5.4
• v1.5.5
• v1.6.0
• v1.6.1
• v1.6.2
• v1.6.3
• v1.6.4
• v1.6.5
• v1.6.6
• v1.6.7
• v1.6.8
• v2.0.0
• v2.0.1
• v3.0.0
• v3.0.1
• v3.0.2
• v3.0.3
• v3.0.4
• v3.0.5
• v3.0.6
• v3.0.7
• v3.0.8
• v3.0.9
• v3.1.0
• v3.2.0
• v3.2.1
• v3.2.2
• v3.2.3
• v3.3.0
• v4.0.1
• v4.1.0
• v4.2.0
• v4.2.1
• v4.2.2
• v4.3.0
• v4.3.2
• v4.3.3
• v4.3.4
• v4.3.5
• v4.4.0
• v4.5.0
• v4.5.1
• v4.5.2
• v4.6.0
• v4.6.1
• v4.6.2

Build # 392

Build Type

push

travis-ci-com

Committed by web-flow

Commit Message

major refactor (#27)

* refactor to use less implicits

* begin refactor of confluent avro support

* implement serdes and upgrade flink to 1.14

* deprecated old avro code

* refactor avro registry serdes

* simplified

* allow multiple events to be generated from a single kafka key/value record

* added rabbitmq source/sink and modernized kafka src/sink, jdbc sink, elastic sink

* add property tests

* begin adding TableConfig

* cleanup the build

* clean up file source/sink

* remove incipient table api support

* refactor EnrichmentAsyncFunction api and clean up tests

* simplify runner creation and getJobConfig calling syntax

* fix BaseSpec

* refactor to simplify usage further

* small refactorings

* source/sink config improvements and readme updates

* more tests

* clean up

* fix test

* fix tests

* make schemaRegistryClient in config transient

* fix kafka configs

* default to use specific avro reader and logical type converters

* add full request support to EnrichmentAsyncFunction

* add generic key to enrichment async function; improve tests

* add dynamic topic naming from schema

* simplify confluent avro registry kafka record serialization

* fix bad import

* simplify confluent schema registry kafka deserialization

* major refactoring

* enable auto-create table on jdbc sink

* small tweaks

* rename some overridable methods for clarity

* get tests passing

* update travis dist

* make test pass on travis

* refactor async enrichment to cache Option values instead of nullable values

* refactor async enrichment test to use http instead of https

* fixed confluent dependency and updated readme

* added support for signing aws requests

* add SBF dedup filter and improved file bucketing

* fix some bugs

* fix another bugs

* enable hashmap state backend

* fix bloom filter aggregation

* fix logging bug

* move test avro files back ... (continued)

Run Details

963 of 1849 relevant lines covered (52.08%)

0.52 hits per line