[
https://issues.apache.org/jira/browse/FLINK-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9455:
-
Assignee: Till Rohrmann (was: Sihua Zhou)
> Make SlotManager aware of multi slot TaskManagers
[
https://issues.apache.org/jira/browse/FLINK-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513336#comment-16513336
]
Sihua Zhou commented on FLINK-9455:
---
Hi [~till.rohrmann] the more I thought about this , the more I
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513320#comment-16513320
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user XiaoZYang commented on the issue:
Github user XiaoZYang commented on the issue:
https://github.com/apache/flink/pull/5845
@zentol got it! So what you mean is that @sijie and I will keep updating
commits until this work is done and you guys will merge this PR to a new
branch. Later PR will be against the new branch.
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513319#comment-16513319
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user deepaks4077 commented on the issue:
Github user deepaks4077 commented on the issue:
https://github.com/apache/flink/pull/6170
@zentol , please take a look when you get the chance.
I think testSimpleAfterMatchSkip() is failing
[here](https://api.travis-ci.org/v3/job/392551505/log.txt) because the program
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-9567:
---
Description:
After restart the Job Manager in Yarn Cluster mode, sometimes Flink does not
release
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-9567:
---
Description:
After restart the Job Manager in Yarn Cluster mode, sometimes Flink does not
release
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-9567:
---
Description:
After restart the Job Manager in Yarn Cluster mode, sometimes Flink does not
release
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-9567:
---
Priority: Critical (was: Major)
> Flink does not release resource in Yarn Cluster mode
>
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-9567:
---
Attachment: fulllog.txt
> Flink does not release resource in Yarn Cluster mode
>
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-9567:
---
Attachment: FlinkYarnProblem
> Flink does not release resource in Yarn Cluster mode
>
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-9567:
---
Attachment: (was: jobmanager.log)
> Flink does not release resource in Yarn Cluster mode
>
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-9567:
---
Description:
After restart the Job Manager in Yarn Cluster mode, Flink does not release task
[
https://issues.apache.org/jira/browse/FLINK-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513210#comment-16513210
]
ASF GitHub Bot commented on FLINK-9573:
---
Github user zhangminglei commented on a diff in the pull
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6154#discussion_r195613671
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedLeaderService.java
---
@@ -356,8 +357,8 @@
[
https://issues.apache.org/jira/browse/FLINK-9590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9590.
---
Resolution: Fixed
master: 24266fd63b72c76e77ed86e46392f7427e4d1f8b
> HistogramDump should
[
https://issues.apache.org/jira/browse/FLINK-9591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9591.
---
Resolution: Fixed
master: 0dc0e36f204401f14e078d24348421cd4140577d
> Remove remnants of
[
https://issues.apache.org/jira/browse/FLINK-9589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9589.
---
Resolution: Fixed
master: 2fc6499496296cf2aa2408e4e15d684496a169a2
> PythonOperationInfo
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8744.
---
Resolution: Fixed
master: eaff4da15bdd7528dcc0d8a37fd59642cee53850
> Add annotations for
[
https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513144#comment-16513144
]
ASF GitHub Bot commented on FLINK-9530:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513146#comment-16513146
]
ASF GitHub Bot commented on FLINK-8744:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9257.
---
Resolution: Fixed
Fix Version/s: 1.5.1
[
https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513145#comment-16513145
]
ASF GitHub Bot commented on FLINK-9257:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6126
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5843
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6053
---
[
https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9530.
---
Resolution: Fixed
master: 03d77b862b845fc2b2836fc35fdbc8793d5064b7
1.5:
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513016#comment-16513016
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user deepaks4077 commented on the issue:
Github user deepaks4077 commented on the issue:
https://github.com/apache/flink/pull/6170
@zentol, thanks, will do!
---
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513012#comment-16513012
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6083
@tillrohrmann Thanks for the review! I will go through them and will make
the changes shortly.
---
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512985#comment-16512985
]
ASF GitHub Bot commented on FLINK-9563:
---
GitHub user deepaks4077 opened a pull request:
GitHub user deepaks4077 opened a pull request:
https://github.com/apache/flink/pull/6170
[FLINK-9563]: Using a custom sink function for tests in CEPITCase instead
of writing to disk
## What is the purpose of the change
This change modifies the CEPITCase integration test to
[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-9592:
--
Description:
Hi mates, I got a proposal about functionality of BucketingSink.
During
[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail Pryakhin updated FLINK-9592:
Description:
Hi mates, I got a proposal about functionality of BucketingSink.
During
Rinat Sharipov created FLINK-9592:
-
Summary: Notify on moving into pending/ final state
Key: FLINK-9592
URL: https://issues.apache.org/jira/browse/FLINK-9592
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-9592:
--
Summary: Notify on moving file into pending/ final state (was: Notify on
moving into pending/
[
https://issues.apache.org/jira/browse/FLINK-9380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512898#comment-16512898
]
Deepak Sharma commented on FLINK-9380:
--
Hi [~till.rohrmann], would mind giving examples? I might be
Github user etiennecarriere commented on the issue:
https://github.com/apache/flink/pull/6149
@pnowojski , I add a unit test which validate the rate limiting feature but
:
* It add 20s to the unit test . Would it be better to move to Integration
Test (even if it is not an
[
https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512891#comment-16512891
]
ASF GitHub Bot commented on FLINK-9560:
---
Github user etiennecarriere commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512865#comment-16512865
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5845
it is not possible to create a PR against a non-existing branch. We will
either have to create a pulsar-connector branch up front, or open the first PR
against master and merge it into a new branch.
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-5860:
---
Assignee: Mahesh Senniappan (was: Yaroslav Mykhaylov)
> Replace all the file
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512860#comment-16512860
]
Chesnay Schepler commented on FLINK-5860:
-
I'll assign it to you.
> Replace all the file
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512859#comment-16512859
]
Chesnay Schepler commented on FLINK-5860:
-
[~maheshsenni] yes i believe this issue is still
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502481#comment-16502481
]
Mahesh Senniappan edited comment on FLINK-5860 at 6/14/18 6:35 PM:
---
Chesnay Schepler created FLINK-9591:
---
Summary: Remove remnants of distributed-cache logic
Key: FLINK-9591
URL: https://issues.apache.org/jira/browse/FLINK-9591
Project: Flink
Issue Type:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5843
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512814#comment-16512814
]
ASF GitHub Bot commented on FLINK-8744:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512801#comment-16512801
]
ASF GitHub Bot commented on FLINK-9530:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6126
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512796#comment-16512796
]
ASF GitHub Bot commented on FLINK-9257:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6053
merging.
---
Chesnay Schepler created FLINK-9590:
---
Summary: HistogramDump should be immutable
Key: FLINK-9590
URL: https://issues.apache.org/jira/browse/FLINK-9590
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512699#comment-16512699
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user XiaoZYang commented on the issue:
Github user XiaoZYang commented on the issue:
https://github.com/apache/flink/pull/5845
@hsaputra There is no error but the issue is
1. when I create a PR to the flink repo from my fork repo I need to choose
a branch to which the commits are merged to
2. I'm expected to
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512689#comment-16512689
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user hsaputra commented on the issue:
Github user hsaputra commented on the issue:
https://github.com/apache/flink/pull/5845
@XiaoZYang You can close this PR and create new branch to submit new PR
since you are the creator os this one.
Did you see any error or something preventing you to close this one?
---
[
https://issues.apache.org/jira/browse/FLINK-9494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512686#comment-16512686
]
ASF GitHub Bot commented on FLINK-9494:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9573.
Resolution: Fixed
Fix Version/s: 1.5.1
1.6.0
Fixed via
1.6.0:
[
https://issues.apache.org/jira/browse/FLINK-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512687#comment-16512687
]
ASF GitHub Bot commented on FLINK-9573:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6154
---
[
https://issues.apache.org/jira/browse/FLINK-9494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9494.
Resolution: Fixed
Fixed via
1.6.0: 7e51b90d909c6feaac6ed48140df00372e95a45c
1.5.1:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6155
---
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512682#comment-16512682
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user XiaoZYang commented on the issue:
Github user XiaoZYang commented on the issue:
https://github.com/apache/flink/pull/5845
I prefer to open a new PR and a new branch. But I am not authorized to do
that.
---
Chesnay Schepler created FLINK-9589:
---
Summary: PythonOperationInfo should be immutable
Key: FLINK-9589
URL: https://issues.apache.org/jira/browse/FLINK-9589
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512652#comment-16512652
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512661#comment-16512661
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512668#comment-16512668
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512648#comment-16512648
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512649#comment-16512649
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512666#comment-16512666
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512656#comment-16512656
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512670#comment-16512670
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512667#comment-16512667
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512650#comment-16512650
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512646#comment-16512646
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512654#comment-16512654
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512659#comment-16512659
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512662#comment-16512662
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512645#comment-16512645
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512658#comment-16512658
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512669#comment-16512669
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512664#comment-16512664
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512660#comment-16512660
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512647#comment-16512647
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512671#comment-16512671
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512651#comment-16512651
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512663#comment-16512663
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512665#comment-16512665
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512657#comment-16512657
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512653#comment-16512653
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16512655#comment-16512655
]
ASF GitHub Bot commented on FLINK-8983:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r195464034
--- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml ---
@@ -0,0 +1,228 @@
+
+http://maven.apache.org/POM/4.0.0;
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r195464899
--- Diff: flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml ---
@@ -0,0 +1,228 @@
+
+http://maven.apache.org/POM/4.0.0;
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r195465238
--- Diff:
flink-end-to-end-tests/flink-confluent-schema-registry/src/main/java/AvroDeserializationConfluentSchema.java
---
@@ -0,0 +1,85 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r195473522
--- Diff:
flink-end-to-end-tests/flink-confluent-schema-registry/src/main/java/AvroSerializationConfluentSchema.java
---
@@ -0,0 +1,93 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6083#discussion_r195469740
--- Diff:
flink-end-to-end-tests/flink-confluent-schema-registry/src/main/java/AvroDeserializationConfluentSchema.java
---
@@ -0,0 +1,85 @@
+/*
1 - 100 of 218 matches
Mail list logo
