[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513429#comment-16513429 ] ASF GitHub Bot commented on FLINK-9187: --- Github user zentol commented on a diff in

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r195644101 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79 @@

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513423#comment-16513423 ] ASF GitHub Bot commented on FLINK-9187: --- Github user zentol commented on a diff in

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r195643808 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79 @@

[jira] [Commented] (FLINK-9567) Flink does not release resource in Yarn Cluster mode

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513390#comment-16513390 ] Shimin Yang commented on FLINK-9567: I modified the onContainerCompleted method and r

[jira] [Assigned] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers

[ 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 >

[jira] [Commented] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513336#comment-16513336 ] Sihua Zhou commented on FLINK-9455: --- Hi [~till.rohrmann] the more I thought about this

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513320#comment-16513320 ] ASF GitHub Bot commented on FLINK-9168: --- Github user XiaoZYang commented on the iss

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

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. Di

[jira] [Commented] (FLINK-9563) Migrate integration tests for CEP

[ https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513319#comment-16513319 ] ASF GitHub Bot commented on FLINK-9563: --- Github user deepaks4077 commented on the i

[GitHub] flink issue #6170: [FLINK-9563]: Using a custom sink function for tests in C...

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 arrived

[jira] [Updated] (FLINK-9567) 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, sometimes Flink does not release ta

[jira] [Updated] (FLINK-9567) 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, sometimes Flink does not release ta

[jira] [Updated] (FLINK-9567) 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, sometimes Flink does not release ta

[jira] [Updated] (FLINK-9567) 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: --- Priority: Critical (was: Major) > Flink does not release resource in Yarn Cluster mode > ---

[jira] [Updated] (FLINK-9567) 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 >

[jira] [Updated] (FLINK-9567) 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 > ---

[jira] [Updated] (FLINK-9567) 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 > --

[jira] [Updated] (FLINK-9567) 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 manager

[jira] [Commented] (FLINK-9573) Check for leadership with leader session id

[ https://issues.apache.org/jira/browse/FLINK-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513210#comment-16513210 ] ASF GitHub Bot commented on FLINK-9573: --- Github user zhangminglei commented on a di

[GitHub] flink pull request #6154: [FLINK-9573] Extend LeaderElectionService#hasLeade...

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 @@ publi

[jira] [Closed] (FLINK-9590) HistogramDump should be immutable

[ 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 be

[jira] [Closed] (FLINK-9591) Remove remnants of distributed-cache logic

[ 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 dist

[jira] [Closed] (FLINK-9589) PythonOperationInfo should be immutable

[ 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 sho

[jira] [Closed] (FLINK-8744) Add annotations for documenting common/advanced options

[ 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 doc

[jira] [Commented] (FLINK-9530) Task numRecords metrics broken for chains

[ https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513144#comment-16513144 ] ASF GitHub Bot commented on FLINK-9530: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8744) Add annotations for documenting common/advanced options

[ https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513146#comment-16513146 ] ASF GitHub Bot commented on FLINK-8744: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

[ 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 master:45ac85e2c4ec66ff02e4277c1781247710252a26

[jira] [Commented] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

[ https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513145#comment-16513145 ] ASF GitHub Bot commented on FLINK-9257: --- Github user asfgit closed the pull request

[GitHub] flink pull request #6126: [FLINK-9530][metrics] Fix numRecords task metric f...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6126 ---

[GitHub] flink pull request #5843: [FLINK-8744][docs] Generate "Common Option" sectio...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5843 ---

[GitHub] flink pull request #6053: [FLINK-9257][E2E Tests] Fix wrong "All tests pass"...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6053 ---

[jira] [Closed] (FLINK-9530) Task numRecords metrics broken for chains

[ 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: 246ef1d291ef8ba6907c

[jira] [Commented] (FLINK-9563) Migrate integration tests for CEP

[ https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513016#comment-16513016 ] ASF GitHub Bot commented on FLINK-9563: --- Github user deepaks4077 commented on the i

[GitHub] flink issue #6170: [FLINK-9563]: Using a custom sink function for tests in C...

Github user deepaks4077 commented on the issue: https://github.com/apache/flink/pull/6170 @zentol, thanks, will do! ---

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513012#comment-16513012 ] ASF GitHub Bot commented on FLINK-8983: --- Github user medcv commented on the issue:

[GitHub] flink issue #6083: [FLINK-8983] End-to-end test: Confluent schema registry

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. ---

[jira] [Commented] (FLINK-9563) Migrate integration tests for CEP

[ https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512985#comment-16512985 ] ASF GitHub Bot commented on FLINK-9563: --- GitHub user deepaks4077 opened a pull requ

[GitHub] flink pull request #6170: [FLINK-9563]: Using a custom sink function for tes...

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

[jira] [Updated] (FLINK-9592) Notify on moving file into pending/ final state

[ 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 implem

[jira] [Updated] (FLINK-9592) Notify on moving file into pending/ final state

[ 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 impl

[jira] [Created] (FLINK-9592) Notify on moving into pending/ final state

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 Fe

[jira] [Updated] (FLINK-9592) Notify on moving file into pending/ final state

[ 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/

[jira] [Commented] (FLINK-9380) Failing end-to-end tests should not clean up logs

[ https://issues.apache.org/jira/browse/FLINK-9380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512898#comment-16512898 ] Deepak Sharma commented on FLINK-9380: -- Hi [~till.rohrmann], would mind giving examp

[GitHub] flink issue #6149: [FLINK-9560] Add RateLimiting for FileSystem

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 Integra

[jira] [Commented] (FLINK-9560) RateLimiting for FileSystem

[ https://issues.apache.org/jira/browse/FLINK-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512891#comment-16512891 ] ASF GitHub Bot commented on FLINK-9560: --- Github user etiennecarriere commented on t

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512865#comment-16512865 ] ASF GitHub Bot commented on FLINK-9168: --- Github user zentol commented on the issue:

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

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. I

[jira] [Assigned] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

[ 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 creati

[jira] [Commented] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

[ https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512860#comment-16512860 ] Chesnay Schepler commented on FLINK-5860: - I'll assign it to you. > Replace all

[jira] [Commented] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

[ https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512859#comment-16512859 ] Chesnay Schepler commented on FLINK-5860: - [~maheshsenni] yes i believe this issu

[jira] [Comment Edited] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

[ https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16502481#comment-16502481 ] Mahesh Senniappan edited comment on FLINK-5860 at 6/14/18 6:35 PM:

[jira] [Created] (FLINK-9591) Remove remnants of distributed-cache logic

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: Bu

[GitHub] flink issue #5843: [FLINK-8744][docs] Generate "Common Option" section

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5843 merging. ---

[jira] [Commented] (FLINK-8744) Add annotations for documenting common/advanced options

[ https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512814#comment-16512814 ] ASF GitHub Bot commented on FLINK-8744: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-9530) Task numRecords metrics broken for chains

[ https://issues.apache.org/jira/browse/FLINK-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512801#comment-16512801 ] ASF GitHub Bot commented on FLINK-9530: --- Github user zentol commented on the issue:

[GitHub] flink issue #6126: [FLINK-9530][metrics] Fix numRecords task metric for chai...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6126 merging. ---

[jira] [Commented] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

[ https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512796#comment-16512796 ] ASF GitHub Bot commented on FLINK-9257: --- Github user zentol commented on the issue:

[GitHub] flink issue #6053: [FLINK-9257][E2E Tests] Fix wrong "All tests pass" messag...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6053 merging. ---

[jira] [Created] (FLINK-9590) HistogramDump should be immutable

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

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512699#comment-16512699 ] ASF GitHub Bot commented on FLINK-9168: --- Github user XiaoZYang commented on the iss

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

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 merge

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512689#comment-16512689 ] ASF GitHub Bot commented on FLINK-9168: --- Github user hsaputra commented on the issu

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

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? ---

[jira] [Commented] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship

[ https://issues.apache.org/jira/browse/FLINK-9494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512686#comment-16512686 ] ASF GitHub Bot commented on FLINK-9494: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-9573) Check for leadership with leader session id

[ 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: 363de6b6436

[jira] [Commented] (FLINK-9573) Check for leadership with leader session id

[ https://issues.apache.org/jira/browse/FLINK-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512687#comment-16512687 ] ASF GitHub Bot commented on FLINK-9573: --- Github user asfgit closed the pull request

[GitHub] flink pull request #6154: [FLINK-9573] Extend LeaderElectionService#hasLeade...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6154 ---

[jira] [Closed] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship

[ 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: a9787d7fb616d231

[GitHub] flink pull request #6155: [FLINK-9494] Fix race condition in Dispatcher with...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6155 ---

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512682#comment-16512682 ] ASF GitHub Bot commented on FLINK-9168: --- Github user XiaoZYang commented on the iss

[GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

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. ---

[jira] [Created] (FLINK-9589) PythonOperationInfo should be immutable

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

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512652#comment-16512652 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512661#comment-16512661 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512668#comment-16512668 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512648#comment-16512648 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512649#comment-16512649 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512666#comment-16512666 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512656#comment-16512656 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512670#comment-16512670 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512667#comment-16512667 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512650#comment-16512650 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512646#comment-16512646 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512654#comment-16512654 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512659#comment-16512659 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512662#comment-16512662 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512645#comment-16512645 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512658#comment-16512658 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512669#comment-16512669 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512664#comment-16512664 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512660#comment-16512660 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512647#comment-16512647 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512671#comment-16512671 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512651#comment-16512651 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512663#comment-16512663 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512665#comment-16512665 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512657#comment-16512657 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512653#comment-16512653 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-8983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512655#comment-16512655 ] ASF GitHub Bot commented on FLINK-8983: --- Github user tillrohrmann commented on a di

  1   2   3   >