[
https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841927#comment-16841927
]
Ivan Mushketyk commented on FLINK-5243:
---
[~jasleenk22] I think a better perso
[
https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16839117#comment-16839117
]
Ivan Mushketyk edited comment on FLINK-5243 at 5/14/19 9:0
[
https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16839117#comment-16839117
]
Ivan Mushketyk commented on FLINK-5243:
---
Sure Jasleen. Go ahead.
> Im
Ivan Mushketyk created FLINK-8315:
-
Summary: Use AWSCredentialsProvider to get AWS credentials
Key: FLINK-8315
URL: https://issues.apache.org/jira/browse/FLINK-8315
Project: Flink
Issue Type
Ivan Mushketyk created FLINK-8314:
-
Summary: Add support for Kinesis Firehose
Key: FLINK-8314
URL: https://issues.apache.org/jira/browse/FLINK-8314
Project: Flink
Issue Type: New Feature
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2367
@kl0u Sure.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
Github user mushketyk closed the pull request at:
https://github.com/apache/flink/pull/2367
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user mushketyk closed the pull request at:
https://github.com/apache/flink/pull/2396
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2396
Closed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2361
Closed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
Github user mushketyk closed the pull request at:
https://github.com/apache/flink/pull/2361
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927063#comment-15927063
]
Ivan Mushketyk commented on FLINK-3414:
---
Hi [~dawidwys]
I don't have tim
[
https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3414:
-
Assignee: Dawid Wysakowicz (was: Ivan Mushketyk)
> Add Scala API for CEP's
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2361
Hi @kl0u
Sorry for the long delay. I don't have any free time to allocate to
contribute to Flink, so I don't mind if @dawidwys works on this.
---
If your project is set up f
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3206
@zentol Sure. Thank you for merging this!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user mushketyk closed the pull request at:
https://github.com/apache/flink/pull/3206
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2431
Hi @uce
I tried the latest version in the `master` branch and it seems that submit
does not work there.
https://cloud.githubusercontent.com/assets/592286/22408446/eefd13c0-e670
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2448
Hi @uce,
I've rebased changes and updated the UI according to your suggestion. Now
it looks like:
https://cloud.githubusercontent.com/assets/592286/22408112/2165724a-e66b-11e6
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3234
[FLINK-5684][web frontend] Add MacOS section to README.md
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
Title: Message Title
Ivan Mushketyk created an issue
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2448
Hi @uce
Thank you for your review.
I'll update the UI in the next couple of days.
---
If your project is set up for it, you can reply to this email and have your
reply a
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2431
Hi @uce,
No worries about the long delay. Just write here if you decide to merge it
and I'll rebase it.
Best regards,
Ivan.
---
If your project is set up for it, yo
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3206
Thank you @StephanEwen !
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2396
Hi @kl0u,
I've rebased the PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this fe
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3206
Hi @StephanEwen, @zentol
Thank you for helping with this PR.
I've updated it according to your review.
---
If your project is set up for it, you can reply to this email and have
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2396
Thank you for looking into this!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2396
Hi @kl0u,
Sure. I'll rebase it today.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2361
Got it Let me check how it works with the current code and I'll come back
with a proposed solution.
---
If your project is set up for it, you can reply to this email and have your
reply appe
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2361
Let's see if I understand correctly the test case you are describing. Do
you mean that a pattern like:
```java
begin().oneOrMany().where("a")
.next().opti
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2361
Hi @kl0u
Thank you for your suggestions.
I don't have a concrete solution yet, but I can try to fill the gaps in
testing and see if I can come up with a better sol
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2361
Hi @kl0u,
Yes you are right. It should work fine without the "end" event and if it
does not work it is a bug.
I'll take a look at this in the next few days, rebase the
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3206
Hi @StephanEwen, @zentol
Thank you for your comments. I've update the PR accordingly.
---
If your project is set up for it, you can reply to this email and have your
reply appe
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2361
Hi @kl0u,
Sorry for misunderstanding, I still don't understand the problem :)
Let's select a test and go through it. For example in the test
`testOneOrMoreCEPPat
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3206
[FLINK-5612] Fix GlobPathFilter not-serializable exception
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
[
https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-5612:
-
Assignee: Ivan Mushketyk
> GlobPathFilter not-serializable except
[
https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15834483#comment-15834483
]
Ivan Mushketyk commented on FLINK-5612:
---
I'll fix it.
> GlobPa
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2396
Hi @chermenin,
To avoid rebasing this PR multiple times I'll wait until Till or another
core reviewer will be available to review and merge this pull request.
Feel free to r
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2396
Hi @chermenin ,
Sure, I'll do it tomorrow.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3124
[FLINK-5281] Extend KafkaJsonTableSources to support nested data
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3871:
-
Assignee: Ivan Mushketyk
> Add Kafka TableSource with Avro serializat
[
https://issues.apache.org/jira/browse/FLINK-5281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-5281:
-
Assignee: Ivan Mushketyk
> Extend KafkaJsonTableSources to support nested d
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @fhueske, @wuchong
Thank you for your reviews and your help with this PR.
I've updated the PR.
---
If your project is set up for it, you can reply to this email and have
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r95333198
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -19,22 +19,23 @@
package
[
https://issues.apache.org/jira/browse/FLINK-5360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk closed FLINK-5360.
-
Resolution: Fixed
> Fix arguments names in WindowedStr
Github user mushketyk closed the pull request at:
https://github.com/apache/flink/pull/3022
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3022
Thank you @aljoscha, @xhumanoid
Closing the issue.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3022
Hi @xhumanoid,
Sorry, I didn't notice that the same applies to `minBy` :)
I've updated the code according to your review.
Could you please review it again?
---
If your
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @fhueske, @wuchong
I've updated the PR according to your feedback.
Could you please review it again?
---
If your project is set up for it, you can reply to this email and
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
@fhueske @wuchong Makes sense to me as well.
I'll try to update the PR during the weekend.
---
If your project is set up for it, you can reply to this email and have your
reply appe
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
@fhueske
Sorry, there are only two methods. Please ignore my comment :)
I think you are right and this seems like a good approach. If @wuchong is
on board with this I'll u
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
I don't think we will win a lot with this. Even if we remove these two
methods from the `TableSource` trait interface there is still `getTypeIndices`
method and Java users will have to call
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
I don't think I got the idea :) Could you elaborate on it?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project doe
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @fhueske, @wuchong
I think we can solve the problem with current `TableSource` class hierarchy
in a different way. If we remove all abstract classes and move all default
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r94865876
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/AbstractBatchStreamTableSource.scala
---
@@ -0,0 +1,30
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @wuchong
>> And provide three other abstract class : BatchTableSource (with
getDataSet interface) , StreamTableSource (with getDataStream interface) and
BatchStreamTableSource
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @fhueske, @wuchong
I've updated my PR according to your reviews.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3022
Hi @xhumanoid
I've updated my PR according to your review.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r94087339
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -268,23 +268,9 @@ object
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @fhueske, @wuchong
Thank you for your reviews.
I think creating three abstract classes is a good idea, since we don't
expect any new types of table sources, so there wil
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @wuchong
I've updated the PR according to your comments. Could you please review it
again?
---
If your project is set up for it, you can reply to this email and have your
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93797831
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -340,25 +331,8 @@ abstract class
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93764349
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -111,24
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @wuchong
Thank you for review. I'll try to update the PR today.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93762225
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TableSourceTable.scala
---
@@ -25,6 +25,6 @@ import
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93762178
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTable.scala
---
@@ -44,14 +44,14 @@ abstract class FlinkTable
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93762127
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/BatchTableSourceScan.scala
---
@@ -38,7 +38,9 @@ class
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93762016
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TableSourceTable.scala
---
@@ -25,6 +25,6 @@ import
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761979
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -111,24
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761987
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -111,24
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761841
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -19,21 +19,32 @@
package
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761823
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -19,21 +19,32 @@
package
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761791
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala
---
@@ -19,21 +19,32 @@
package
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761574
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761556
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761548
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761442
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/3039#discussion_r93761407
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -535,4 +509,74 @@ object TableEnvironment
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3039
[FLINK-5280] Update TableSource to support nested data
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15770498#comment-15770498
]
Ivan Mushketyk commented on FLINK-5280:
---
Hi guys,
I like your idea, Fabian,
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15769924#comment-15769924
]
Ivan Mushketyk commented on FLINK-5280:
---
Hi [~fhueske]
{quote}
We could
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15769556#comment-15769556
]
Ivan Mushketyk commented on FLINK-5280:
---
Hi [~fhueske]
Thank you for the great
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765160#comment-15765160
]
Ivan Mushketyk commented on FLINK-5280:
---
Hi Fabian,
Thank you for your reply.
[
https://issues.apache.org/jira/browse/FLINK-5244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-5244:
-
Assignee: Ivan Mushketyk
> Implement methods for BipartiteGraph transformati
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3032
[FLINK-5245] Implement BipartiteGraph mutations
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2314
The Bahir PR was merged in closed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user mushketyk closed the pull request at:
https://github.com/apache/flink/pull/2314
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3024
[FLINK-5362] Implement methods to access BipartiteGraph properties
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
Ivan Mushketyk created FLINK-5362:
-
Summary: Implement methods to access BipartiteGraph properties
Key: FLINK-5362
URL: https://issues.apache.org/jira/browse/FLINK-5362
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk closed FLINK-3298.
-
Resolution: Fixed
> Streaming connector for Activ
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758501#comment-15758501
]
Ivan Mushketyk commented on FLINK-3298:
---
Bahir PR was accepted.
Closing the i
[
https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3427:
-
Assignee: (was: Ivan Mushketyk)
> Add watermark monitoring to JobManager
[
https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-4029:
-
Assignee: (was: Ivan Mushketyk)
> Multi-field "sum" function jus
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3022
[FLINK-5360] Fix argument names in WindowedStream
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Ivan Mushketyk created FLINK-5360:
-
Summary: Fix arguments names in WindowedStream
Key: FLINK-5360
URL: https://issues.apache.org/jira/browse/FLINK-5360
Project: Flink
Issue Type: Bug
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2985
Rebased this PR on top of `master`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15754948#comment-15754948
]
Ivan Mushketyk commented on FLINK-5280:
---
Thank you for working on it. I'
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3015
[FLINK-5349] Fix typos in Twitter connector code sample
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
Ivan Mushketyk created FLINK-5349:
-
Summary: Fix code sample for Twitter connector
Key: FLINK-5349
URL: https://issues.apache.org/jira/browse/FLINK-5349
Project: Flink
Issue Type: Bug
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2984
Hi @vasia , thank you for your review!
I've added the warning to the Bipartite Graph page.
I am a bit reluctant to rename "Graph transformations" though since I
wanted
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751685#comment-15751685
]
Ivan Mushketyk commented on FLINK-5280:
---
Hi [~jark]
Your suggestion makes sens
1 - 100 of 518 matches
Mail list logo
