[jira] [Commented] (FLINK-2935) Allow scala shell to read yarn properties

[ https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15209546#comment-15209546 ] ASF GitHub Bot commented on FLINK-2935: --- Github user chiwanpark commented on the pull request:

[jira] [Commented] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public'

[ https://issues.apache.org/jira/browse/FLINK-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15209210#comment-15209210 ] ASF GitHub Bot commented on FLINK-3657: --- Github user smarthi commented on the pull request:

[GitHub] flink pull request: FLINK-3657: Change access of DataSetUtils.coun...

Github user smarthi commented on the pull request: https://github.com/apache/flink/pull/1829#issuecomment-200551422 Not sure as to why u think this is "way to specific", this is a very convenient feature to have when dealing with Distributed Row Matrix (DRM) blocks for distributed

[jira] [Assigned] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

[ https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suneel Marthi reassigned FLINK-3405: Assignee: Suneel Marthi > Extend NiFiSource with interface StoppableFunction >

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-200480609 @tillrohrmann thanks! I'll polish up knn.md soon --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208921#comment-15208921 ] ASF GitHub Bot commented on FLINK-1745: --- Github user danielblazevski commented on the pull request:

[jira] [Updated] (FLINK-3664) Create a method to easily Summarize a DataSet

[ https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Todd Lisonbee updated FLINK-3664: - Description: Here is an example: {code} /** * Summarize a DataSet of Tuples by collecting

[jira] [Updated] (FLINK-3664) Create a method to easily Summarize a DataSet

[ https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Todd Lisonbee updated FLINK-3664: - Description: Here is an example: /** * Summarize a DataSet of Tuples by collecting single pass

[jira] [Commented] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations

[ https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208869#comment-15208869 ] Todd Lisonbee commented on FLINK-3613: -- I created another related JIRA FLINK-3664 with a design for a

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208861#comment-15208861 ] ASF GitHub Bot commented on FLINK-1745: --- Github user tillrohrmann commented on the pull request:

[jira] [Updated] (FLINK-3664) Create a method to easily Summarize a DataSet

[ https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Todd Lisonbee updated FLINK-3664: - Attachment: DataSet-Summary-Design-March2016-v1.txt Attached is a first revision of a design. (I

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-200465211 Hi Daniel, the docs are handwritten as far as I know. On Wed, Mar 23, 2016 at 5:49 PM, Daniel Blazevski wrote: >

[jira] [Commented] (FLINK-3664) Create a method to easily Summarize a DataSet

[ https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208806#comment-15208806 ] Todd Lisonbee commented on FLINK-3664: -- I'm writing a design for this now. > Create a method to

[jira] [Created] (FLINK-3664) Create a method to easily Summarize a DataSet

Todd Lisonbee created FLINK-3664: Summary: Create a method to easily Summarize a DataSet Key: FLINK-3664 URL: https://issues.apache.org/jira/browse/FLINK-3664 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208753#comment-15208753 ] ASF GitHub Bot commented on FLINK-1745: --- Github user danielblazevski commented on the pull request:

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-200436234 @chiwanpark about the docs, when I look at docs/libs/ml/smv.md for instance (or als.md, etc.), the `parameters` section seems auto-generated, is that correct?

[jira] [Commented] (FLINK-2609) Automatic type registration is only called from the batch execution environment

[ https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208738#comment-15208738 ] ASF GitHub Bot commented on FLINK-2609: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2609] [streaming] auto-register types

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1833#discussion_r57193823 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java --- @@ -94,6 +95,7 @@ public

[jira] [Resolved] (FLINK-2997) Support range partition with user customized data distribution.

[ https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2997. -- Resolution: Implemented Assignee: GaoLun Fix Version/s: 1.1.0 Implemented for

[jira] [Closed] (FLINK-2445) Add tests for HadoopOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2445. Resolution: Implemented Fix Version/s: 1.0.1 1.1.0 Tests added for 1.1.0

[jira] [Commented] (FLINK-2444) Add tests for HadoopInputFormats

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

[jira] [Closed] (FLINK-2444) Add tests for HadoopInputFormats

[ https://issues.apache.org/jira/browse/FLINK-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2444. Resolution: Implemented Fix Version/s: 1.0.1 1.1.0 Tests added for 1.1.0

[jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208717#comment-15208717 ] ASF GitHub Bot commented on FLINK-2445: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1486#issuecomment-200426694 Closed this PR as part of PR #1628. @ajaybhat, your commit was added as 8e4a001b84c36827eb6168adac2724f76e30cc2c Thanks for the contribution. --- If your

[jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats

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

[jira] [Commented] (FLINK-2997) Support range partition with user customized data distribution.

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

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

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

[GitHub] flink pull request: [FLINK-2444] add tests for HadoopInputFormats

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

[GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats

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

[jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union

[ https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208711#comment-15208711 ] ASF GitHub Bot commented on FLINK-3547: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3547] add support for streaming filter,...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1820#issuecomment-200424618 Proposed a few refactorings. Looks good otherwise. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: [FLINK-3547] add support for streaming filter,...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1820#discussion_r57190990 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/datastream/DataStreamScanRule.scala --- @@ -0,0 +1,52 @@ +/*

[jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union

[ https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208707#comment-15208707 ] ASF GitHub Bot commented on FLINK-3547: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union

[ https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208704#comment-15208704 ] ASF GitHub Bot commented on FLINK-3547: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3547] add support for streaming filter,...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1820#discussion_r57190736 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamUnion.scala --- @@ -0,0 +1,68 @@ +/*

[jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union

[ https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208703#comment-15208703 ] ASF GitHub Bot commented on FLINK-3547: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3547] add support for streaming filter,...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1820#discussion_r57190463 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamCalc.scala --- @@ -0,0 +1,103 @@ +/*

[jira] [Commented] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public'

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

[GitHub] flink pull request: FLINK-3657: Change access of DataSetUtils.coun...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1829#issuecomment-200418755 Please stop force pushing for squashed changes, it obfuscates which comments you addressed, forcing us to through the _entire _PR again. --- If your project is set up

[jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union

[ https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208684#comment-15208684 ] ASF GitHub Bot commented on FLINK-3547: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3547] add support for streaming filter,...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1820#discussion_r57188635 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetRel.scala --- @@ -20,15 +20,15 @@ package

[jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union

[ https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208675#comment-15208675 ] ASF GitHub Bot commented on FLINK-3547: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3547] add support for streaming filter,...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1820#discussion_r57188121 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkCalc.scala --- @@ -0,0 +1,179 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union

[ https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208673#comment-15208673 ] ASF GitHub Bot commented on FLINK-3547: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3547] add support for streaming filter,...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1820#discussion_r57187905 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkCalc.scala --- @@ -0,0 +1,179 @@ +/* + * Licensed to

[GitHub] flink pull request: FLINK-3657: Change access of DataSetUtils.coun...

Github user andrewpalumbo commented on the pull request: https://github.com/apache/flink/pull/1829#issuecomment-200413224 This method would be very useful to us, e.g., when assigning ordinal indices to the elements of a `DataSet` from an external mapping. I would not think that this

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208659#comment-15208659 ] Farouk Salem commented on FLINK-3343: - Hi Robert, I still have this problem but it happens less with

[jira] [Commented] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public'

[ https://issues.apache.org/jira/browse/FLINK-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208661#comment-15208661 ] ASF GitHub Bot commented on FLINK-3657: --- Github user andrewpalumbo commented on the pull request:

[jira] [Commented] (FLINK-3663) FlinkKafkaConsumerBase.logPartitionInfo is missing a log marker

[ https://issues.apache.org/jira/browse/FLINK-3663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208617#comment-15208617 ] ASF GitHub Bot commented on FLINK-3663: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: FLINK-3663: FlinkKafkaConsumerBase.logPartitio...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1835#issuecomment-200400881 Good catch! +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

[GitHub] flink pull request: FLINK-3663: FlinkKafkaConsumerBase.logPartitio...

GitHub user NielsZeilemaker opened a pull request: https://github.com/apache/flink/pull/1835 FLINK-3663: FlinkKafkaConsumerBase.logPartitionInfo fix You can merge this pull request into a Git repository by running: $ git pull https://github.com/NielsZeilemaker/flink master

[jira] [Commented] (FLINK-3663) FlinkKafkaConsumerBase.logPartitionInfo is missing a log marker

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

[jira] [Created] (FLINK-3663) FlinkKafkaConsumerBase.logPartitionInfo is missing a log marker

Niels Zeilemaker created FLINK-3663: --- Summary: FlinkKafkaConsumerBase.logPartitionInfo is missing a log marker Key: FLINK-3663 URL: https://issues.apache.org/jira/browse/FLINK-3663 Project: Flink

[jira] [Commented] (FLINK-3639) Add methods and utilities to register DataSets and Tables in the TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208595#comment-15208595 ] ASF GitHub Bot commented on FLINK-3639: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3639] add methods for registering datas...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1827#issuecomment-200394123 Proposed a few minor refactorings. Looks good otherwise :-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-3639) Add methods and utilities to register DataSets and Tables in the TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208593#comment-15208593 ] ASF GitHub Bot commented on FLINK-3639: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3639] add methods for registering datas...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1827#discussion_r57179250 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/RegisterDataSetITCase.java --- @@ -0,0 +1,147 @@ +/* + *

[GitHub] flink pull request: [FLINK-3639] add methods for registering datas...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1827#discussion_r57178675 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/TranslationContext.scala --- @@ -59,29 +64,48 @@ object

[jira] [Commented] (FLINK-3639) Add methods and utilities to register DataSets and Tables in the TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208588#comment-15208588 ] ASF GitHub Bot commented on FLINK-3639: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3639) Add methods and utilities to register DataSets and Tables in the TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208572#comment-15208572 ] ASF GitHub Bot commented on FLINK-3639: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3639] add methods for registering datas...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1827#discussion_r57178398 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/TranslationContext.scala --- @@ -59,29 +64,48 @@ object

[GitHub] flink pull request: [FLINK-3639] add methods for registering datas...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1827#discussion_r57173359 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/AbstractTableEnvironment.scala --- @@ -0,0 +1,86 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3639) Add methods and utilities to register DataSets and Tables in the TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208533#comment-15208533 ] ASF GitHub Bot commented on FLINK-3639: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3639) Add methods and utilities to register DataSets and Tables in the TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208534#comment-15208534 ] ASF GitHub Bot commented on FLINK-3639: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3639] add methods for registering datas...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1827#discussion_r57173349 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/AbstractTableEnvironment.scala --- @@ -0,0 +1,86 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3129) Add tooling to ensure interface stability

[ https://issues.apache.org/jira/browse/FLINK-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208510#comment-15208510 ] Robert Metzger commented on FLINK-3129: --- Resolved for the "release-1.0" branch to ensure the 1.0.1

[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types

[ https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208489#comment-15208489 ] ASF GitHub Bot commented on FLINK-3633: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1818#issuecomment-200367314 okay, thank you. --- 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

[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types

[ https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208482#comment-15208482 ] ASF GitHub Bot commented on FLINK-3633: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1818#issuecomment-200366856 Yes I think so. --- 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

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

[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208476#comment-15208476 ] ASF GitHub Bot commented on FLINK-3034: --- Github user rmetzger commented on the pull request:

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

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1813#issuecomment-200365541 Thank you for opening this PR. I'll soon review it. --- 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-3633) Job submission silently fails when using user code types

[ https://issues.apache.org/jira/browse/FLINK-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208470#comment-15208470 ] ASF GitHub Bot commented on FLINK-3633: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1818#issuecomment-200364341 The issue has been introduced after the 1.0 release, so we don't need to incldue this into 1.0.1? --- If your project is set up for it, you can reply to this email

[jira] [Resolved] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.

[ https://issues.apache.org/jira/browse/FLINK-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3327. --- Resolution: Fixed I think the fix version was incorrectly set to 1.0.0. I've corrected it to

[jira] [Updated] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.

[ https://issues.apache.org/jira/browse/FLINK-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3327: -- Fix Version/s: (was: 1.0.0) 1.1.0 > Attach the ExecutionConfig to the

[jira] [Reopened] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.

[ https://issues.apache.org/jira/browse/FLINK-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-3327: --- > Attach the ExecutionConfig to the JobGraph and make it accessible to the > AbstractInvocable.

[jira] [Commented] (FLINK-3608) ImmutableSettings error in ElasticsearchSink

[ https://issues.apache.org/jira/browse/FLINK-3608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208463#comment-15208463 ] Carlos Gonzalez de Zarate commented on FLINK-3608: -- Thanks Robert, I will try it as soon

[GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1625#issuecomment-200337522 Thanks for the quick update. Will merge this PR --- 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

[jira] [Commented] (FLINK-3658) Allow the FlinkKafkaProducer to send data to multiple topics

[ https://issues.apache.org/jira/browse/FLINK-3658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208430#comment-15208430 ] ASF GitHub Bot commented on FLINK-3658: --- Github user gyfora commented on the pull request:

[GitHub] flink pull request: [FLINK-3658][Kafka] Allow producing into multi...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1832#issuecomment-200354048 This is a very useful feature :) The code looks good and straightforward :+1: --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request: [FLINK-2444] add tests for HadoopInputFormats

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1628#issuecomment-200337562 Thanks for the quick update. Will merge this PR --- 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

[jira] [Resolved] (FLINK-3115) Update Elasticsearch connector to 2.X

[ https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3115. --- Resolution: Fixed Fix Version/s: (was: 1.0.1) 1.1.0 Resolved

[jira] [Resolved] (FLINK-3608) ImmutableSettings error in ElasticsearchSink

[ https://issues.apache.org/jira/browse/FLINK-3608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3608. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved with: FLINK-3115 > ImmutableSettings

[jira] [Commented] (FLINK-3115) Update Elasticsearch connector to 2.X

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

[GitHub] flink pull request: FLINK-3115: Update ElasticSearch connector to ...

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

[jira] [Commented] (FLINK-3115) Update Elasticsearch connector to 2.X

[ https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208390#comment-15208390 ] ASF GitHub Bot commented on FLINK-3115: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: FLINK-3115: Update ElasticSearch connector to ...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1792#issuecomment-200341175 Merging the change ... --- 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

[jira] [Created] (FLINK-3661) Make Scala 2.11.x the default Scala version

Maximilian Michels created FLINK-3661: - Summary: Make Scala 2.11.x the default Scala version Key: FLINK-3661 URL: https://issues.apache.org/jira/browse/FLINK-3661 Project: Flink Issue

[jira] [Created] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x

Maximilian Michels created FLINK-3662: - Summary: Bump Akka version to 2.4.x for Scala 2.11.x Key: FLINK-3662 URL: https://issues.apache.org/jira/browse/FLINK-3662 Project: Flink Issue

[jira] [Commented] (FLINK-3659) Allow ConnectedStreams to Be Keyed on Only One Side

[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208384#comment-15208384 ] ASF GitHub Bot commented on FLINK-3659: --- Github user gyfora commented on the pull request:

[jira] [Commented] (FLINK-2997) Support range partition with user customized data distribution.

[ https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208383#comment-15208383 ] ASF GitHub Bot commented on FLINK-2997: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3659] Allow ConnectedStreams to Be Keye...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1831#issuecomment-200339097 Thanks Aljoscha, this seems to work :+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

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1776#issuecomment-200339079 Thanks for the fast update. The PR looks good. :-) I will merge it. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208370#comment-15208370 ] ASF GitHub Bot commented on FLINK-2445: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-2444) Add tests for HadoopInputFormats

[ https://issues.apache.org/jira/browse/FLINK-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208371#comment-15208371 ] ASF GitHub Bot commented on FLINK-2444: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208366#comment-15208366 ] Maximilian Michels commented on FLINK-2821: --- +1 Sounds like a good way to proceed. > Change

[GitHub] flink pull request: [FLINK-3524] [kafka] Add JSONDeserializationSc...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1834#issuecomment-200330990 Otherwise, the change looks good 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

[jira] [Commented] (FLINK-3524) Provide a JSONDeserialisationSchema in the kafka connector package

[ https://issues.apache.org/jira/browse/FLINK-3524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15208352#comment-15208352 ] ASF GitHub Bot commented on FLINK-3524: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3524] [kafka] Add JSONDeserializationSc...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1834#issuecomment-200330964 Can you quickly mention the class in the Kafka documentation? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

  1   2   >