[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=15227709#comment-15227709 ] ramkrishna.s.vasudevan commented on FLINK-3086: --- This also includes abs() operator when used

[jira] [Comment Edited] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15227632#comment-15227632 ] Daniel Blazevski edited comment on FLINK-1934 at 4/6/16 3:07 AM: -

[jira] [Comment Edited] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15227632#comment-15227632 ] Daniel Blazevski edited comment on FLINK-1934 at 4/6/16 3:05 AM: -

[jira] [Commented] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15227632#comment-15227632 ] Daniel Blazevski commented on FLINK-1934: - [~chiwanpark] [~till.rohrmann] I have a Flink version

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15227573#comment-15227573 ] Tian, Li commented on FLINK-3655: - Thanks, I will do the path list first and use "readFile(FileInputFormat

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15227545#comment-15227545 ] Tian, Li commented on FLINK-3655: - Will support wildcards > Allow comma-separated or multiple directories

[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=15227311#comment-15227311 ] Todd Lisonbee commented on FLINK-3664: -- I didn't have Travis CI setup with my github account so I

[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=15227214#comment-15227214 ] Todd Lisonbee commented on FLINK-3664: -- Pull request is ready. Please let me know if you'd like to

[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=15227168#comment-15227168 ] ASF GitHub Bot commented on FLINK-3664: --- GitHub user tlisonbee opened a pull request:

[GitHub] flink pull request: [FLINK-3664] Create method to easily summarize...

GitHub user tlisonbee opened a pull request: https://github.com/apache/flink/pull/1855 [FLINK-3664] Create method to easily summarize a DataSet of Tuples Adding summarize() method in DataSetUtils that will supply a number of single pass statistics for DataSets of Tuples.

[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime

[ https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226941#comment-15226941 ] Konstantin Knauf commented on FLINK-3688: - Could open the PR

[jira] [Commented] (FLINK-3696) Some Union tests fail for TableConfigMode.EFFICIENT

[ https://issues.apache.org/jira/browse/FLINK-3696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226745#comment-15226745 ] Vasia Kalavri commented on FLINK-3696: -- The problem here is that the TypeConverter creates a

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226676#comment-15226676 ] Gna Phetsarath commented on FLINK-3655: --- Will do be doing wildcards as well, or should be put that

[jira] [Assigned] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes

[ https://issues.apache.org/jira/browse/FLINK-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3697: - Assignee: Robert Metzger > keyBy() with nested POJO computes invalid field position

[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=15226613#comment-15226613 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58572834 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/test/resources/cassandra.yaml --- @@ -0,0 +1,43 @@

[jira] [Commented] (FLINK-3492) Allow users to define a min pause between checkpoints

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

[GitHub] flink pull request: [FLINK-3492] Configurable interval between Che...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1794#issuecomment-205887495 reworked test to be more reliable. --- 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

[GitHub] flink pull request: [FLINK-3637] Refactor rolling sink writer

Github user dalegaard commented on the pull request: https://github.com/apache/flink/pull/1826#issuecomment-205886932 @aljoscha okay, I'll fix that and rebase onto master. Naming things is one of the only two hard problems in computer science after all :) --- If your project is set

[jira] [Commented] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs

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

[GitHub] flink pull request: [FLINK-2143] Added ReduceFunctionWithInverse

Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/856#issuecomment-205884988 I think that this unfortunately can't be adapted to the new windowing system, so it can be closed. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter

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

[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=15226596#comment-15226596 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58571353 --- Diff:

[GitHub] flink pull request: [FLINK-3637] Refactor rolling sink writer

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1826#issuecomment-205885519 The changes look good. One thing I would like to have changed is to rename `SimpleWriterBase` to `StreamWriterBase` or `StreamWriter` based to reflect the fact that it

[GitHub] flink pull request: [FLINK-2143] Added ReduceFunctionWithInverse

Github user ggevay closed the pull request at: https://github.com/apache/flink/pull/856 --- 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-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter

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

[jira] [Commented] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter

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

[GitHub] flink pull request: [FLINK-2143] Added ReduceFunctionWithInverse

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/856#issuecomment-205883786 @ggevay The windowing system changed a while back. Is this still valid or can it be closed? --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs

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

[GitHub] flink pull request: [FLINK-3637] Refactor rolling sink writer

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1826#issuecomment-205883214 hi @dalegaard this must have slipped my mind. I'll review it tomorrow and merge if possible. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment

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

[GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/939#issuecomment-205882687 @twalthr @fhueske @vasia Is this still valid with the recent changes in the Table API? --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

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

[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=15226563#comment-15226563 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1237#issuecomment-205881346 @twalthr is this still valid with the changes in the Table API or can it be closed? --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58568963 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -0,0

[jira] [Commented] (FLINK-3283) Failed Kafka 0.9 test on duplicate message

[ https://issues.apache.org/jira/browse/FLINK-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226559#comment-15226559 ] Robert Metzger commented on FLINK-3283: --- This commit improves the Kafka tests stability:

[jira] [Assigned] (FLINK-3283) Failed Kafka 0.9 test on duplicate message

[ https://issues.apache.org/jira/browse/FLINK-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3283: - Assignee: Robert Metzger > Failed Kafka 0.9 test on duplicate message >

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

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

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

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

[GitHub] flink pull request: [FLINK-3697] Properly access type information ...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1851#discussion_r58564424 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/util/FieldAccessor.java --- @@ -182,11 +182,14 @@ public R set(R record, F

[jira] [Commented] (FLINK-1337) Create an Amazon EMR Bootstrap Action

[ https://issues.apache.org/jira/browse/FLINK-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226522#comment-15226522 ] Timur Fayruzov commented on FLINK-1337: --- It's an old issue, but if there is still interest I can

[jira] [Commented] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes

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

[GitHub] flink pull request: [FLINK-3697] Properly access type information ...

Github user RonCrocker commented on the pull request: https://github.com/apache/flink/pull/1851#issuecomment-205868281 :+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

[jira] [Commented] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes

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

[jira] [Commented] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes

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

[GitHub] flink pull request: [FLINK-3697] Properly access type information ...

Github user RonCrocker commented on a diff in the pull request: https://github.com/apache/flink/pull/1851#discussion_r58564095 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/util/FieldAccessor.java --- @@ -182,11 +182,14 @@ public R set(R record, F

[jira] [Commented] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes

[ https://issues.apache.org/jira/browse/FLINK-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226504#comment-15226504 ] Ron Crocker commented on FLINK-3697: [~rmetzger] This code is fine to use for your test case. The

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58562758 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -0,0

[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=15226491#comment-15226491 ] ASF GitHub Bot commented on FLINK-3311: --- Github user zentol commented on a diff in the pull request:

[jira] [Updated] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

[ https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3706: Attachment: log.txt > YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable >

[jira] [Created] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

Aljoscha Krettek created FLINK-3706: --- Summary: YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable Key: FLINK-3706 URL: https://issues.apache.org/jira/browse/FLINK-3706 Project: Flink

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58562221 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchExample.java --- @@

[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=15226486#comment-15226486 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[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=15226485#comment-15226485 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58562019 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/ClusterBuilder.java --- @@

[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=15226484#comment-15226484 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58562121 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchExample.java --- @@

[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=15226483#comment-15226483 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

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

[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=15226480#comment-15226480 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

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

[jira] [Comment Edited] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226474#comment-15226474 ] Maximilian Michels edited comment on FLINK-3655 at 4/5/16 3:37 PM: ---

[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=15226477#comment-15226477 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226474#comment-15226474 ] Maximilian Michels commented on FLINK-3655: --- Sounds good. It is important to maintain backwards

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58561096 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java --- @@

[jira] [Created] (FLINK-3705) Provide explanation for Hadoop dependencies and how to configure it

Ufuk Celebi created FLINK-3705: -- Summary: Provide explanation for Hadoop dependencies and how to configure it Key: FLINK-3705 URL: https://issues.apache.org/jira/browse/FLINK-3705 Project: Flink

[jira] [Commented] (FLINK-3614) Remove Non-Keyed Window Operator

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

[jira] [Resolved] (FLINK-3174) Add merging WindowAssigner

[ https://issues.apache.org/jira/browse/FLINK-3174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3174. - Resolution: Fixed Fix Version/s: (was: 1.0.0) 1.1.0 Done in

[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=15226447#comment-15226447 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58557862 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -0,0

[jira] [Resolved] (FLINK-3614) Remove Non-Keyed Window Operator

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

[GitHub] flink pull request: [FLINK-3614] Remove Non-Keyed Window Operator

Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/1805 --- 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-3174) Add merging WindowAssigner

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

[jira] [Commented] (FLINK-3614) Remove Non-Keyed Window Operator

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

[GitHub] flink pull request: [FLINK-3614] Remove Non-Keyed Window Operator

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1805#issuecomment-205855000 Manually merged. --- 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

[GitHub] flink pull request: [FLINK-3174] Add MergingWindowAssigner and Ses...

Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/1802 --- 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-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=15226433#comment-15226433 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58556585 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -0,0

[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=15226428#comment-15226428 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58556061 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -0,0

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58548774 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java --- @@

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58548996 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java --- @@

[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=15226375#comment-15226375 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[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=15226373#comment-15226373 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r58548581 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java --- @@

[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=15226369#comment-15226369 ] ASF GitHub Bot commented on FLINK-3311: --- Github user rmetzger commented on a diff in the pull

[jira] [Created] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable

Robert Metzger created FLINK-3704: - Summary: JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable Key: FLINK-3704 URL: https://issues.apache.org/jira/browse/FLINK-3704

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

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

[GitHub] flink pull request: FLINK-3398: Allow for opting-out from Kafka of...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1690#issuecomment-205819299 I think the functionality is very desirable. In many cases, you really don't want Flink to write something to Zookeeper for some random GroupId. This floods

[jira] [Commented] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09

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

[GitHub] flink pull request: [FLINK-3541] [Kafka Connector] Clean up workar...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1846#issuecomment-205811304 Yes, we can drop the retry loop. --- 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

[GitHub] flink pull request: [FLINK-3700] [core] Add 'Preconditions' utilit...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1853#issuecomment-205811166 +1 for 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

[jira] [Commented] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions

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

[jira] [Commented] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions

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

[GitHub] flink pull request: [FLINK-3700] [core] Remove Guava as a dependen...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1854 [FLINK-3700] [core] Remove Guava as a dependency from "flink-core" **Note: This builds on top of pull request #1853** Almost all Guava functionality used within `flink-core` has

[jira] [Commented] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions

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

[GitHub] flink pull request: [FLINK-3700] [core] Add 'Preconditions' utilit...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1853 [FLINK-3700] [core] Add 'Preconditions' utility class. The functionality that Flink uses from Guava is super simple and limited. We get a big dependency that has caused a lot of pain in the

[jira] [Commented] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager

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

  1   2   >