[jira] [Commented] (BAHIR-89) New API for subscribing from a list of MQTT topics and Return tuple of as output
[ https://issues.apache.org/jira/browse/BAHIR-89?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890971#comment-15890971 ] Christian Kadner commented on BAHIR-89: --- [~anntinutj] -- thanks for you PR and your patience! I will review it later today > New API for subscribing from a list of MQTT topics and Return tuple of > as output > > > Key: BAHIR-89 > URL: https://issues.apache.org/jira/browse/BAHIR-89 > Project: Bahir > Issue Type: New Feature > Components: Spark Streaming Connectors >Affects Versions: Not Applicable > Environment: Spark Streaming MQTT Connector >Reporter: Anntinu Josy > Labels: MQTT, SPARK > Fix For: Not Applicable > > Original Estimate: 168h > Remaining Estimate: 168h > > I am working in IoT Project. As part of MQTT-Kafka bridge program development > I used Bahir. I feel that it will be a good feature to prove a new API to > support a list of MQTT topic as input and output as a tuple of Message>. This will be useful to reduce resource usage in case of multiple > topic subscription. I had developed this feature a like to integrate -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (BAHIR-90) Bahir website missing docs, source links, download for Flink extensions
[ https://issues.apache.org/jira/browse/BAHIR-90?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890719#comment-15890719 ] Christian Kadner commented on BAHIR-90: --- [~luciano resende] -- please add [~tzulitai] as a developer on the Bahir JIRA project and assign this issue to him. Thanks > Bahir website missing docs, source links, download for Flink extensions > --- > > Key: BAHIR-90 > URL: https://issues.apache.org/jira/browse/BAHIR-90 > Project: Bahir > Issue Type: Task > Components: Website >Affects Versions: Flink-0.1 >Reporter: Christian Kadner > > The [Apache Bahir website|http://bahir.apache.org/] is missing download link, > source repository links and documentation for the Apache Flink extensions. > There also is a typo on the landing page missing the letter L in "Flink". -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Comment Edited] (BAHIR-90) Bahir website missing docs, source links, download for Flink extensions
[ https://issues.apache.org/jira/browse/BAHIR-90?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890111#comment-15890111 ] Tzu-Li (Gordon) Tai edited comment on BAHIR-90 at 3/1/17 1:06 PM: -- Thanks! contributor permissions for ticket assignment would be nice. FYI: https://github.com/apache/bahir-website/pull/9 this is the Github PR for this ticket. was (Author: tzulitai): Thanks, contributor permissions for ticket assignment would be nice. FYI: https://github.com/apache/bahir-website/pull/9 this is the Github PR for this ticket. > Bahir website missing docs, source links, download for Flink extensions > --- > > Key: BAHIR-90 > URL: https://issues.apache.org/jira/browse/BAHIR-90 > Project: Bahir > Issue Type: Task > Components: Website >Affects Versions: Flink-0.1 >Reporter: Christian Kadner > > The [Apache Bahir website|http://bahir.apache.org/] is missing download link, > source repository links and documentation for the Apache Flink extensions. > There also is a typo on the landing page missing the letter L in "Flink". -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (BAHIR-90) Bahir website missing docs, source links, download for Flink extensions
[ https://issues.apache.org/jira/browse/BAHIR-90?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890111#comment-15890111 ] Tzu-Li (Gordon) Tai commented on BAHIR-90: -- Thanks, contributor permissions would be nice. FYI: https://github.com/apache/bahir-website/pull/9 this is the Github PR for this ticket. > Bahir website missing docs, source links, download for Flink extensions > --- > > Key: BAHIR-90 > URL: https://issues.apache.org/jira/browse/BAHIR-90 > Project: Bahir > Issue Type: Task > Components: Website >Affects Versions: Flink-0.1 >Reporter: Christian Kadner > > The [Apache Bahir website|http://bahir.apache.org/] is missing download link, > source repository links and documentation for the Apache Flink extensions. > There also is a typo on the landing page missing the letter L in "Flink". -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Comment Edited] (BAHIR-90) Bahir website missing docs, source links, download for Flink extensions
[ https://issues.apache.org/jira/browse/BAHIR-90?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890111#comment-15890111 ] Tzu-Li (Gordon) Tai edited comment on BAHIR-90 at 3/1/17 1:01 PM: -- Thanks, contributor permissions for ticket assignment would be nice. FYI: https://github.com/apache/bahir-website/pull/9 this is the Github PR for this ticket. was (Author: tzulitai): Thanks, contributor permissions would be nice. FYI: https://github.com/apache/bahir-website/pull/9 this is the Github PR for this ticket. > Bahir website missing docs, source links, download for Flink extensions > --- > > Key: BAHIR-90 > URL: https://issues.apache.org/jira/browse/BAHIR-90 > Project: Bahir > Issue Type: Task > Components: Website >Affects Versions: Flink-0.1 >Reporter: Christian Kadner > > The [Apache Bahir website|http://bahir.apache.org/] is missing download link, > source repository links and documentation for the Apache Flink extensions. > There also is a typo on the landing page missing the letter L in "Flink". -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (BAHIR-91) Upgrade bahir-flink to support Flink 1.2
[
https://issues.apache.org/jira/browse/BAHIR-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890097#comment-15890097
]
ASF GitHub Bot commented on BAHIR-91:
-
Github user tzulitai commented on the issue:
https://github.com/apache/bahir-flink/pull/11
@rmetzger I don't think there's an easy way to do this, unless we try to
make the affected connectors backwards compatible.
Just rebased on {{master}} to resolve conflicts.
> Upgrade bahir-flink to support Flink 1.2
>
>
> Key: BAHIR-91
> URL: https://issues.apache.org/jira/browse/BAHIR-91
> Project: Bahir
> Issue Type: New Feature
> Components: Flink Streaming Connectors
>Affects Versions: Flink-0.1
> Environment: Ubuntu Yakkety Yak
>Reporter: Markus Müller
> Fix For: Flink-0.1
>
>
> After working around https://issues.apache.org/jira/browse/FLINK-4813 by
> specifying Flink version 1.3-SNAPSHOT instead of 1.2.0 in the bahir-flink pom
> file, I get the following compiler errors for the ActiveMQ connector:
> ERROR]
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[32,33]
> error: cannot find symbol
> [ERROR] symbol: class ForkableFlinkMiniCluster
> location: package org.apache.flink.test.util
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[54,19]
> error: cannot find symbol
> [ERROR] symbol: class ForkableFlinkMiniCluster
> location: class ActiveMQConnectorITCase
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[66,20]
> error: cannot find symbol
> [ERROR] symbol: class ForkableFlinkMiniCluster
> location: class ActiveMQConnectorITCase
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[216,22]
> error: method snapshotState in class
> MessageAcknowledgingSourceBase cannot be applied to given types;
> [ERROR] required: FunctionSnapshotContext
> found: long,long
> reason: actual and formal argument lists differ in length
> where Type,UId are type-variables:
> Type extends Object declared in class MessageAcknowledgingSourceBase
> UId extends Object declared in class MessageAcknowledgingSourceBase
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[229,4]
> error: ActiveMQConnectorITCase.TestSourceContext is not abstract and does
> not override abstract method markAsTemporarilyIdle() in SourceContext
> Excluding ActiveMQ from compilation leads to the next issue in the
> Akka-Connector:
> [ERROR]
> /home/markus/src/bahir-flink/flink-connector-akka/src/test/java/org/apache/flink/streaming/connectors/akka/AkkaSourceTest.java:[210,17]
> error: DummySourceContext is not abstract and does not override abstract
> method markAsTemporarilyIdle() in SourceContext
> [INFO] 1 error
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
[jira] [Resolved] (BAHIR-94) Apache Flink extension READMEs should include link to Flink's "Linking with Optional Modules" doc
[ https://issues.apache.org/jira/browse/BAHIR-94?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved BAHIR-94. - Resolution: Fixed Fix Version/s: Flink-0.1 > Apache Flink extension READMEs should include link to Flink's "Linking with > Optional Modules" doc > - > > Key: BAHIR-94 > URL: https://issues.apache.org/jira/browse/BAHIR-94 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: Tzu-Li (Gordon) Tai > Fix For: Flink-0.1 > > > Without this link, Bahir users will most likely bump into questions when > trying to include the connector for Flink cluster execution. > We should also try to improve the overall doc quality of the Flink extensions > for the 1.0 release. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Resolved] (BAHIR-93) Wrong version in README.md for several Apache Flink extensions
[
https://issues.apache.org/jira/browse/BAHIR-93?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved BAHIR-93.
-
Resolution: Fixed
Fix Version/s: Flink-0.1
> Wrong version in README.md for several Apache Flink extensions
> --
>
> Key: BAHIR-93
> URL: https://issues.apache.org/jira/browse/BAHIR-93
> Project: Bahir
> Issue Type: Bug
> Components: Flink Streaming Connectors
>Reporter: Tzu-Li (Gordon) Tai
> Fix For: Flink-0.1
>
>
> In several Apache Flink extensions (redis, activemq, netty, etc.), the
> current version is incorrectly {{1.0}} (missing "SNAPSHOT" tag).
> Also, in the akka extension, the version is {{1.0.0-SNAPSHOT}} (From the
> looks of https://www.mail-archive.com/dev@bahir.apache.org/msg00448.html, it
> seems like the agreed version format is "major-minor" for the {{bahir-flink}}
> module).
> Therefore, we should uniformly correct them to be {{1.0-SNAPSHOT}}. I think
> we should do this before creating the first {{bahir-flink}} release.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
[jira] [Commented] (BAHIR-94) Apache Flink extension READMEs should include link to Flink's "Linking with Optional Modules" doc
[ https://issues.apache.org/jira/browse/BAHIR-94?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889953#comment-15889953 ] ASF GitHub Bot commented on BAHIR-94: - Github user asfgit closed the pull request at: https://github.com/apache/bahir-flink/pull/12 > Apache Flink extension READMEs should include link to Flink's "Linking with > Optional Modules" doc > - > > Key: BAHIR-94 > URL: https://issues.apache.org/jira/browse/BAHIR-94 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: Tzu-Li (Gordon) Tai > Fix For: Flink-0.1 > > > Without this link, Bahir users will most likely bump into questions when > trying to include the connector for Flink cluster execution. > We should also try to improve the overall doc quality of the Flink extensions > for the 1.0 release. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (BAHIR-94) Apache Flink extension READMEs should include link to Flink's "Linking with Optional Modules" doc
[ https://issues.apache.org/jira/browse/BAHIR-94?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889952#comment-15889952 ] ASF subversion and git services commented on BAHIR-94: -- Commit 9f306889f3d02126aa89a5fdddf385a57adebe64 in bahir-flink's branch refs/heads/master from [~tzulitai] [ https://git-wip-us.apache.org/repos/asf?p=bahir-flink.git;h=9f30688 ] [BAHIR-94] Add link to "Linking with Optional Modules" in READMEs This commit also attempts to improve the overall quality of the Flink connector docs (typos, extra empty lines, etc.) for the upcoming 1.0 release. This closes #12 > Apache Flink extension READMEs should include link to Flink's "Linking with > Optional Modules" doc > - > > Key: BAHIR-94 > URL: https://issues.apache.org/jira/browse/BAHIR-94 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: Tzu-Li (Gordon) Tai > > Without this link, Bahir users will most likely bump into questions when > trying to include the connector for Flink cluster execution. > We should also try to improve the overall doc quality of the Flink extensions > for the 1.0 release. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (BAHIR-94) Apache Flink extension READMEs should include link to Flink's "Linking with Optional Modules" doc
[ https://issues.apache.org/jira/browse/BAHIR-94?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889950#comment-15889950 ] ASF GitHub Bot commented on BAHIR-94: - Github user rmetzger commented on the issue: https://github.com/apache/bahir-flink/pull/12 I'm merging this one as well > Apache Flink extension READMEs should include link to Flink's "Linking with > Optional Modules" doc > - > > Key: BAHIR-94 > URL: https://issues.apache.org/jira/browse/BAHIR-94 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: Tzu-Li (Gordon) Tai > > Without this link, Bahir users will most likely bump into questions when > trying to include the connector for Flink cluster execution. > We should also try to improve the overall doc quality of the Flink extensions > for the 1.0 release. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (BAHIR-93) Wrong version in README.md for several Apache Flink extensions
[
https://issues.apache.org/jira/browse/BAHIR-93?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889932#comment-15889932
]
ASF GitHub Bot commented on BAHIR-93:
-
Github user asfgit closed the pull request at:
https://github.com/apache/bahir-flink/pull/10
> Wrong version in README.md for several Apache Flink extensions
> --
>
> Key: BAHIR-93
> URL: https://issues.apache.org/jira/browse/BAHIR-93
> Project: Bahir
> Issue Type: Bug
> Components: Flink Streaming Connectors
>Reporter: Tzu-Li (Gordon) Tai
>
> In several Apache Flink extensions (redis, activemq, netty, etc.), the
> current version is incorrectly {{1.0}} (missing "SNAPSHOT" tag).
> Also, in the akka extension, the version is {{1.0.0-SNAPSHOT}} (From the
> looks of https://www.mail-archive.com/dev@bahir.apache.org/msg00448.html, it
> seems like the agreed version format is "major-minor" for the {{bahir-flink}}
> module).
> Therefore, we should uniformly correct them to be {{1.0-SNAPSHOT}}. I think
> we should do this before creating the first {{bahir-flink}} release.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
[jira] [Commented] (BAHIR-93) Wrong version in README.md for several Apache Flink extensions
[
https://issues.apache.org/jira/browse/BAHIR-93?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889931#comment-15889931
]
ASF subversion and git services commented on BAHIR-93:
--
Commit c06d9d76aeea7ebd338a719996d25f6230896f99 in bahir-flink's branch
refs/heads/master from [~tzulitai]
[ https://git-wip-us.apache.org/repos/asf?p=bahir-flink.git;h=c06d9d7 ]
[BAHIR-93] Correct all version strings to be 1.0-SNAPSHOT
This closes #10
> Wrong version in README.md for several Apache Flink extensions
> --
>
> Key: BAHIR-93
> URL: https://issues.apache.org/jira/browse/BAHIR-93
> Project: Bahir
> Issue Type: Bug
> Components: Flink Streaming Connectors
>Reporter: Tzu-Li (Gordon) Tai
>
> In several Apache Flink extensions (redis, activemq, netty, etc.), the
> current version is incorrectly {{1.0}} (missing "SNAPSHOT" tag).
> Also, in the akka extension, the version is {{1.0.0-SNAPSHOT}} (From the
> looks of https://www.mail-archive.com/dev@bahir.apache.org/msg00448.html, it
> seems like the agreed version format is "major-minor" for the {{bahir-flink}}
> module).
> Therefore, we should uniformly correct them to be {{1.0-SNAPSHOT}}. I think
> we should do this before creating the first {{bahir-flink}} release.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
[jira] [Commented] (BAHIR-94) Apache Flink extension READMEs should include link to Flink's "Linking with Optional Modules" doc
[ https://issues.apache.org/jira/browse/BAHIR-94?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889902#comment-15889902 ] ASF GitHub Bot commented on BAHIR-94: - Github user rmetzger commented on the issue: https://github.com/apache/bahir-flink/pull/12 Good fixes, +1 to merge. > Apache Flink extension READMEs should include link to Flink's "Linking with > Optional Modules" doc > - > > Key: BAHIR-94 > URL: https://issues.apache.org/jira/browse/BAHIR-94 > Project: Bahir > Issue Type: Improvement > Components: Flink Streaming Connectors >Reporter: Tzu-Li (Gordon) Tai > > Without this link, Bahir users will most likely bump into questions when > trying to include the connector for Flink cluster execution. > We should also try to improve the overall doc quality of the Flink extensions > for the 1.0 release. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (BAHIR-90) Bahir website missing docs, source links, download for Flink extensions
[ https://issues.apache.org/jira/browse/BAHIR-90?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889900#comment-15889900 ] Robert Metzger commented on BAHIR-90: - Can somebody give Gordon contributor permissions in this JIRA so that we can assign him to the issue? > Bahir website missing docs, source links, download for Flink extensions > --- > > Key: BAHIR-90 > URL: https://issues.apache.org/jira/browse/BAHIR-90 > Project: Bahir > Issue Type: Task > Components: Website >Affects Versions: Flink-0.1 >Reporter: Christian Kadner > > The [Apache Bahir website|http://bahir.apache.org/] is missing download link, > source repository links and documentation for the Apache Flink extensions. > There also is a typo on the landing page missing the letter L in "Flink". -- This message was sent by Atlassian JIRA (v6.3.15#6346)
Re: Next Releases
I would like to revive the 1.0 release discussion for bahir-flink. I have to admit that I didn't have enough time to do the first release last year. I've asked Gordon (CC, committer at Flink) to help me fixing the documentation and upgrading Bahir to Apache Flink 1.2.0. Once that is done we can start creating the first bahir-flink release (in my opinion). Regarding the actual release creation process, I guess it makes sense to adopt this script: https://github.com/apache/bahir/blob/master/dev/release-build.sh for "bahir-flink"? On Thu, Oct 13, 2016 at 11:44 PM, Luciano Resende wrote: > Good, the sync to maven central was with some issues... > > Let me get a release candidate available soon. > > On Thu, Oct 13, 2016 at 1:50 PM, Ted Yu wrote: > > > Spark 2.0.1 is in maven: > > > > https://repo1.maven.org/maven2/org/apache/spark/spark-core_2.11/2.0.1/ > > > > Time to roll Bahir for Spark 2.0.1 release ? > > > > On Mon, Sep 26, 2016 at 11:48 AM, Ted Yu wrote: > > > > > +1 > > > > > > > On Sep 26, 2016, at 11:33 AM, Jean-Baptiste Onofré > > > wrote: > > > > > > > > +1 > > > > > > > > Regards > > > > JB > > > > > > > >> On 09/26/2016 08:32 PM, Luciano Resende wrote: > > > >> Looks like Spark is working on 2.0.1 release (RC3 being voted now), > > and > > > I > > > >> was wondering if we should use this opportunity to create a Bahir > for > > > Spark > > > >> 2.0.1 release and also a Bahir for Flink 1.0 release. > > > >> > > > >> Thoughts ? > > > > > > > > -- > > > > Jean-Baptiste Onofré > > > > jbono...@apache.org > > > > http://blog.nanthrax.net > > > > Talend - http://www.talend.com > > > > > > > > > -- > Luciano Resende > http://twitter.com/lresende1975 > http://lresende.blogspot.com/ >
[jira] [Commented] (BAHIR-91) Upgrade bahir-flink to support Flink 1.2
[ https://issues.apache.org/jira/browse/BAHIR-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15889880#comment-15889880 ] ASF GitHub Bot commented on BAHIR-91: - Github user rmetzger commented on the issue: https://github.com/apache/bahir-flink/pull/11 I think the travis tests will fail because they are overwriting the Flink version. I have a constant there for the Flink version. My initial plan was to support multiple Flink versions at the same time. Do you think there is an easy way to still support 1.1. and 1.2 with the Bahir connectors? > Upgrade bahir-flink to support Flink 1.2 > > > Key: BAHIR-91 > URL: https://issues.apache.org/jira/browse/BAHIR-91 > Project: Bahir > Issue Type: New Feature > Components: Flink Streaming Connectors >Affects Versions: Flink-0.1 > Environment: Ubuntu Yakkety Yak >Reporter: Markus Müller > Fix For: Flink-0.1 > > > After working around https://issues.apache.org/jira/browse/FLINK-4813 by > specifying Flink version 1.3-SNAPSHOT instead of 1.2.0 in the bahir-flink pom > file, I get the following compiler errors for the ActiveMQ connector: > ERROR] > /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[32,33] > error: cannot find symbol > [ERROR] symbol: class ForkableFlinkMiniCluster > location: package org.apache.flink.test.util > /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[54,19] > error: cannot find symbol > [ERROR] symbol: class ForkableFlinkMiniCluster > location: class ActiveMQConnectorITCase > /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[66,20] > error: cannot find symbol > [ERROR] symbol: class ForkableFlinkMiniCluster > location: class ActiveMQConnectorITCase > /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[216,22] > error: method snapshotState in class > MessageAcknowledgingSourceBase cannot be applied to given types; > [ERROR] required: FunctionSnapshotContext > found: long,long > reason: actual and formal argument lists differ in length > where Type,UId are type-variables: > Type extends Object declared in class MessageAcknowledgingSourceBase > UId extends Object declared in class MessageAcknowledgingSourceBase > /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[229,4] > error: ActiveMQConnectorITCase.TestSourceContext is not abstract and does > not override abstract method markAsTemporarilyIdle() in SourceContext > Excluding ActiveMQ from compilation leads to the next issue in the > Akka-Connector: > [ERROR] > /home/markus/src/bahir-flink/flink-connector-akka/src/test/java/org/apache/flink/streaming/connectors/akka/AkkaSourceTest.java:[210,17] > error: DummySourceContext is not abstract and does not override abstract > method markAsTemporarilyIdle() in SourceContext > [INFO] 1 error -- This message was sent by Atlassian JIRA (v6.3.15#6346)
