[jira] [Commented] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics

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

[GitHub] flink pull request: [FLINK-3229] Flink streaming consumer for AWS ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/1911#discussion_r60346774 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[GitHub] flink pull request: Flink 1827 and small fixes in some tests

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1915#issuecomment-212076850 I quickly scrolled over the changed, and overall I like the idea of fixing the thing with the test utils. I wonder if we could get rid of the "flink-test-utils"

[jira] [Commented] (FLINK-3768) Clustering Coefficient

[ https://issues.apache.org/jira/browse/FLINK-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15248425#comment-15248425 ] Greg Hogan commented on FLINK-3768: --- The global clustering coefficient is simple to compute but fitting

[GitHub] flink pull request:

Github user uce commented on the pull request: https://github.com/apache/flink/commit/7462a5bfd7cb2dafbbc9eb02a43d3db9f6add30e#commitcomment-17165776 Can you push this to `release-1.0` as well to have it in 1.0.3 or the next 1.0.2 RC? --- If your project is set up for it, you can

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15248270#comment-15248270 ] Greg Hogan commented on FLINK-3780: --- The Jaccard Similarity is computed on two vertices. For a graph

[jira] [Updated] (FLINK-3789) Overload methods which trigger program execution to allow naming job

[ https://issues.apache.org/jira/browse/FLINK-3789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3789: -- Description: Overload the following functions to additionally accept a job name to pass to

[jira] [Updated] (FLINK-3789) Overload methods which trigger program execution to allow naming job

[ https://issues.apache.org/jira/browse/FLINK-3789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3789: -- Description: Overload the following functions to additionally accept a job name to pass to

[jira] [Commented] (FLINK-3780) Jaccard Similarity

[ https://issues.apache.org/jira/browse/FLINK-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15248193#comment-15248193 ] Vasia Kalavri commented on FLINK-3780: -- Hi [~greghogan], what do you mean by "all non-zero"

[jira] [Closed] (FLINK-1528) Add local clustering coefficient library method and example

[ https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri closed FLINK-1528. > Add local clustering coefficient library method and example >

[jira] [Resolved] (FLINK-1528) Add local clustering coefficient library method and example

[ https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-1528. -- Resolution: Fixed > Add local clustering coefficient library method and example >

[jira] [Commented] (FLINK-3768) Clustering Coefficient

[ https://issues.apache.org/jira/browse/FLINK-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15248180#comment-15248180 ] Vasia Kalavri commented on FLINK-3768: -- Thanks! It makes sense to proceed with this implementation.

[GitHub] flink pull request: [FLINK-3781] BlobClient may be left unclosed i...

Github user gaoyike commented on the pull request: https://github.com/apache/flink/pull/1908#issuecomment-212011148 Updated! Thanks uce! --- 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

[jira] [Commented] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal()

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

[GitHub] flink pull request: Flink 1827 and small fixes in some tests

GitHub user stefanobortoli opened a pull request: https://github.com/apache/flink/pull/1915 Flink 1827 and small fixes in some tests Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your

[jira] [Updated] (FLINK-3789) Overload methods which trigger program execution to allow naming job

[ https://issues.apache.org/jira/browse/FLINK-3789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3789: -- Description: Overload the following functions to additionally accept a job name to pass to

[jira] [Commented] (FLINK-3788) Local variable values are not distributed to job runners

[ https://issues.apache.org/jira/browse/FLINK-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247924#comment-15247924 ] Stefano Baghino commented on FLINK-3788: Yes, I experimented this very problem when trying Flink

[jira] [Commented] (FLINK-3788) Local variable values are not distributed to job runners

[ https://issues.apache.org/jira/browse/FLINK-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247919#comment-15247919 ] Andreas C. Osowski commented on FLINK-3788: --- In that case, the behaviour can probably be

[jira] [Commented] (FLINK-3788) Local variable values are not distributed to job runners

[ https://issues.apache.org/jira/browse/FLINK-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247896#comment-15247896 ] Gabor Gevay commented on FLINK-3788: It seems that the `extends App` stuff is causing this somehow. If

[jira] [Created] (FLINK-3789) Overload methods which trigger program execution to allow naming job

Greg Hogan created FLINK-3789: - Summary: Overload methods which trigger program execution to allow naming job Key: FLINK-3789 URL: https://issues.apache.org/jira/browse/FLINK-3789 Project: Flink

[jira] [Updated] (FLINK-3788) Local variable values are not distributed to job runners

[ https://issues.apache.org/jira/browse/FLINK-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andreas C. Osowski updated FLINK-3788: -- Summary: Local variable values are not distributed to job runners (was: Local variable

[GitHub] flink pull request: [FLINK-3718] Add Option For Completely Async B...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1879#issuecomment-211955064 Looking at the list of changed files, it should not be a big problem to merge your changes with mine. Thus, I would say go ahead. --- If your project is set up

[jira] [Commented] (FLINK-3718) Add Option For Completely Async Backup in RocksDB State Backend

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

[jira] [Commented] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247847#comment-15247847 ] Till Rohrmann commented on FLINK-3701: -- Yes that should work. > Cant call execute after first

[jira] [Updated] (FLINK-3788) Local variable values are not distributed to task runners

[ https://issues.apache.org/jira/browse/FLINK-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andreas C. Osowski updated FLINK-3788: -- Attachment: FLINK-3788.tgz > Local variable values are not distributed to task runners

[jira] [Created] (FLINK-3788) Local variable values are not distributed to task runners

Andreas C. Osowski created FLINK-3788: - Summary: Local variable values are not distributed to task runners Key: FLINK-3788 URL: https://issues.apache.org/jira/browse/FLINK-3788 Project: Flink

[GitHub] flink pull request: [FLINK-3774] [shell] Forwards Flink configurat...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1904#discussion_r60238192 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java --- @@ -133,26 +137,31 @@ public RemoteEnvironment(String host, int

[jira] [Commented] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

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

[jira] [Commented] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

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

[GitHub] flink pull request: [FLINK-3774] [shell] Forwards Flink configurat...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1904#discussion_r60235985 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java --- @@ -133,26 +137,31 @@ public RemoteEnvironment(String host, int

[GitHub] flink pull request: [FLINK-3229] Flink streaming consumer for AWS ...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1911#discussion_r60235061 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[jira] [Commented] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics

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

[GitHub] flink pull request: [FLINK-3783] [core] Support weighted random sa...

Github user gaoyike commented on the pull request: https://github.com/apache/flink/pull/1909#issuecomment-211930810 What is the core algorithm A-ES or A-Chao? 2016-04-19 6:41 GMT-05:00 Trevor Grant : > Nice. If this gets merged before

[jira] [Commented] (FLINK-3783) Support weighted random sampling with reservoir

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

[jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction

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

[GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1517#discussion_r60232838 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/base/ReduceOperatorBase.java --- @@ -54,6 +54,32 @@ @Internal public

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60232443 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@

[jira] [Commented] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

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

[GitHub] flink pull request: [FLINK-3774] [shell] Forwards Flink configurat...

Github user smarthi commented on a diff in the pull request: https://github.com/apache/flink/pull/1904#discussion_r60231836 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java --- @@ -133,26 +137,31 @@ public RemoteEnvironment(String host, int port,

[jira] [Commented] (FLINK-2998) Support range partition comparison for multi input nodes.

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

[GitHub] flink pull request: [FLINK-2998] Support range partition compariso...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1838#issuecomment-211923989 Hi @gallenvara, thanks for the update! I tried it locally and it worked as expected. I would like two more test methods though, to ensure that the thing is

[GitHub] flink pull request: [FLINK-3775] [shell] Load Flink configuration ...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1914 [FLINK-3775] [shell] Load Flink configuration before forwarding it This commit makes sure that the GlobalConfiguration is loaded before the FlinkShell is started. - [X] General

[jira] [Commented] (FLINK-3775) Flink Scala shell does not respect Flink configuration

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

[jira] [Commented] (FLINK-2998) Support range partition comparison for multi input nodes.

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

[GitHub] flink pull request: [FLINK-2998] Support range partition compariso...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1838#discussion_r60229754 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java --- @@ -84,8 +84,8 @@ public PartitionOperator(DataSet input,

[jira] [Assigned] (FLINK-3775) Flink Scala shell does not respect Flink configuration

[ https://issues.apache.org/jira/browse/FLINK-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3775: Assignee: Till Rohrmann > Flink Scala shell does not respect Flink configuration >

[GitHub] flink pull request: [FLINK-3701] reuse serializer lists in Executi...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1913#issuecomment-211918388 When simply clearing the lists, we loose the registered serializers. Added another commit to make the fields transient instead of clearing the lists. That way we can reuse

[jira] [Commented] (FLINK-3701) Cant call execute after first execution

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

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60224497 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -0,0

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

Till Rohrmann created FLINK-3787: Summary: Yarn client does not report unfulfillable container constraints Key: FLINK-3787 URL: https://issues.apache.org/jira/browse/FLINK-3787 Project: Flink

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1910#issuecomment-211906744 Thank you @zentol and @uce for the review. I hope I addressed all your concerns. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-3786) Add BigDecimal and BigInteger as Basic types

[ https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247657#comment-15247657 ] Chesnay Schepler commented on FLINK-3786: - The JDBC formats would benefit from this as well, +1.

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60220641 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/examples/ProduceIntoKinesis.java ---

[jira] [Commented] (FLINK-3701) Cant call execute after first execution

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

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60220590 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@

[GitHub] flink pull request: [FLINK-3701] reuse serializer lists in Executi...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1913 [FLINK-3701] reuse serializer lists in ExecutionConfig https://issues.apache.org/jira/browse/FLINK-3701 You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247644#comment-15247644 ] Maximilian Michels commented on FLINK-3701: --- The issue is that the serializer lists in the

[jira] [Assigned] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3701: - Assignee: Maximilian Michels > Cant call execute after first execution >

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60219813 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60219525 --- Diff: flink-streaming-connectors/flink-connector-twitter/pom.xml --- @@ -35,6 +35,11 @@ under the License. jar + +

[jira] [Commented] (FLINK-3749) Improve decimal handling

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

[GitHub] flink pull request: [FLINK-3749] [table] Improve decimal handling

Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1881#issuecomment-211892621 @vasia and @fhueske: I have opened FLINK-3786 for a long-term solution ;-) I will start working on this issue. --- If your project is set up for it, you can reply

[jira] [Created] (FLINK-3786) Add BigDecimal and BigInteger as Basic types

Timo Walther created FLINK-3786: --- Summary: Add BigDecimal and BigInteger as Basic types Key: FLINK-3786 URL: https://issues.apache.org/jira/browse/FLINK-3786 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

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

[GitHub] flink pull request: [FLINK-3774] [shell] Forwards Flink configurat...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1904#discussion_r60217702 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java --- @@ -133,26 +137,31 @@ public RemoteEnvironment(String host, int port,

[jira] [Closed] (FLINK-1427) Configuration through environment variables

[ https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-1427. - Resolution: Won't Fix Thanks, closing for now. > Configuration through environment

[jira] [Closed] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-3764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3764. --- Resolution: Fixed Fixed in 716d832098b47ec19c6f5c675eb461d3ba96f60a >

[GitHub] flink pull request: [FLINK-3764] [tests] Improve LeaderChangeState...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1894 --- 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-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis

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

[jira] [Commented] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations

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

[GitHub] flink pull request: [FLINK-3086] [table] ExpressionParser does not...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/1912 [FLINK-3086] [table] ExpressionParser does not support concatenation of suffix operations Thanks for contributing to Apache Flink. Before you open your pull request, please take the following

[jira] [Commented] (FLINK-3783) Support weighted random sampling with reservoir

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

[GitHub] flink pull request: [FLINK-3783] [core] Support weighted random sa...

Github user rawkintrevo commented on the pull request: https://github.com/apache/flink/pull/1909#issuecomment-211873070 Nice. If this gets merged before https://github.com/apache/flink/pull/1898 I'll integrate it in. Otherwise I'll open a seperate PR after. --- If your project is

[jira] [Commented] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis

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

[GitHub] flink pull request: [FLINK-3764] [tests] Improve LeaderChangeState...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1894#issuecomment-211872883 Merging. --- 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

[jira] [Closed] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module

[ https://issues.apache.org/jira/browse/FLINK-2848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2848. --- Resolution: Invalid The JMH license is not ASL compliant. Further discussions regarding a

[jira] [Resolved] (FLINK-2344) Deprecate/Remove the old Pact Pair type

[ https://issues.apache.org/jira/browse/FLINK-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler resolved FLINK-2344. - Resolution: Fixed This class was removed in FLINK-3169. > Deprecate/Remove the old Pact

[jira] [Commented] (FLINK-2265) Tachyon Tests sometimes fail with pre-mature process exists

[ https://issues.apache.org/jira/browse/FLINK-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247554#comment-15247554 ] Chesnay Schepler commented on FLINK-2265: - The failure causing test no longer exists, does it? >

[jira] [Commented] (FLINK-1427) Configuration through environment variables

[ https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247549#comment-15247549 ] Chesnay Schepler commented on FLINK-1427: - can we close this issue? ti appears that the consensus

[jira] [Created] (FLINK-3785) Add REST resource to query information about checkpointing

Konstantin Knauf created FLINK-3785: --- Summary: Add REST resource to query information about checkpointing Key: FLINK-3785 URL: https://issues.apache.org/jira/browse/FLINK-3785 Project: Flink

[jira] [Commented] (FLINK-1394) TachyonFileSystemWrapperTest fails if the HADOOP_HOME variable is set

[ https://issues.apache.org/jira/browse/FLINK-1394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247548#comment-15247548 ] Chesnay Schepler commented on FLINK-1394: - does this test still exist? >

[jira] [Commented] (FLINK-1146) Add a way to provide types for generic type variables

[ https://issues.apache.org/jira/browse/FLINK-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247540#comment-15247540 ] Chesnay Schepler commented on FLINK-1146: - was this issue resolved with the implementation of

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/1910#issuecomment-211847621 Great addition to have a producer to Kinesis. The changes look good overall, I had some minor inline comments. The main concern is that we can only test this with a

[jira] [Commented] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics

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

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[GitHub] flink pull request: [FLINK-3229] Flink streaming consumer for AWS ...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1911#issuecomment-211847420 Cool. You don't need to resubmit a new PR. By pushing new commits to your `FLINK-3229` branch, the pull request will update automatically. --- If your project is set

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60207331 --- Diff: flink-streaming-connectors/flink-connector-twitter/pom.xml --- @@ -35,6 +35,11 @@ under the License. jar + +

[jira] [Commented] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics

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

[GitHub] flink pull request: [FLINK-3229] Flink streaming consumer for AWS ...

Github user tzulitai commented on the pull request: https://github.com/apache/flink/pull/1911#issuecomment-211847140 @rmetzger Sure, that seems reasonable. I'll wait until the producer is merged and resubmit a new PR for the integrated consumer. --- If your project is set up for it,

[jira] [Commented] (FLINK-3230) Kinesis streaming producer

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

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60207207 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/examples/ProduceIntoKinesis.java ---

[GitHub] flink pull request: [FLINK-3230] Add producer for Amazon Kinesis S...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1910#discussion_r60207039 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@

  1   2   >