[GitHub] dawidwys closed pull request #7089: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

dawidwys closed pull request #7089: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7089 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686182#comment-16686182 ] ASF GitHub Bot commented on FLINK-10419: dawidwys closed pull request #7089: [FLINK-10419] Using

[jira] [Commented] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions`

[ https://issues.apache.org/jira/browse/FLINK-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686220#comment-16686220 ] sunjincheng commented on FLINK-10875: - Hi, [~fhueske]  [~twalthr] , does this change make sense to

[GitHub] azagrebin commented on a change in pull request #6989: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination

azagrebin commented on a change in pull request #6989: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination URL: https://github.com/apache/flink/pull/6989#discussion_r233363582 ## File path:

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686228#comment-16686228 ] ASF GitHub Bot commented on FLINK-10455: azagrebin commented on a change in pull request #6989:

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686192#comment-16686192 ] ASF GitHub Bot commented on FLINK-10419: dawidwys opened a new pull request #7093:

[GitHub] dawidwys opened a new pull request #7093: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

dawidwys opened a new pull request #7093: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7093 ## What is the purpose of the change Invoking `declineCheckpoint` RPC endpoint with `DeclineCheckpoint`

[GitHub] zhijiangW commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

zhijiangW commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#discussion_r233348674 ## File path:

[jira] [Commented] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686214#comment-16686214 ] Miguel E. Coimbra commented on FLINK-10867: --- I intend to work on this and thought about the

[jira] [Created] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions`

sunjincheng created FLINK-10875: --- Summary: Add `toTableWithTimestamp` method in `DataStreamConversions` Key: FLINK-10875 URL: https://issues.apache.org/jira/browse/FLINK-10875 Project: Flink

[GitHub] dawidwys commented on issue #7090: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

dawidwys commented on issue #7090: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7090#issuecomment-438577794 @tillrohrmann do you think it is ok to backport #7005? The `ClassLoaderUtils` were introduced

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686201#comment-16686201 ] ASF GitHub Bot commented on FLINK-10843: twalthr commented on a change in pull request #7087:

[jira] [Closed] (FLINK-10620) Remove the dependency on the version string literal.

[ https://issues.apache.org/jira/browse/FLINK-10620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-10620. Resolution: Duplicate > Remove the dependency on the version string literal. >

[jira] [Created] (FLINK-10876) Deadlock if closing firstly pending transactions in FlinkKafkaProducer(011).close()

Andrey Zagrebin created FLINK-10876: --- Summary: Deadlock if closing firstly pending transactions in FlinkKafkaProducer(011).close() Key: FLINK-10876 URL: https://issues.apache.org/jira/browse/FLINK-10876

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686187#comment-16686187 ] ASF GitHub Bot commented on FLINK-10843: twalthr commented on a change in pull request #7087:

[GitHub] twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#discussion_r233347043 ## File path: docs/dev/table/connect.md ## @@ -524,7 +525,8 @@ The Kafka

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686195#comment-16686195 ] ASF GitHub Bot commented on FLINK-10419: dawidwys commented on issue #7090: [FLINK-10419] Using

[GitHub] twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#discussion_r233353227 ## File path:

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686205#comment-16686205 ] ASF GitHub Bot commented on FLINK-10843: twalthr commented on a change in pull request #7087:

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686178#comment-16686178 ] ASF GitHub Bot commented on FLINK-10134: XuQianJin-Stars opened a new pull request #7092:

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686193#comment-16686193 ] ASF GitHub Bot commented on FLINK-10820: zhijiangW commented on a change in pull request #7051:

[GitHub] dawidwys commented on a change in pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests

dawidwys commented on a change in pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests URL: https://github.com/apache/flink/pull/7077#discussion_r233352507 ## File path: flink-end-to-end-tests/test-scripts/test_shaded_hadoop_s3a.sh

[jira] [Commented] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686204#comment-16686204 ] ASF GitHub Bot commented on FLINK-10736: dawidwys commented on a change in pull request #7077:

[jira] [Created] (FLINK-10874) Kafka 2.0 connector testMigrateFromAtLeastOnceToExactlyOnce failure

Piotr Nowojski created FLINK-10874: -- Summary: Kafka 2.0 connector testMigrateFromAtLeastOnceToExactlyOnce failure Key: FLINK-10874 URL: https://issues.apache.org/jira/browse/FLINK-10874 Project:

[GitHub] pnowojski closed pull request #6989: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination

pnowojski closed pull request #6989: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination URL: https://github.com/apache/flink/pull/6989 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686224#comment-16686224 ] ASF GitHub Bot commented on FLINK-10455: pnowojski closed pull request #6989:

[GitHub] vthinkxie commented on issue #7086: [FLINK-10858] Create Angular Scaffold in Flink Dashboard

vthinkxie commented on issue #7086: [FLINK-10858] Create Angular Scaffold in Flink Dashboard URL: https://github.com/apache/flink/pull/7086#issuecomment-438589045 cc @tillrohrmann This is an automated message from the

[GitHub] twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#discussion_r233351993 ## File path:

[jira] [Closed] (FLINK-10766) Add a link to flink-china.org in Flink website

[ https://issues.apache.org/jira/browse/FLINK-10766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-10766. --- Resolution: Won't Fix > Add a link to flink-china.org in Flink website >

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686197#comment-16686197 ] ASF GitHub Bot commented on FLINK-10843: twalthr commented on a change in pull request #7087:

[GitHub] twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#discussion_r233350930 ## File path:

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686200#comment-16686200 ] ASF GitHub Bot commented on FLINK-10843: twalthr commented on a change in pull request #7087:

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686199#comment-16686199 ] ASF GitHub Bot commented on FLINK-10843: twalthr commented on a change in pull request #7087:

[GitHub] twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#discussion_r233351993 ## File path:

[GitHub] twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

twalthr commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#discussion_r233351993 ## File path:

[jira] [Commented] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686221#comment-16686221 ] vinoyang commented on FLINK-10867: -- hi [~mcoimbra] Thanks for your idea. I think this is a nice

[GitHub] 1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r233364405 ## File path:

[jira] [Commented] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686246#comment-16686246 ] Chesnay Schepler commented on FLINK-10857: -- Your test is broken since your {{FrontMetricGroup}}

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686267#comment-16686267 ] ASF GitHub Bot commented on FLINK-7155: --- zentol commented on a change in pull request #6976:

[GitHub] zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r233375997 ## File path:

[jira] [Commented] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686283#comment-16686283 ] Chesnay Schepler commented on FLINK-10857: -- Correct, i can confirm the issue. Looks like this

[jira] [Created] (FLINK-10877) Remove duplicate dependency entries in kafka connector pom

Till Rohrmann created FLINK-10877: - Summary: Remove duplicate dependency entries in kafka connector pom Key: FLINK-10877 URL: https://issues.apache.org/jira/browse/FLINK-10877 Project: Flink

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686282#comment-16686282 ] Chesnay Schepler commented on FLINK-10864: -- When you say {{all the REST API}} it naturally also

[jira] [Commented] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686340#comment-16686340 ] ASF GitHub Bot commented on FLINK-10736: azagrebin commented on a change in pull request #7077:

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686341#comment-16686341 ] Stephan Ewen commented on FLINK-10864: -- Is this about listing main classes in jar file? If yes,

[GitHub] zentol commented on issue #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test

zentol commented on issue #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test URL: https://github.com/apache/flink/pull/7056#issuecomment-438618845 > Also it is worth adding a line in the README for the Prometheus and this test that states that you can run them locally

[jira] [Created] (FLINK-10878) State evolution E2E test failed on travis

Chesnay Schepler created FLINK-10878: Summary: State evolution E2E test failed on travis Key: FLINK-10878 URL: https://issues.apache.org/jira/browse/FLINK-10878 Project: Flink Issue

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686368#comment-16686368 ] Flavio Pompermaier commented on FLINK-10864: I don't suggest to scan the entire jar, just to

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686413#comment-16686413 ] Chesnay Schepler commented on FLINK-10864: -- I don't like the idea of introducing a separate

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686407#comment-16686407 ] Stephan Ewen commented on FLINK-10864: -- I am skeptical about that, to be honest. This seems very

[jira] [Commented] (FLINK-10852) Decremented number of unfinished producers below 0. This is most likely a bug in the execution state/intermediate result partition management

[ https://issues.apache.org/jira/browse/FLINK-10852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686417#comment-16686417 ] Stephan Ewen commented on FLINK-10852: -- {{jobmanager.execution.failover-strategy}} is very much a

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686241#comment-16686241 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on issue #6594: [FLINK-9311]

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686273#comment-16686273 ] Flavio Pompermaier commented on FLINK-10864: That's fine, but ideally I show the user the

[jira] [Assigned] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-10857: Assignee: Chesnay Schepler > Conflict between JMX and Prometheus Metrics

[jira] [Resolved] (FLINK-10856) Harden resume from externalized checkpoint E2E test

[ https://issues.apache.org/jira/browse/FLINK-10856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10856. --- Resolution: Fixed Fixed via master:

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686459#comment-16686459 ] Flavio Pompermaier commented on FLINK-10864: What about program-class attribute? Also that

[GitHub] twalthr commented on issue #7045: [hotfix] Update nightly master cron jobs

twalthr commented on issue #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045#issuecomment-438646738 The changes have been applied to `cron-master-e2e` and `cron-1.7-e2e`. This is

[GitHub] twalthr closed pull request #7045: [hotfix] Update nightly master cron jobs

twalthr closed pull request #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull

[jira] [Commented] (FLINK-10858) Create Angular Scaffold in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686223#comment-16686223 ] ASF GitHub Bot commented on FLINK-10858: vthinkxie commented on issue #7086: [FLINK-10858]

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686249#comment-16686249 ] Chesnay Schepler commented on FLINK-10864: -- When running a jar you can specify an

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686231#comment-16686231 ] ASF GitHub Bot commented on FLINK-7155: --- 1u0 commented on a change in pull request #6976:

[jira] [Commented] (FLINK-10856) Harden resume from externalized checkpoint E2E test

[ https://issues.apache.org/jira/browse/FLINK-10856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686290#comment-16686290 ] ASF GitHub Bot commented on FLINK-10856: tillrohrmann closed pull request #7088: [FLINK-10856]

[jira] [Commented] (FLINK-10856) Harden resume from externalized checkpoint E2E test

[ https://issues.apache.org/jira/browse/FLINK-10856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686288#comment-16686288 ] ASF GitHub Bot commented on FLINK-10856: tillrohrmann commented on issue #7088: [FLINK-10856]

[GitHub] tillrohrmann closed pull request #7088: [FLINK-10856] Take latest checkpoint to resume from in resume from externalized checkpoint e2e test

tillrohrmann closed pull request #7088: [FLINK-10856] Take latest checkpoint to resume from in resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7088 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[jira] [Commented] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686302#comment-16686302 ] Stefan Richter commented on FLINK-10828: Interesting sidenode, it seems like the problem is

[jira] [Updated] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10867: --- Labels: pull-request-available (was: ) > Add a DataSet-based CacheOperator to reuse

[jira] [Updated] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10857: - Affects Version/s: 1.7.0 1.5.5 > Conflict between JMX and

[jira] [Commented] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686345#comment-16686345 ] vinoyang commented on FLINK-10867: -- [~Zentol] Maybe the PR you submitted should not bind to this issue?

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686342#comment-16686342 ] ASF GitHub Bot commented on FLINK-10634: zentol commented on issue #7056:

[jira] [Commented] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686331#comment-16686331 ] ASF GitHub Bot commented on FLINK-10867: zentol opened a new pull request #7095:

[jira] [Commented] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686346#comment-16686346 ] Chesnay Schepler commented on FLINK-10867: -- [~yanghua] Yes, thanks! It should point to

[jira] [Commented] (FLINK-10874) Kafka 2.0 connector testMigrateFromAtLeastOnceToExactlyOnce failure

[ https://issues.apache.org/jira/browse/FLINK-10874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686361#comment-16686361 ] Piotr Nowojski commented on FLINK-10874: Google search for this error suggests that usually this

[jira] [Updated] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel E. Coimbra updated FLINK-10867: -- Description: *Motivation.* There are job scenarios where Flink batch processing

[jira] [Updated] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel E. Coimbra updated FLINK-10867: -- Description: *Motivation.* There are job scenarios where Flink batch processing

[GitHub] nielsbasjes commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

nielsbasjes commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-438593620 I check why the build failed and all I could find is this: [FAIL] 'Kafka

[jira] [Commented] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686264#comment-16686264 ] Truong Duc Kien commented on FLINK-10857: - I've updated my code, even when {{FrontMetricGroup}}

[jira] [Commented] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686263#comment-16686263 ] ASF GitHub Bot commented on FLINK-10736: zentol commented on a change in pull request #7077:

[GitHub] zentol commented on a change in pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests

zentol commented on a change in pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests URL: https://github.com/apache/flink/pull/7077#discussion_r233374112 ## File path: flink-end-to-end-tests/test-scripts/test_shaded_presto_s3.sh

[jira] [Commented] (FLINK-10864) Support multiple Main classes per jar

[ https://issues.apache.org/jira/browse/FLINK-10864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686276#comment-16686276 ] Flavio Pompermaier commented on FLINK-10864: Just to be clear, you're talking about

[jira] [Commented] (FLINK-10862) REST API does not show program descriptions of "simple" ProgramDescription

[ https://issues.apache.org/jira/browse/FLINK-10862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686343#comment-16686343 ] Stephan Ewen commented on FLINK-10862: -- The ProgramDescription is a bit of an artifact that we

[jira] [Commented] (FLINK-10862) REST API does not show program descriptions of "simple" ProgramDescription

[ https://issues.apache.org/jira/browse/FLINK-10862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686391#comment-16686391 ] Flavio Pompermaier commented on FLINK-10862: What do you mean with "proper artifact

[jira] [Reopened] (FLINK-10856) Harden resume from externalized checkpoint E2E test

[ https://issues.apache.org/jira/browse/FLINK-10856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-10856: -- The latest fix introduced a new instability where we attempt to resume from an

[jira] [Created] (FLINK-10881) SavepointITCase deadlocks on travis

Chesnay Schepler created FLINK-10881: Summary: SavepointITCase deadlocks on travis Key: FLINK-10881 URL: https://issues.apache.org/jira/browse/FLINK-10881 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10856) Harden resume from externalized checkpoint E2E test

[ https://issues.apache.org/jira/browse/FLINK-10856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686289#comment-16686289 ] ASF GitHub Bot commented on FLINK-10856: tillrohrmann edited a comment on issue #7088:

[jira] [Commented] (FLINK-10866) Queryable state can prevent cluster from starting

[ https://issues.apache.org/jira/browse/FLINK-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686335#comment-16686335 ] Stephan Ewen commented on FLINK-10866: -- QS is still a more experimental feature, hence I agree with

[GitHub] azagrebin commented on a change in pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests

azagrebin commented on a change in pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests URL: https://github.com/apache/flink/pull/7077#discussion_r233394753 ## File path: flink-end-to-end-tests/test-scripts/test_shaded_presto_s3.sh

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686347#comment-16686347 ] ASF GitHub Bot commented on FLINK-10419: dawidwys closed pull request #7093: [FLINK-10419]

[GitHub] dawidwys closed pull request #7093: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

dawidwys closed pull request #7093: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7093 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Created] (FLINK-10879) Align Flink clients on env.execute()

Flavio Pompermaier created FLINK-10879: -- Summary: Align Flink clients on env.execute() Key: FLINK-10879 URL: https://issues.apache.org/jira/browse/FLINK-10879 Project: Flink Issue Type:

[jira] [Closed] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10455. -- Resolution: Fixed Fix Version/s: 1.7.0 merged commit 9f1f25d into apache:master merged

[jira] [Updated] (FLINK-10874) Kafka 2.0 connector testMigrateFromAtLeastOnceToExactlyOnce failure

[ https://issues.apache.org/jira/browse/FLINK-10874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10874: -- Priority: Critical (was: Major) > Kafka 2.0 connector

[jira] [Commented] (FLINK-10849) The flink Metric has no data when two or more filter operators are used

[ https://issues.apache.org/jira/browse/FLINK-10849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686253#comment-16686253 ] Chesnay Schepler commented on FLINK-10849: -- You have a name-clash. Please assign distinct names

[GitHub] tillrohrmann edited a comment on issue #7088: [FLINK-10856] Take latest checkpoint to resume from in resume from externalized checkpoint e2e test

tillrohrmann edited a comment on issue #7088: [FLINK-10856] Take latest checkpoint to resume from in resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7088#issuecomment-438606795 Thanks for the review @twalthr. Merging this PR.

[GitHub] tillrohrmann commented on issue #7088: [FLINK-10856] Take latest checkpoint to resume from in resume from externalized checkpoint e2e test

tillrohrmann commented on issue #7088: [FLINK-10856] Take latest checkpoint to resume from in resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7088#issuecomment-438606795 Thanks for the review. Merging this PR.

[jira] [Commented] (FLINK-10877) Remove duplicate dependency entries in kafka connector pom

[ https://issues.apache.org/jira/browse/FLINK-10877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686314#comment-16686314 ] ASF GitHub Bot commented on FLINK-10877: zentol commented on a change in pull request #7094:

[jira] [Commented] (FLINK-10628) Add end-to-end test for REST communication encryption

[ https://issues.apache.org/jira/browse/FLINK-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686319#comment-16686319 ] ASF GitHub Bot commented on FLINK-10628: zentol commented on issue #6967:

[GitHub] zentol commented on issue #6967: [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests

zentol commented on issue #6967: [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests URL: https://github.com/apache/flink/pull/6967#issuecomment-438613591 Please rebase the branch, e2e test runs are still failing but this is likely just caused by the recent instabilities in

[jira] [Commented] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686338#comment-16686338 ] ASF GitHub Bot commented on FLINK-10736: azagrebin commented on a change in pull request #7077:

[GitHub] azagrebin commented on a change in pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests

azagrebin commented on a change in pull request #7077: [FLINK-10736][E2E tests] Use already uploaded to s3 file in shaded s3 e2e tests URL: https://github.com/apache/flink/pull/7077#discussion_r233394753 ## File path: flink-end-to-end-tests/test-scripts/test_shaded_presto_s3.sh

[jira] [Commented] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686339#comment-16686339 ] ASF GitHub Bot commented on FLINK-10736: azagrebin commented on a change in pull request #7077:

  1   2   >