This is an automated email from the ASF dual-hosted git repository.
eskabetxe pushed a change to branch BAHIR-308
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git
omit 6c7b37d Update to 1.15.3
omit cc22c27 Influx DB fixing
omit 7ddf5c6 Pinot fixing V2
omit 7de10ca Pinot fixing
omit 56dff30 kudu fixing
omit 0511d92 influxdb testing
omit 65d29e2 [BAHIR-308] InfluxDB changes
omit 45808eb fix: fixed flink upgrade 1.15 causing the projectFields
method to be incompatible
omit 40a462c [BAHIR-308] Bump flink version to 1.15.1
omit 2f0d137 [BAHIR-308] Remove support for scala 2.11
add bcd0c22 prevent each element from infludb2 sink buffer from being
dropped
add 536ac65 [BAHIR-308] Remove support for scala 2.11
add c9fa6d5 [BAHIR-308] Bump flink version to 1.15.1
add 83f3bd2 fix: fixed flink upgrade 1.15 causing the projectFields
method to be incompatible
add 23d90e3 [BAHIR-308] InfluxDB changes
add 2a39c19 influxdb testing
add 4264133 kudu fixing
add 89d423f Pinot fixing
add 5477808 Pinot fixing V2
add 5f56864 Influx DB fixing
add 387cb27 Fix influxdb
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (6c7b37d)
\
N -- N -- N refs/heads/BAHIR-308 (387cb27)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../influxdb/sink/commiter/InfluxDBCommitter.java | 2 +-
.../influxdb/sink/writer/InfluxDBWriter.java | 4 +-
.../influxdb/sink2/writer/InfluxDBWriter.java | 64 ++++++++----------
.../influxdb/sink/InfluxDBSinkBuilderTest.java | 55 ++++++++--------
.../InfluxDBSinkIntegrationTestCase.java | 31 +++++----
.../writer}/InfluxDBTestSerializer.java | 2 +-
.../InfluxDBSinkIntegrationTestCase.java} | 30 ++++-----
.../writer/InfluxDBTestSerializer.java} | 5 +-
.../InfluxDBSourceIntegrationTestCase.java | 5 +-
.../reader}/InfluxDBTestDeserializer.java | 2 +-
.../influxdb/util/InfluxDBContainer.java | 76 ++--------------------
...Container.java => InfluxDBContainerCustom.java} | 51 ++++++++-------
pom.xml | 2 +-
13 files changed, 131 insertions(+), 198 deletions(-)
rename
flink-connector-influxdb2/src/test/java/org/apache/flink/streaming/connectors/influxdb/{
=> sink}/InfluxDBSinkIntegrationTestCase.java (86%)
rename
flink-connector-influxdb2/src/test/java/org/apache/flink/streaming/connectors/influxdb/{util
=> sink/writer}/InfluxDBTestSerializer.java (95%)
rename
flink-connector-influxdb2/src/test/java/org/apache/flink/streaming/connectors/influxdb/{InfluxDBSink2IntegrationTestCase.java
=> sink2/InfluxDBSinkIntegrationTestCase.java} (87%)
rename
flink-connector-influxdb2/src/test/java/org/apache/flink/streaming/connectors/influxdb/{util/InfluxDBTestSerializer2.java
=> sink2/writer/InfluxDBTestSerializer.java} (84%)
rename
flink-connector-influxdb2/src/test/java/org/apache/flink/streaming/connectors/influxdb/{
=> source}/InfluxDBSourceIntegrationTestCase.java (97%)
rename
flink-connector-influxdb2/src/test/java/org/apache/flink/streaming/connectors/influxdb/{util
=> source/reader}/InfluxDBTestDeserializer.java (94%)
copy
flink-connector-influxdb2/src/test/java/org/apache/flink/streaming/connectors/influxdb/util/{InfluxDBContainer.java
=> InfluxDBContainerCustom.java} (74%)
