[GitHub] flink issue #2133: [FLINK-4091] Fix Guava shading in Cassandra connector

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2133 you are right, guava is not properly included and shaded under the new reference. --- 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] [Comment Edited] (FLINK-4058) Error uploading JAR with dependencies using flink.bat on a Windows stand-alone instance

[ https://issues.apache.org/jira/browse/FLINK-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339254#comment-15339254 ] miaoever edited comment on FLINK-4058 at 6/20/16 9:43 AM: -- I met the same problem

[jira] [Commented] (FLINK-4058) Error uploading JAR with dependencies using flink.bat on a Windows stand-alone instance

[ https://issues.apache.org/jira/browse/FLINK-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339254#comment-15339254 ] miaoever commented on FLINK-4058: - I met the same problem . If [~mark.nadel...@point72.com] do not fix it

[jira] [Assigned] (FLINK-3838) CLI parameter parser is munging application params

[ https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3838: - Assignee: Maximilian Michels > CLI parameter parser is munging application

[jira] [Commented] (FLINK-3838) CLI parameter parser is munging application params

[ https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339240#comment-15339240 ] Maximilian Michels commented on FLINK-3838: --- Thanks for reporting! > CLI parameter parser is

[jira] [Updated] (FLINK-3838) CLI parameter parser is munging application params

[ https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3838: -- Affects Version/s: 1.0.3 > CLI parameter parser is munging application params >

[jira] [Updated] (FLINK-3838) CLI parameter parser is munging application params

[ https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3838: -- Fix Version/s: 1.0.4 1.1.0 > CLI parameter parser is munging

[jira] [Resolved] (FLINK-3820) ScalaShellITCase.testPreventRecreationBatch deadlocks on Travis

[ https://issues.apache.org/jira/browse/FLINK-3820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3820. --- Resolution: Duplicate Should be resolved with FLINK-4030. >

[jira] [Commented] (FLINK-3787) Yarn client does not report unfulfillable container constraints

[ https://issues.apache.org/jira/browse/FLINK-3787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339230#comment-15339230 ] Maximilian Michels commented on FLINK-3787: --- Do we want to fix this for the 1.1.0 release? >

[jira] [Resolved] (FLINK-3765) ScalaShellITCase deadlocks spuriously

[ https://issues.apache.org/jira/browse/FLINK-3765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3765. --- Resolution: Duplicate This should be resolved with the resolution of FLINK-4030.

[jira] [Commented] (FLINK-3757) addAccumulator does not throw Exception on duplicate accumulator name

[ https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339224#comment-15339224 ] Maximilian Michels commented on FLINK-3757: --- Accumulators are first created locally without

[GitHub] flink issue #2133: [FLINK-4091] Fix Guava shading in Cassandra connector

Github user theomega commented on the issue: https://github.com/apache/flink/pull/2133 Are you sure that this fixes the problem (I haven't tried): The change only changes the references in the connectors-code to the new package. But someone needs to provide this package, or am I

[jira] [Commented] (FLINK-4091) flink-connector-cassandra has conflicting guava version

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

[jira] [Commented] (FLINK-4090) Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties()

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

[GitHub] flink issue #2132: [FLINK-4090] Close of OutputStream should be in finally c...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2132 +1 --- 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

[jira] [Commented] (FLINK-4093) Expose metric interfaces

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

[GitHub] flink pull request #2134: [FLINK-4093] Expose metric interfaces

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2134 [FLINK-4093] Expose metric interfaces This PR allows users to create their own metrics and register them with Flink. To that end, Counter was refactored into a SimpleCounter class

[jira] [Commented] (FLINK-4091) flink-connector-cassandra has conflicting guava version

[ https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339202#comment-15339202 ] Chesnay Schepler commented on FLINK-4091: - I've opened a PR to change the shading pattern here:

[GitHub] flink pull request #2133: [FLINK-4091] Fix Guava shading in Cassandra connec...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2133 [FLINK-4091] Fix Guava shading in Cassandra connector This PR modifies the guava shading in the Cassandra connector. It no longer uses the same pattern as flink-dist which lead to version conflicts.

[jira] [Commented] (FLINK-4091) flink-connector-cassandra has conflicting guava version

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

[jira] [Assigned] (FLINK-4091) flink-connector-cassandra has conflicting guava version

[ https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4091: --- Assignee: Chesnay Schepler > flink-connector-cassandra has conflicting guava version

[jira] [Created] (FLINK-4093) Expose metric interfaces

Chesnay Schepler created FLINK-4093: --- Summary: Expose metric interfaces Key: FLINK-4093 URL: https://issues.apache.org/jira/browse/FLINK-4093 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

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

[GitHub] flink issue #2125: [FLINK-3864] Yarn tests don't check for prohibited string...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2125 The commit message is the JIRA issue subject. I agree that it makes sense to give a description of the changes instead. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

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

[GitHub] flink issue #1771: [FLINK-3311/FLINK-3332] Add Cassandra connector

Github user f1yegor commented on the issue: https://github.com/apache/flink/pull/1771 Looking at the code of `CassandraSinkBase` I assume that every new sink will create own session to the cluster. I'm creating arount 1000 streams and sinks for them, so cassandra cluster would

<    1   2