[GitHub] flink issue #2186: [licenses] Remove not included dependency from LICENSE

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2186 +1 to merge --- 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 th

[jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API

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

[GitHub] flink issue #1954: [FLINK-3190] failure rate restart strategy

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/1954 Hi @fijolekProjects, what's the status on your side? I would like to include your PR in the upcoming release :-) --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request #2193: [FLINK-4145] [core] Configure port range for JMXRe...

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2193#discussion_r69421710 --- Diff: flink-core/src/test/java/org/apache/flink/metrics/reporter/JMXReporterTest.java --- @@ -285,4 +289,23 @@ public long getMin() {

[jira] [Commented] (FLINK-4145) JmxReporterTest fails due to port conflicts

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

[GitHub] flink pull request #2176: [FLINK-4118] The docker-flink image is outdated (1...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2176 --- 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 enab

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

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

[GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2176 I merged it, thanks again for your work! --- 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 en

[jira] [Resolved] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-4118. - Resolution: Fixed Fix Version/s: 1.1.0 Added in https://github.com/apache/flink/co

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

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

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69426825 --- Diff: docs/apis/streaming/connectors/redis.md --- @@ -0,0 +1,177 @@ +--- +title: "Redis Connector" + +# Sub-level navigation +sub-nav-gro

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69427102 --- Diff: docs/apis/streaming/connectors/redis.md --- @@ -0,0 +1,177 @@ +--- +title: "Redis Connector" + +# Sub-level navigation +sub-nav-gro

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69427347 --- Diff: docs/apis/streaming/connectors/redis.md --- @@ -0,0 +1,177 @@ +--- +title: "Redis Connector" + +# Sub-level navigation +sub-nav-gro

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69427481 --- Diff: docs/apis/streaming/connectors/redis.md --- @@ -0,0 +1,177 @@ +--- +title: "Redis Connector" + +# Sub-level navigation +sub-nav-gro

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69427444 --- Diff: docs/apis/streaming/connectors/redis.md --- @@ -0,0 +1,177 @@ +--- +title: "Redis Connector" + +# Sub-level navigation +sub-nav-gro

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69427880 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java --- @@ -0,0 +1,193 @@ +

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69428038 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java --- @@ -0,0 +1,193 @@ +

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69428276 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java ---

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69428451 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java ---

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69428463 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java ---

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69428684 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java ---

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69429234 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisConfigBase.java ---

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69429555 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java ---

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69429657 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java ---

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69429926 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java --

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69429896 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java --

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69430042 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java --

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69430279 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainer.java -

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69430592 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java --- @

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69430812 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java --- @

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69431563 --- Diff: flink-streaming-connectors/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisSinkITCase.java --- @@ -0,0 +1,240 @@

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink issue #1954: [FLINK-3190] failure rate restart strategy

Github user fijolekProjects commented on the issue: https://github.com/apache/flink/pull/1954 Hi @tillrohrmann , that's nice. I'll do my best to push fixes today/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

[jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69432240 --- Diff: flink-streaming-connectors/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/common/config/JedisClusterConfigTest.java ---

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on the issue: https://github.com/apache/flink/pull/1813 @subhankarb I think one more pass and we are good to go! --- 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 th

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[jira] [Resolved] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4027. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved in http://git-wip-us.apache.org/repos/a

[GitHub] flink pull request #2108: [FLINK-4027] Flush FlinkKafkaProducer on checkpoin...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2108 --- 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 enab

[GitHub] flink pull request #2058: Not able to create flink-streaming-connectors jar

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2058 --- 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 enab

[jira] [Commented] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

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

[jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API

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

[GitHub] flink issue #1954: [FLINK-3190] failure rate restart strategy

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/1954 Great to hear :-) --- 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

[GitHub] flink pull request #2183: [FLINK-4123] Cassandra sink checks for exceptions ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2183#discussion_r69440065 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.jav

[jira] [Commented] (FLINK-4123) CassandraWriteAheadSink can hang on cassandra failure

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

[jira] [Assigned] (FLINK-4133) Reflect streaming file source changes in documentation

[ https://issues.apache.org/jira/browse/FLINK-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-4133: - Assignee: Kostas Kloudas > Reflect streaming file source changes in documentation > -

[jira] [Assigned] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis

[ https://issues.apache.org/jira/browse/FLINK-4146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4146: - Assignee: Robert Metzger > CliFrontendYarnAddressConfigurationTest picks wrong IP address

[jira] [Commented] (FLINK-4123) CassandraWriteAheadSink can hang on cassandra failure

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

[GitHub] flink issue #2183: [FLINK-4123] Cassandra sink checks for exceptions in ack ...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2183 I have one final remark concerning the busy wait loop. I think it's better to replace it with a wait-notify construct. Maybe we could also add a test which assures that the `sendValues` loop is

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user subhankarb commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69442146 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java

[jira] [Updated] (FLINK-939) Distribute required JAR files with seperate service

[ https://issues.apache.org/jira/browse/FLINK-939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-939: -- Component/s: (was: New Components) > Distribute required JAR files with seperate service > --

[jira] [Updated] (FLINK-972) Run Flink on Tez

[ https://issues.apache.org/jira/browse/FLINK-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-972: -- Component/s: (was: New Components) Local Runtime > Run Flink on Tez > --

[jira] [Updated] (FLINK-1219) Add support for Apache Tez as execution engine

[ https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-1219: --- Component/s: (was: Flink on Tez) (was: New Components) Local

[jira] [Updated] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-1725: --- Component/s: (was: New Components) Local Runtime > New Partitioner for better loa

[jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos

[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-1984: --- Component/s: (was: New Components) Cluster Management > Integrate Flink with Apac

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user subhankarb commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69444769 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisConfigBase.java -

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user subhankarb commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69444815 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainerBui

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user subhankarb commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69444781 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

Github user subhankarb commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69444799 --- Diff: flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisConfigBase.java -

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[jira] [Commented] (FLINK-3034) Redis SInk Connector

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

[GitHub] flink pull request #2195: FLINK-3397 Failed streaming jobs should fall back ...

GitHub user ramkrish86 opened a pull request: https://github.com/apache/flink/pull/2195 FLINK-3397 Failed streaming jobs should fall back to the most recent Initial patch to see if this is what is intended out of the JIRA. Thought a PR could help me in getting a better feedback. I t

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

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

[GitHub] flink issue #2195: FLINK-3397 Failed streaming jobs should fall back to the ...

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2195 @uce - any feedback/suggestions are welcome. --- 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 feat

[jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

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

[jira] [Updated] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis

[ https://issues.apache.org/jira/browse/FLINK-4146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4146: -- Labels: test-stability (was: ) > CliFrontendYarnAddressConfigurationTest picks wrong IP address

[jira] [Commented] (FLINK-3319) Add or operator to CEP's pattern API

[ https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15361206#comment-15361206 ] Till Rohrmann commented on FLINK-3319: -- Great to hear :-) I think it's also still eno

[GitHub] flink issue #2193: [FLINK-4145] [core] Configure port range for JMXReporterT...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2193 I believe the underlying issue is that there are a bunch of tests that just don't close their ports properly, as for quite a few tests a MetricRegistry is fired up silently in the background.

[jira] [Commented] (FLINK-4145) JmxReporterTest fails due to port conflicts

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

[jira] [Assigned] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

[ https://issues.apache.org/jira/browse/FLINK-4137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4137: Assignee: Till Rohrmann > JobManager web frontend does not shut down on OOM exception on JM

[GitHub] flink issue #2153: [FLINK-4110] Add testing skeleton to quickstart

Github user uce commented on the issue: https://github.com/apache/flink/pull/2153 +1 to what Till and Jamie said. Regarding the removed joda-time exclusion: that's independent of the testing skeleton, right? --- If your project is set up for it, you can reply to this email a

[jira] [Commented] (FLINK-4110) Provide testing skeleton in quickstarts

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

[GitHub] flink issue #2135: [hotfix] [metrics] Prevent log flooding from collisions

Github user uce commented on the issue: https://github.com/apache/flink/pull/2135 In which cases do the collisions occur? --- 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] flink issue #2123: [FLINK-3904] GlobalConfiguration doesn't ensure config ha...

Github user uce commented on the issue: https://github.com/apache/flink/pull/2123 This problem sounds like it might cause very hard to debug problems. --- 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 n

[jira] [Commented] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded

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

[GitHub] flink issue #2135: [hotfix] [metrics] Prevent log flooding from collisions

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2135 For the default scope it occurs if either - 2 jobs are executed for which the name is equal - within a job there are 2 tasks for which the name is equal - within a job there are 2 operators

  1   2   3   >