[jira] [Commented] (BAHIR-324) JobManager created a kuduReader that was not closed, resulting in an increase in server handles
[
https://issues.apache.org/jira/browse/BAHIR-324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727616#comment-17727616
]
ASF subversion and git services commented on BAHIR-324:
---
Commit 4a8f60f03f7caeb5421c7c88fa34a3ba419b61ee in bahir-flink's branch
refs/heads/master from Shimin Huang
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=4a8f60f ]
[BAHIR-324] Closing KuduReader at JobManager
> JobManager created a kuduReader that was not closed, resulting in an increase
> in server handles
>
>
> Key: BAHIR-324
> URL: https://issues.apache.org/jira/browse/BAHIR-324
> Project: Bahir
> Issue Type: Bug
> Components: Flink Streaming Connectors
>Affects Versions: Flink-1.1.0
>Reporter: ShiminHuang
>Assignee: ShiminHuang
>Priority: Critical
> Fix For: Flink-1.2.0
>
> Attachments: image-2023-05-30-15-03-38-388.png,
> image-2023-05-30-15-04-47-387.png, image-2023-05-30-15-05-33-472.png,
> image-2023-05-30-15-06-16-063.png, image-2023-05-30-15-25-01-115.png
>
> Original Estimate: 1h
> Remaining Estimate: 1h
>
> h1. Problem
> {quote}When JobManager starts, the ExecutionJobVertex constructor calls the
> AbstractKuduInputFormat#createInputSplits method, Causes the KuduReader
> object to create the KuduClient and KuduSession objects, but
> ExecutionJobVertex does not call the Kudureader #close() method with the
> display, causing the Kudu-related handle to remain open after the Flink task
> is closed. As a result, the number of server handles increases with the
> number of Flink tasks. As a result, the entire server becomes
> unavailable{quote}
> h1. Code
> *ExecutionJobVertex#constructor*
> !image-2023-05-30-15-03-38-388.png!
> {*}AbstractKuduInputFormat#createInputSplits{*}{*}{*}
> *!image-2023-05-30-15-04-47-387.png!*
> {*}AbstractKuduInputFormat{*}{*}#startKuduReader{*}
> {*}!image-2023-05-30-15-06-16-063.png!{*}{*}{*}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (BAHIR-285) flink-connector support SREM command
[ https://issues.apache.org/jira/browse/BAHIR-285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727611#comment-17727611 ] ASF subversion and git services commented on BAHIR-285: --- Commit 3744457437ef74696747911897bb746dc2dde6c9 in bahir-flink's branch refs/heads/master from Hyeonho Kim [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=3744457 ] [BAHIR-285] Redis: fix typo error in log message > flink-connector support SREM command > > > Key: BAHIR-285 > URL: https://issues.apache.org/jira/browse/BAHIR-285 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: Ethan Wang >Assignee: Hyeonho Kim >Priority: Critical > Fix For: Flink-1.2.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-285) flink-connector support SREM command
[ https://issues.apache.org/jira/browse/BAHIR-285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727609#comment-17727609 ] ASF subversion and git services commented on BAHIR-285: --- Commit cd8f61e2808d9e62650632e5e1ce5a38843ef346 in bahir-flink's branch refs/heads/master from Hyeonho Kim [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=cd8f61e ] [BAHIR-285] Redis: add srem command (#164) > flink-connector support SREM command > > > Key: BAHIR-285 > URL: https://issues.apache.org/jira/browse/BAHIR-285 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: Ethan Wang >Priority: Critical > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-201) Redis connector flink should support the HDEL command
[ https://issues.apache.org/jira/browse/BAHIR-201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727608#comment-17727608 ] ASF subversion and git services commented on BAHIR-201: --- Commit a03fa8c1c9320ff5b729bf75c2717c0e832fa5f1 in bahir-flink's branch refs/heads/master from Hyeonho Kim [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=a03fa8c ] [BAHIR-201] Redis: add hdel command > Redis connector flink should support the HDEL command > - > > Key: BAHIR-201 > URL: https://issues.apache.org/jira/browse/BAHIR-201 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: David Sharer >Assignee: Hyeonho Kim >Priority: Major > Original Estimate: 3h > Remaining Estimate: 3h > > Right now the flink streaming connector for Redis supports the HSET command > for HASH data types, but it does not support the HDEL command. This > improvement would be adding support for performing HDEL operations on the > HASH. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720941#comment-17720941 ] ASF subversion and git services commented on BAHIR-308: --- Commit 06fe56a73540c100f8699d2af29e396330452d95 in bahir-flink's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=06fe56a ] [BAHIR-308] Bump flink version to 1.15.3 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720942#comment-17720942 ] ASF subversion and git services commented on BAHIR-308: --- Commit 5f287b9abe1025dae55d3e8179c34cebafdaccb6 in bahir-flink's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=5f287b9 ] [BAHIR-308] Bump flink version to 1.16.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720943#comment-17720943 ] ASF subversion and git services commented on BAHIR-308: --- Commit aa0f5b1f95d9312f23e4c17322dc179f58dc9e10 in bahir-flink's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=aa0f5b1 ] [BAHIR-308] Bump flink version to 1.17.0 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720944#comment-17720944 ] ASF subversion and git services commented on BAHIR-308: --- Commit 176242c9d10d8a67a0f773dc61235b96b26e3c44 in bahir-flink's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=176242c ] [BAHIR-308] Remove scala prefix where we can > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720940#comment-17720940 ] ASF subversion and git services commented on BAHIR-308: --- Commit 017d4181987d1956b47f1dd56804c82a3e673d5b in bahir-flink's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=017d418 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707241#comment-17707241 ] ASF subversion and git services commented on BAHIR-308: --- Commit ab7b3569c2bc8829fc42bb468156aea48c2e1c67 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ab7b356 ] [BAHIR-308] Remove scala prefix where we can > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706317#comment-17706317 ] ASF subversion and git services commented on BAHIR-308: --- Commit 871f10442e0a53cf5860ff873e1beba91cf457a7 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=871f104 ] [BAHIR-308] Bump flink version to 1.17.0 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706324#comment-17706324 ] ASF subversion and git services commented on BAHIR-308: --- Commit 2254ea09380e73b53fb8c15098018abb204c552f in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=2254ea0 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706326#comment-17706326 ] ASF subversion and git services commented on BAHIR-308: --- Commit ac1cf6a234120b1ef9797b16c14c14fa46fe4ada in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ac1cf6a ] [BAHIR-308] Bump flink version to 1.16.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706328#comment-17706328 ] ASF subversion and git services commented on BAHIR-308: --- Commit a84533e8ae0cce0e89608b041aedfebc2db5d619 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=a84533e ] [BAHIR-308] Remove scala prefix where we can > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706316#comment-17706316 ] ASF subversion and git services commented on BAHIR-308: --- Commit ac1cf6a234120b1ef9797b16c14c14fa46fe4ada in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ac1cf6a ] [BAHIR-308] Bump flink version to 1.16.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706325#comment-17706325 ] ASF subversion and git services commented on BAHIR-308: --- Commit 380c746fa55292f11c2a397cc1fcb2a9c3c6ad96 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=380c746 ] [BAHIR-308] Bump flink version to 1.15.3 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706322#comment-17706322 ] ASF subversion and git services commented on BAHIR-308: --- Commit 871f10442e0a53cf5860ff873e1beba91cf457a7 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=871f104 ] [BAHIR-308] Bump flink version to 1.17.0 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706321#comment-17706321 ] ASF subversion and git services commented on BAHIR-308: --- Commit ac1cf6a234120b1ef9797b16c14c14fa46fe4ada in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ac1cf6a ] [BAHIR-308] Bump flink version to 1.16.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706318#comment-17706318 ] ASF subversion and git services commented on BAHIR-308: --- Commit a84533e8ae0cce0e89608b041aedfebc2db5d619 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=a84533e ] [BAHIR-308] Remove scala prefix where we can > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706323#comment-17706323 ] ASF subversion and git services commented on BAHIR-308: --- Commit a84533e8ae0cce0e89608b041aedfebc2db5d619 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=a84533e ] [BAHIR-308] Remove scala prefix where we can > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706327#comment-17706327 ] ASF subversion and git services commented on BAHIR-308: --- Commit 871f10442e0a53cf5860ff873e1beba91cf457a7 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=871f104 ] [BAHIR-308] Bump flink version to 1.17.0 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706320#comment-17706320 ] ASF subversion and git services commented on BAHIR-308: --- Commit 380c746fa55292f11c2a397cc1fcb2a9c3c6ad96 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=380c746 ] [BAHIR-308] Bump flink version to 1.15.3 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706315#comment-17706315 ] ASF subversion and git services commented on BAHIR-308: --- Commit 380c746fa55292f11c2a397cc1fcb2a9c3c6ad96 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=380c746 ] [BAHIR-308] Bump flink version to 1.15.3 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706319#comment-17706319 ] ASF subversion and git services commented on BAHIR-308: --- Commit 2254ea09380e73b53fb8c15098018abb204c552f in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=2254ea0 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706314#comment-17706314 ] ASF subversion and git services commented on BAHIR-308: --- Commit 2254ea09380e73b53fb8c15098018abb204c552f in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=2254ea0 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704217#comment-17704217 ] ASF subversion and git services commented on BAHIR-308: --- Commit a84533e8ae0cce0e89608b041aedfebc2db5d619 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=a84533e ] [BAHIR-308] Remove scala prefix where we can > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704186#comment-17704186 ] ASF subversion and git services commented on BAHIR-308: --- Commit 35b6ff7455bcf84c9044935f46a2469505c44526 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=35b6ff7 ] [BAHIR-308] Remove scala prefix where we can > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704123#comment-17704123 ] ASF subversion and git services commented on BAHIR-308: --- Commit 380c746fa55292f11c2a397cc1fcb2a9c3c6ad96 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=380c746 ] [BAHIR-308] Bump flink version to 1.15.3 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704124#comment-17704124 ] ASF subversion and git services commented on BAHIR-308: --- Commit ac1cf6a234120b1ef9797b16c14c14fa46fe4ada in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ac1cf6a ] [BAHIR-308] Bump flink version to 1.16.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704121#comment-17704121 ] ASF subversion and git services commented on BAHIR-308: --- Commit c52289ef46c119e9301d765146688e5382fafcde in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=c52289e ] [BAHIR-308] Remove scala prefix where we can > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704125#comment-17704125 ] ASF subversion and git services commented on BAHIR-308: --- Commit 871f10442e0a53cf5860ff873e1beba91cf457a7 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=871f104 ] [BAHIR-308] Bump flink version to 1.17.0 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704126#comment-17704126 ] ASF subversion and git services commented on BAHIR-308: --- Commit c52289ef46c119e9301d765146688e5382fafcde in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=c52289e ] [BAHIR-308] Remove scala prefix where we can > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704122#comment-17704122 ] ASF subversion and git services commented on BAHIR-308: --- Commit 2254ea09380e73b53fb8c15098018abb204c552f in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=2254ea0 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704033#comment-17704033 ] ASF subversion and git services commented on BAHIR-308: --- Commit 871f10442e0a53cf5860ff873e1beba91cf457a7 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=871f104 ] [BAHIR-308] Bump flink version to 1.17.0 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703991#comment-17703991 ] ASF subversion and git services commented on BAHIR-308: --- Commit cba2beb5808589cd6bb11bc811742e3697b56ea2 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=cba2beb ] [BAHIR-308] Bump flink version to 1.17.0 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701099#comment-17701099 ] ASF subversion and git services commented on BAHIR-308: --- Commit ac1cf6a234120b1ef9797b16c14c14fa46fe4ada in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ac1cf6a ] [BAHIR-308] Bump flink version to 1.16.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697998#comment-17697998 ] ASF subversion and git services commented on BAHIR-308: --- Commit d23ffb9a05c3bad0b8b8703ca21dd22fc8f79b9a in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=d23ffb9 ] [BAHIR-308] Bump flink version to 1.16.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697997#comment-17697997 ] ASF subversion and git services commented on BAHIR-308: --- Commit bf1fb02ecd88c51f96893302915a93aca5cba9ec in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=bf1fb02 ] [BAHIR-308] Bump flink version to 1.16.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697993#comment-17697993 ] ASF subversion and git services commented on BAHIR-308: --- Commit 380c746fa55292f11c2a397cc1fcb2a9c3c6ad96 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=380c746 ] [BAHIR-308] Bump flink version to 1.15.3 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697992#comment-17697992 ] ASF subversion and git services commented on BAHIR-308: --- Commit 2254ea09380e73b53fb8c15098018abb204c552f in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=2254ea0 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697994#comment-17697994 ] ASF subversion and git services commented on BAHIR-308: --- Commit d23ffb9a05c3bad0b8b8703ca21dd22fc8f79b9a in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=d23ffb9 ] [BAHIR-308] Bump flink version to 1.16.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697988#comment-17697988 ] ASF subversion and git services commented on BAHIR-308: --- Commit 380c746fa55292f11c2a397cc1fcb2a9c3c6ad96 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=380c746 ] [BAHIR-308] Bump flink version to 1.15.3 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-283) InfluxDBWriter fails to write the final element in each element
[
https://issues.apache.org/jira/browse/BAHIR-283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697474#comment-17697474
]
ASF subversion and git services commented on BAHIR-283:
---
Commit c8b6f6122ae6411064a1ec55cf2c2fbc08d4979f in bahir-flink's branch
refs/heads/BAHIR-308 from dave
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=c8b6f61 ]
[BAHIR-283] Fix dropped elements on InfluxDbSink
> InfluxDBWriter fails to write the final element in each element
> ---
>
> Key: BAHIR-283
> URL: https://issues.apache.org/jira/browse/BAHIR-283
> Project: Bahir
> Issue Type: Bug
> Components: Flink Streaming Connectors
>Affects Versions: Flink-1.0
>Reporter: David Quigley
>Priority: Major
> Fix For: Flink-1.2.0
>
> Original Estimate: 2h
> Remaining Estimate: 2h
>
> {{/**
> * This method calls the InfluxDB write API whenever the element list
> reaches the {@link
> * #bufferSize}. It keeps track of the latest timestamp of each element.
> It compares the latest
> * timestamp with the context.timestamp() and takes the bigger (latest)
> timestamp.
> *
> * @param in incoming data
> * @param context current Flink context
> * @see org.apache.flink.api.connector.sink.SinkWriter.Context
> */
> @Override
> public void write(final IN in, final Context context) throws IOException {
> if (this.elements.size() == this.bufferSize) {
> LOG.debug("Buffer size reached preparing to write the elements.");
> this.writeCurrentElements();
> this.elements.clear();
> } else {
> LOG.trace("Adding elements to buffer. Buffer size: {}",
> this.elements.size());
> this.elements.add(this.schemaSerializer.serialize(in, context));
> if (context.timestamp() != null) {
> this.lastTimestamp = Math.max(this.lastTimestamp,
> context.timestamp());
> }
> }
> }}}
> The bug is in this write method. If the number of elements in the buffer is
> less than the configured buffer size, the current element is added to the
> buffer. If the number of elements in the buffer is equal to the buffer size,
> the buffer is flushed and the current element is not added to the next
> buffer. This results in the current element being dropped.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697475#comment-17697475 ] ASF subversion and git services commented on BAHIR-308: --- Commit 2254ea09380e73b53fb8c15098018abb204c552f in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=2254ea0 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697477#comment-17697477 ] ASF subversion and git services commented on BAHIR-308: --- Commit 647ec12bc3c88ab758846c6283500473c4c87d24 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=647ec12 ] [BAHIR-308] InfluxDB changes > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697476#comment-17697476 ] ASF subversion and git services commented on BAHIR-308: --- Commit e2fd9cf78bdf2cdc5ef587386f9947a3a8053142 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=e2fd9cf ] [BAHIR-308] Bump flink version to 1.15.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-283) InfluxDBWriter fails to write the final element in each element
[
https://issues.apache.org/jira/browse/BAHIR-283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697472#comment-17697472
]
ASF subversion and git services commented on BAHIR-283:
---
Commit c8b6f6122ae6411064a1ec55cf2c2fbc08d4979f in bahir-flink's branch
refs/heads/master from dave
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=c8b6f61 ]
[BAHIR-283] Fix dropped elements on InfluxDbSink
> InfluxDBWriter fails to write the final element in each element
> ---
>
> Key: BAHIR-283
> URL: https://issues.apache.org/jira/browse/BAHIR-283
> Project: Bahir
> Issue Type: Bug
> Components: Flink Streaming Connectors
>Affects Versions: Flink-1.0
>Reporter: David Quigley
>Priority: Major
> Fix For: Flink-1.2.0
>
> Original Estimate: 2h
> Remaining Estimate: 2h
>
> {{/**
> * This method calls the InfluxDB write API whenever the element list
> reaches the {@link
> * #bufferSize}. It keeps track of the latest timestamp of each element.
> It compares the latest
> * timestamp with the context.timestamp() and takes the bigger (latest)
> timestamp.
> *
> * @param in incoming data
> * @param context current Flink context
> * @see org.apache.flink.api.connector.sink.SinkWriter.Context
> */
> @Override
> public void write(final IN in, final Context context) throws IOException {
> if (this.elements.size() == this.bufferSize) {
> LOG.debug("Buffer size reached preparing to write the elements.");
> this.writeCurrentElements();
> this.elements.clear();
> } else {
> LOG.trace("Adding elements to buffer. Buffer size: {}",
> this.elements.size());
> this.elements.add(this.schemaSerializer.serialize(in, context));
> if (context.timestamp() != null) {
> this.lastTimestamp = Math.max(this.lastTimestamp,
> context.timestamp());
> }
> }
> }}}
> The bug is in this write method. If the number of elements in the buffer is
> less than the configured buffer size, the current element is added to the
> buffer. If the number of elements in the buffer is equal to the buffer size,
> the buffer is flushed and the current element is not added to the next
> buffer. This results in the current element being dropped.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697460#comment-17697460 ] ASF subversion and git services commented on BAHIR-308: --- Commit 536ac65b32e1d40d6fa91fda6256f346e30e422d in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=536ac65 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697462#comment-17697462 ] ASF subversion and git services commented on BAHIR-308: --- Commit 23d90e3857dc0014b06debf9b5e72e641e0e03f9 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=23d90e3 ] [BAHIR-308] InfluxDB changes > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697461#comment-17697461 ] ASF subversion and git services commented on BAHIR-308: --- Commit c9fa6d593012bb4d2e17f1d82ace24bd6e882e72 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=c9fa6d5 ] [BAHIR-308] Bump flink version to 1.15.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684596#comment-17684596 ] ASF subversion and git services commented on BAHIR-308: --- Commit 65d29e289845a465dedba2c7409186800a247491 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=65d29e2 ] [BAHIR-308] InfluxDB changes > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684594#comment-17684594 ] ASF subversion and git services commented on BAHIR-308: --- Commit 2f0d1374adf454557f1eda71a3bb653cc0d32211 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=2f0d137 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-321) Kudu lookup join fails with String literal in WHERE clause
[
https://issues.apache.org/jira/browse/BAHIR-321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684593#comment-17684593
]
ASF subversion and git services commented on BAHIR-321:
---
Commit 724e17c4481fb12c1ab14608dd04b974d6f5e090 in bahir-flink's branch
refs/heads/BAHIR-308 from Balazs Varga
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=724e17c ]
[BAHIR-321] Make KuduFilterInfo handle String literals
> Kudu lookup join fails with String literal in WHERE clause
> --
>
> Key: BAHIR-321
> URL: https://issues.apache.org/jira/browse/BAHIR-321
> Project: Bahir
> Issue Type: Bug
> Components: Flink Streaming Connectors
>Reporter: Balazs Varga
>Priority: Major
>
> When performing a (processing time) temporal table join with a Kudu table,
> and using a String literal in the WHERE condition:
> {code:java}
> SELECT d.sensor_id, k.sensor_type, d.`value`
> FROM datagen AS d
> JOIN `kudu`.`default_database`.`default.sensors` FOR SYSTEM_TIME AS OF
> d.proctime as k
> ON k.sensor_id = d.sensor_id
> WHERE sensor_type = 'pressure';{code}
> We get the following error:
> Caused by: java.lang.ClassCastException:
> org.apache.flink.table.data.binary.BinaryStringData cannot be cast to
> java.lang.Stringat
> org.apache.flink.connectors.kudu.connector.KuduFilterInfo.predicateComparator(KuduFilterInfo.java:68)
> This is because in KuduFilterInfo it tries to cast the literal, which is a
> BinaryStringData, to a String.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684595#comment-17684595 ] ASF subversion and git services commented on BAHIR-308: --- Commit 40a462ca77c993ca8dbf966cb2999f31197cfdf9 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=40a462c ] [BAHIR-308] Bump flink version to 1.15.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684582#comment-17684582 ] ASF subversion and git services commented on BAHIR-308: --- Commit 1573b01031b16f18ce61670f9eb2806b09a0d699 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=1573b01 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684583#comment-17684583 ] ASF subversion and git services commented on BAHIR-308: --- Commit 2a7925ce4fcaa9096fc6c149f552550f8014ee0c in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=2a7925c ] [BAHIR-308] Bump flink version to 1.15.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-315) Redis connector: add Support for SSL connections for cluster
[ https://issues.apache.org/jira/browse/BAHIR-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684581#comment-17684581 ] ASF subversion and git services commented on BAHIR-315: --- Commit 510a2b18ea8ad42932a37604b57ad5d47fb62a03 in bahir-flink's branch refs/heads/BAHIR-308 from Sebastian Ramirez [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=510a2b1 ] [BAHIR-315] Move SSL config to FlinkJedisConfigBase This allows us to support SSL connections in non-cluster configurations. JedisSentinelPool currently doesn't support SSL connections. > Redis connector: add Support for SSL connections for cluster > - > > Key: BAHIR-315 > URL: https://issues.apache.org/jira/browse/BAHIR-315 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Affects Versions: Flink-1.0 >Reporter: Kostas Netsiporenko >Assignee: João Boto >Priority: Major > Fix For: Flink-1.2.0 > > > Add support for SSL connections for clusters connections > * Upgrade the redis/jedis dependency to support SSL connections for clusters > (SSL support for cluster was added on 3.1.0. > [https://github.com/redis/jedis/releases/tag/jedis-3.1.0] ) > * FlinkJedisClusterConfig should allow you to set a flag. > * When creating a JedisCluster pass the SSL flag. > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684584#comment-17684584 ] ASF subversion and git services commented on BAHIR-308: --- Commit e8dff35854f68dc861cf6e39919b8ad5b2ce206d in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=e8dff35 ] [BAHIR-308] InfluxDB changes > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-321) Kudu lookup join fails with String literal in WHERE clause
[
https://issues.apache.org/jira/browse/BAHIR-321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17683463#comment-17683463
]
ASF subversion and git services commented on BAHIR-321:
---
Commit 724e17c4481fb12c1ab14608dd04b974d6f5e090 in bahir-flink's branch
refs/heads/master from Balazs Varga
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=724e17c ]
[BAHIR-321] Make KuduFilterInfo handle String literals
> Kudu lookup join fails with String literal in WHERE clause
> --
>
> Key: BAHIR-321
> URL: https://issues.apache.org/jira/browse/BAHIR-321
> Project: Bahir
> Issue Type: Bug
> Components: Flink Streaming Connectors
>Reporter: Balazs Varga
>Priority: Major
>
> When performing a (processing time) temporal table join with a Kudu table,
> and using a String literal in the WHERE condition:
> {code:java}
> SELECT d.sensor_id, k.sensor_type, d.`value`
> FROM datagen AS d
> JOIN `kudu`.`default_database`.`default.sensors` FOR SYSTEM_TIME AS OF
> d.proctime as k
> ON k.sensor_id = d.sensor_id
> WHERE sensor_type = 'pressure';{code}
> We get the following error:
> Caused by: java.lang.ClassCastException:
> org.apache.flink.table.data.binary.BinaryStringData cannot be cast to
> java.lang.Stringat
> org.apache.flink.connectors.kudu.connector.KuduFilterInfo.predicateComparator(KuduFilterInfo.java:68)
> This is because in KuduFilterInfo it tries to cast the literal, which is a
> BinaryStringData, to a String.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (BAHIR-315) Redis connector: add Support for SSL connections for cluster
[ https://issues.apache.org/jira/browse/BAHIR-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636708#comment-17636708 ] ASF subversion and git services commented on BAHIR-315: --- Commit 510a2b18ea8ad42932a37604b57ad5d47fb62a03 in bahir-flink's branch refs/heads/master from Sebastian Ramirez [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=510a2b1 ] [BAHIR-315] Move SSL config to FlinkJedisConfigBase This allows us to support SSL connections in non-cluster configurations. JedisSentinelPool currently doesn't support SSL connections. > Redis connector: add Support for SSL connections for cluster > - > > Key: BAHIR-315 > URL: https://issues.apache.org/jira/browse/BAHIR-315 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Affects Versions: Flink-1.0 >Reporter: Kostas Netsiporenko >Assignee: João Boto >Priority: Major > Fix For: Flink-1.2.0 > > > Add support for SSL connections for clusters connections > * Upgrade the redis/jedis dependency to support SSL connections for clusters > (SSL support for cluster was added on 3.1.0. > [https://github.com/redis/jedis/releases/tag/jedis-3.1.0] ) > * FlinkJedisClusterConfig should allow you to set a flag. > * When creating a JedisCluster pass the SSL flag. > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-319) Remove travis from bahir-flink
[ https://issues.apache.org/jira/browse/BAHIR-319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629097#comment-17629097 ] ASF subversion and git services commented on BAHIR-319: --- Commit c031420c237462dfcd37a4d22a4d852833d6d2f3 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=c031420 ] [BAHIR-319] Remove travis support > Remove travis from bahir-flink > -- > > Key: BAHIR-319 > URL: https://issues.apache.org/jira/browse/BAHIR-319 > Project: Bahir > Issue Type: Sub-task > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > Fix For: Flink-1.2.0 > > > travis is already moved to GitHub actions > the only thing needed is to remove travis file -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629099#comment-17629099 ] ASF subversion and git services commented on BAHIR-308: --- Commit beb6766b5bf9daa73abfd81d0ee038b0fcd988bb in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=beb6766 ] [BAHIR-308] Bump flink version to 1.15.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629098#comment-17629098 ] ASF subversion and git services commented on BAHIR-308: --- Commit 86cbac9dddafcc1ae45e32918b9f9cb60ff3dcb8 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=86cbac9 ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-317) Bump flink to 1.14.6
[ https://issues.apache.org/jira/browse/BAHIR-317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629094#comment-17629094 ] ASF subversion and git services commented on BAHIR-317: --- Commit f3b096ef71b05fc2f482881a1d706fcc1d4c79b1 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=f3b096e ] [BAHIR-317] Fix distribution parent version > Bump flink to 1.14.6 > > > Key: BAHIR-317 > URL: https://issues.apache.org/jira/browse/BAHIR-317 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > Fix For: Flink-1.2.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-315) Redis connector: add Support for SSL connections for cluster
[ https://issues.apache.org/jira/browse/BAHIR-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629093#comment-17629093 ] ASF subversion and git services commented on BAHIR-315: --- Commit 522624f481eaf8fdaced084bf166b0e84c664b68 in bahir-flink's branch refs/heads/BAHIR-308 from netsi [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=522624f ] [BAHIR-315] add support for SSL connection > Redis connector: add Support for SSL connections for cluster > - > > Key: BAHIR-315 > URL: https://issues.apache.org/jira/browse/BAHIR-315 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Affects Versions: Flink-1.0 >Reporter: Kostas Netsiporenko >Assignee: João Boto >Priority: Major > Fix For: Flink-1.2.0 > > > Add support for SSL connections for clusters connections > * Upgrade the redis/jedis dependency to support SSL connections for clusters > (SSL support for cluster was added on 3.1.0. > [https://github.com/redis/jedis/releases/tag/jedis-3.1.0] ) > * FlinkJedisClusterConfig should allow you to set a flag. > * When creating a JedisCluster pass the SSL flag. > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-315) Redis connector: add Support for SSL connections for cluster
[ https://issues.apache.org/jira/browse/BAHIR-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629092#comment-17629092 ] ASF subversion and git services commented on BAHIR-315: --- Commit ef3d18b07ca5ab2d4b653171777122ae257e747c in bahir-flink's branch refs/heads/BAHIR-308 from netsi [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ef3d18b ] [BAHIR-315] update jedis dependency to 4.3.0 > Redis connector: add Support for SSL connections for cluster > - > > Key: BAHIR-315 > URL: https://issues.apache.org/jira/browse/BAHIR-315 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Affects Versions: Flink-1.0 >Reporter: Kostas Netsiporenko >Assignee: João Boto >Priority: Major > Fix For: Flink-1.2.0 > > > Add support for SSL connections for clusters connections > * Upgrade the redis/jedis dependency to support SSL connections for clusters > (SSL support for cluster was added on 3.1.0. > [https://github.com/redis/jedis/releases/tag/jedis-3.1.0] ) > * FlinkJedisClusterConfig should allow you to set a flag. > * When creating a JedisCluster pass the SSL flag. > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629100#comment-17629100 ] ASF subversion and git services commented on BAHIR-308: --- Commit c128a2a6d4f1315c7e7bcf2fad11bbe49986fa3b in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=c128a2a ] [BAHIR-308] InfluxDB changes > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-312) Add Apache License header to readme.md
[
https://issues.apache.org/jira/browse/BAHIR-312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629091#comment-17629091
]
ASF subversion and git services commented on BAHIR-312:
---
Commit efd9520a8234c9be632e4691a1b0dda553a74518 in bahir-flink's branch
refs/heads/BAHIR-308 from Joao Boto
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=efd9520 ]
[BAHIR-312] Add license header to README.md files
> Add Apache License header to readme.md
> --
>
> Key: BAHIR-312
> URL: https://issues.apache.org/jira/browse/BAHIR-312
> Project: Bahir
> Issue Type: Improvement
> Components: Flink Streaming Connectors
>Affects Versions: Flink-1.1.0
>Reporter: João Boto
>Assignee: João Boto
>Priority: Major
> Fix For: Flink-1.2.0
>
>
> add license to md files
> {code:java}
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (BAHIR-317) Bump flink to 1.14.6
[ https://issues.apache.org/jira/browse/BAHIR-317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629095#comment-17629095 ] ASF subversion and git services commented on BAHIR-317: --- Commit 5c0017c28b6863c2636c9f83ad5ea9a9cc8c8b00 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=5c0017c ] [BAHIR-317] Bump flink version to 1.14.6 > Bump flink to 1.14.6 > > > Key: BAHIR-317 > URL: https://issues.apache.org/jira/browse/BAHIR-317 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > Fix For: Flink-1.2.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-304) Fix dev scripts
[ https://issues.apache.org/jira/browse/BAHIR-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629096#comment-17629096 ] ASF subversion and git services commented on BAHIR-304: --- Commit ffb413f0ae625800d2e13e1425728065b162f3b9 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ffb413f ] [BAHIR-304] Add gitBranch option to release script > Fix dev scripts > --- > > Key: BAHIR-304 > URL: https://issues.apache.org/jira/browse/BAHIR-304 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > Fix For: Flink-1.1.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628781#comment-17628781 ] ASF subversion and git services commented on BAHIR-320: --- Commit 8b647c8ef80455ba900ef91e08eaf5eafa35c133 in bahir's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=8b647c8 ] [BAHIR-320] Add maven ci > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task > Components: Build >Reporter: João Boto >Assignee: João Boto >Priority: Major > Fix For: Spark-2.4.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628246#comment-17628246 ] ASF subversion and git services commented on BAHIR-320: --- Commit f7d2d6472d3ed95b88e357a31d700ac4ae0d6353 in bahir's branch refs/heads/dependabot/maven/sql-streaming-jdbc/com.h2database-h2-2.1.210 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=f7d2d64 ] [BAHIR-320] Add maven ci > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task > Components: Build >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628237#comment-17628237 ] ASF subversion and git services commented on BAHIR-320: --- Commit f7d2d6472d3ed95b88e357a31d700ac4ae0d6353 in bahir's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=f7d2d64 ] [BAHIR-320] Add maven ci > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task > Components: Build >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628231#comment-17628231 ] ASF subversion and git services commented on BAHIR-320: --- Commit ba53b73a89a4aa9980743dbf274d0efddd1ea27c in bahir's branch refs/heads/dependabot/maven/sql-streaming-jdbc/com.h2database-h2-2.1.210 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=ba53b73 ] [BAHIR-320] Add maven ci > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task > Components: Build >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628230#comment-17628230 ] ASF subversion and git services commented on BAHIR-320: --- Commit ba53b73a89a4aa9980743dbf274d0efddd1ea27c in bahir's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=ba53b73 ] [BAHIR-320] Add maven ci > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task > Components: Build >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628219#comment-17628219 ] ASF subversion and git services commented on BAHIR-320: --- Commit 73c28fef8477d84ca55a1da8a46a4fb98d22b280 in bahir's branch refs/heads/dependabot/maven/sql-streaming-jdbc/com.h2database-h2-2.1.210 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=73c28fe ] [BAHIR-320] Migrate travis to github actions > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task > Components: Build >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628217#comment-17628217 ] ASF subversion and git services commented on BAHIR-320: --- Commit 73c28fef8477d84ca55a1da8a46a4fb98d22b280 in bahir's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=73c28fe ] [BAHIR-320] Migrate travis to github actions > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task > Components: Build >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628209#comment-17628209 ] ASF subversion and git services commented on BAHIR-320: --- Commit f3236b484dbc11574edf7573647f8cb071d66b6a in bahir's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=f3236b4 ] [BAHIR-320] Migrate travis to github actions > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task > Components: Build >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626623#comment-17626623 ] ASF subversion and git services commented on BAHIR-320: --- Commit fa9a9684df1d29851fea2ddadd30c0f56aaf072a in bahir's branch refs/heads/BAHIR-320 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=fa9a968 ] [BAHIR-320] Migrate travis to github actions > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task >Reporter: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-319) Remove travis from bahir-flink
[ https://issues.apache.org/jira/browse/BAHIR-319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626622#comment-17626622 ] ASF subversion and git services commented on BAHIR-319: --- Commit c031420c237462dfcd37a4d22a4d852833d6d2f3 in bahir-flink's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=c031420 ] [BAHIR-319] Remove travis support > Remove travis from bahir-flink > -- > > Key: BAHIR-319 > URL: https://issues.apache.org/jira/browse/BAHIR-319 > Project: Bahir > Issue Type: Sub-task >Reporter: João Boto >Assignee: João Boto >Priority: Major > > travis is already moved to GitHub actions > the only thing needed is to remove travis file -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-320) Remove travis from bahir-spark
[ https://issues.apache.org/jira/browse/BAHIR-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626621#comment-17626621 ] ASF subversion and git services commented on BAHIR-320: --- Commit fd11f8c314624f10b5511ce248cfd32c4e9d2b27 in bahir's branch refs/heads/BAHIR-320 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir.git;h=fd11f8c ] [BAHIR-320] Migrate travis to github actions > Remove travis from bahir-spark > -- > > Key: BAHIR-320 > URL: https://issues.apache.org/jira/browse/BAHIR-320 > Project: Bahir > Issue Type: Sub-task >Reporter: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-317) Bump flink to 1.14.6
[ https://issues.apache.org/jira/browse/BAHIR-317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622082#comment-17622082 ] ASF subversion and git services commented on BAHIR-317: --- Commit 5c0017c28b6863c2636c9f83ad5ea9a9cc8c8b00 in bahir-flink's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=5c0017c ] [BAHIR-317] Bump flink version to 1.14.6 > Bump flink to 1.14.6 > > > Key: BAHIR-317 > URL: https://issues.apache.org/jira/browse/BAHIR-317 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-317) Bump flink to 1.14.6
[ https://issues.apache.org/jira/browse/BAHIR-317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622081#comment-17622081 ] ASF subversion and git services commented on BAHIR-317: --- Commit f3b096ef71b05fc2f482881a1d706fcc1d4c79b1 in bahir-flink's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=f3b096e ] [BAHIR-317] Fix distribution parent version > Bump flink to 1.14.6 > > > Key: BAHIR-317 > URL: https://issues.apache.org/jira/browse/BAHIR-317 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-304) Fix dev scripts
[ https://issues.apache.org/jira/browse/BAHIR-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622083#comment-17622083 ] ASF subversion and git services commented on BAHIR-304: --- Commit ffb413f0ae625800d2e13e1425728065b162f3b9 in bahir-flink's branch refs/heads/master from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ffb413f ] [BAHIR-304] Add gitBranch option to release script > Fix dev scripts > --- > > Key: BAHIR-304 > URL: https://issues.apache.org/jira/browse/BAHIR-304 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > Fix For: Flink-1.1.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-304) Fix dev scripts
[ https://issues.apache.org/jira/browse/BAHIR-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621244#comment-17621244 ] ASF subversion and git services commented on BAHIR-304: --- Commit 4a5b6d533fcb96d5f6cd9c46009a013d38b8e7c2 in bahir-flink's branch refs/heads/BAHIR-317 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=4a5b6d5 ] [BAHIR-304] Add gitBranch option to release script > Fix dev scripts > --- > > Key: BAHIR-304 > URL: https://issues.apache.org/jira/browse/BAHIR-304 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > Fix For: Flink-1.1.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-317) Bump flink to 1.14.6
[ https://issues.apache.org/jira/browse/BAHIR-317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621232#comment-17621232 ] ASF subversion and git services commented on BAHIR-317: --- Commit c20b49015673ea433a114187b4afe73b3158d770 in bahir-flink's branch refs/heads/BAHIR-317 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=c20b490 ] [BAHIR-317] Bump flink version to 1.14.6 > Bump flink to 1.14.6 > > > Key: BAHIR-317 > URL: https://issues.apache.org/jira/browse/BAHIR-317 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-317) Bump flink to 1.14.6
[ https://issues.apache.org/jira/browse/BAHIR-317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621228#comment-17621228 ] ASF subversion and git services commented on BAHIR-317: --- Commit af0d7bc270e77049db46f12de3b503512dcdba14 in bahir-flink's branch refs/heads/BAHIR-317 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=af0d7bc ] [BAHIR-317] Fix distribution parent version > Bump flink to 1.14.6 > > > Key: BAHIR-317 > URL: https://issues.apache.org/jira/browse/BAHIR-317 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-317) Bump flink to 1.14.6
[ https://issues.apache.org/jira/browse/BAHIR-317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621229#comment-17621229 ] ASF subversion and git services commented on BAHIR-317: --- Commit af07d9853591c28137d0971505c1c881c342 in bahir-flink's branch refs/heads/BAHIR-317 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=af0 ] [BAHIR-317] Bump flink version to 1.14.6 > Bump flink to 1.14.6 > > > Key: BAHIR-317 > URL: https://issues.apache.org/jira/browse/BAHIR-317 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-315) Redis connector: add Support for SSL connections for cluster
[ https://issues.apache.org/jira/browse/BAHIR-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619336#comment-17619336 ] ASF subversion and git services commented on BAHIR-315: --- Commit 522624f481eaf8fdaced084bf166b0e84c664b68 in bahir-flink's branch refs/heads/master from netsi [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=522624f ] [BAHIR-315] add support for SSL connection > Redis connector: add Support for SSL connections for cluster > - > > Key: BAHIR-315 > URL: https://issues.apache.org/jira/browse/BAHIR-315 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Affects Versions: Flink-1.0 >Reporter: Kostas Netsiporenko >Assignee: João Boto >Priority: Major > Fix For: Flink-1.2.0 > > > Add support for SSL connections for clusters connections > * Upgrade the redis/jedis dependency to support SSL connections for clusters > (SSL support for cluster was added on 3.1.0. > [https://github.com/redis/jedis/releases/tag/jedis-3.1.0] ) > * FlinkJedisClusterConfig should allow you to set a flag. > * When creating a JedisCluster pass the SSL flag. > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619337#comment-17619337 ] ASF subversion and git services commented on BAHIR-308: --- Commit 751955b30a9e35f47f2209e0f764e3eb4e29caf2 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=751955b ] [BAHIR-308] Remove support for scala 2.11 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619338#comment-17619338 ] ASF subversion and git services commented on BAHIR-308: --- Commit b629de887c03dfade853b41871fa92bf8a6848f3 in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=b629de8 ] [BAHIR-308] Bump flink version to 1.15.1 > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-315) Redis connector: add Support for SSL connections for cluster
[ https://issues.apache.org/jira/browse/BAHIR-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619335#comment-17619335 ] ASF subversion and git services commented on BAHIR-315: --- Commit ef3d18b07ca5ab2d4b653171777122ae257e747c in bahir-flink's branch refs/heads/master from netsi [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ef3d18b ] [BAHIR-315] update jedis dependency to 4.3.0 > Redis connector: add Support for SSL connections for cluster > - > > Key: BAHIR-315 > URL: https://issues.apache.org/jira/browse/BAHIR-315 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Affects Versions: Flink-1.0 >Reporter: Kostas Netsiporenko >Assignee: João Boto >Priority: Major > Fix For: Flink-1.2.0 > > > Add support for SSL connections for clusters connections > * Upgrade the redis/jedis dependency to support SSL connections for clusters > (SSL support for cluster was added on 3.1.0. > [https://github.com/redis/jedis/releases/tag/jedis-3.1.0] ) > * FlinkJedisClusterConfig should allow you to set a flag. > * When creating a JedisCluster pass the SSL flag. > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619339#comment-17619339 ] ASF subversion and git services commented on BAHIR-308: --- Commit 7af51110d162c64d03ca4726edb70f1586ec4b2d in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=7af5111 ] [BAHIR-308] InfluxDB changes > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-312) Add Apache License header to readme.md
[
https://issues.apache.org/jira/browse/BAHIR-312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619334#comment-17619334
]
ASF subversion and git services commented on BAHIR-312:
---
Commit efd9520a8234c9be632e4691a1b0dda553a74518 in bahir-flink's branch
refs/heads/master from Joao Boto
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=efd9520 ]
[BAHIR-312] Add license header to README.md files
> Add Apache License header to readme.md
> --
>
> Key: BAHIR-312
> URL: https://issues.apache.org/jira/browse/BAHIR-312
> Project: Bahir
> Issue Type: Improvement
> Components: Flink Streaming Connectors
>Affects Versions: Flink-1.1.0
>Reporter: João Boto
>Assignee: João Boto
>Priority: Major
> Fix For: Flink-1.2.0
>
>
> add license to md files
> {code:java}
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (BAHIR-315) Redis connector: add Support for SSL connections for cluster
[ https://issues.apache.org/jira/browse/BAHIR-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617801#comment-17617801 ] ASF subversion and git services commented on BAHIR-315: --- Commit ef3d18b07ca5ab2d4b653171777122ae257e747c in bahir-flink's branch refs/heads/master from netsi [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=ef3d18b ] [BAHIR-315] update jedis dependency to 4.3.0 > Redis connector: add Support for SSL connections for cluster > - > > Key: BAHIR-315 > URL: https://issues.apache.org/jira/browse/BAHIR-315 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Affects Versions: Flink-1.0 >Reporter: Kostas Netsiporenko >Priority: Major > > Add support for SSL connections for clusters connections > * Upgrade the redis/jedis dependency to support SSL connections for clusters > (SSL support for cluster was added on 3.1.0. > [https://github.com/redis/jedis/releases/tag/jedis-3.1.0] ) > * FlinkJedisClusterConfig should allow you to set a flag. > * When creating a JedisCluster pass the SSL flag. > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-315) Redis connector: add Support for SSL connections for cluster
[ https://issues.apache.org/jira/browse/BAHIR-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617802#comment-17617802 ] ASF subversion and git services commented on BAHIR-315: --- Commit 522624f481eaf8fdaced084bf166b0e84c664b68 in bahir-flink's branch refs/heads/master from netsi [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=522624f ] [BAHIR-315] add support for SSL connection > Redis connector: add Support for SSL connections for cluster > - > > Key: BAHIR-315 > URL: https://issues.apache.org/jira/browse/BAHIR-315 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Affects Versions: Flink-1.0 >Reporter: Kostas Netsiporenko >Priority: Major > > Add support for SSL connections for clusters connections > * Upgrade the redis/jedis dependency to support SSL connections for clusters > (SSL support for cluster was added on 3.1.0. > [https://github.com/redis/jedis/releases/tag/jedis-3.1.0] ) > * FlinkJedisClusterConfig should allow you to set a flag. > * When creating a JedisCluster pass the SSL flag. > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-308) Bump flink to 1.15
[ https://issues.apache.org/jira/browse/BAHIR-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615813#comment-17615813 ] ASF subversion and git services commented on BAHIR-308: --- Commit 7af51110d162c64d03ca4726edb70f1586ec4b2d in bahir-flink's branch refs/heads/BAHIR-308 from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=7af5111 ] [BAHIR-308] InfluxDB changes > Bump flink to 1.15 > -- > > Key: BAHIR-308 > URL: https://issues.apache.org/jira/browse/BAHIR-308 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > > Failing tests: > influxdb2 > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-312) Add Apache License header to readme.md
[
https://issues.apache.org/jira/browse/BAHIR-312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613358#comment-17613358
]
ASF subversion and git services commented on BAHIR-312:
---
Commit efd9520a8234c9be632e4691a1b0dda553a74518 in bahir-flink's branch
refs/heads/master from Joao Boto
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=efd9520 ]
[BAHIR-312] Add license header to README.md files
> Add Apache License header to readme.md
> --
>
> Key: BAHIR-312
> URL: https://issues.apache.org/jira/browse/BAHIR-312
> Project: Bahir
> Issue Type: Improvement
> Components: Flink Streaming Connectors
>Affects Versions: Flink-Next
>Reporter: João Boto
>Assignee: João Boto
>Priority: Major
>
> add license to md files
> {code:java}
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (BAHIR-289) Publish website with asf file
[ https://issues.apache.org/jira/browse/BAHIR-289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576353#comment-17576353 ] ASF subversion and git services commented on BAHIR-289: --- Commit 519da842c251935077d82c1aca88b86194da81bf in bahir-website's branch refs/heads/asf_testing from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-website.git;h=519da84 ] [BAHIR-289] Add jekyll config to .asf.yaml > Publish website with asf file > - > > Key: BAHIR-289 > URL: https://issues.apache.org/jira/browse/BAHIR-289 > Project: Bahir > Issue Type: Improvement >Reporter: João Boto >Assignee: João Boto >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (BAHIR-293) Fix documentation
[ https://issues.apache.org/jira/browse/BAHIR-293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576351#comment-17576351 ] ASF subversion and git services commented on BAHIR-293: --- Commit 62bce83563e9d14722ba533e33aedc0b543f3e11 in bahir-website's branch refs/heads/asf_testing from Joao Boto [ https://gitbox.apache.org/repos/asf?p=bahir-website.git;h=62bce83 ] [BAHIR-293] Fix flink documentation > Fix documentation > - > > Key: BAHIR-293 > URL: https://issues.apache.org/jira/browse/BAHIR-293 > Project: Bahir > Issue Type: Bug > Components: Flink Streaming Connectors >Reporter: João Boto >Assignee: João Boto >Priority: Major > Fix For: Flink-Next > > -- This message was sent by Atlassian Jira (v8.20.10#820010)
