[jira] [Created] (FLINK-3474) Partial aggregate interface design and sort-based implementation

Chengxiang Li created FLINK-3474: Summary: Partial aggregate interface design and sort-based implementation Key: FLINK-3474 URL: https://issues.apache.org/jira/browse/FLINK-3474 Project: Flink

[jira] [Created] (FLINK-3473) Add partial aggregate support in Flink

Chengxiang Li created FLINK-3473: Summary: Add partial aggregate support in Flink Key: FLINK-3473 URL: https://issues.apache.org/jira/browse/FLINK-3473 Project: Flink Issue Type: Improvement

Re: Key expressions vs case class fields

Hi Greg, from a user's point of view, expression keys (dataSet.groupBy("_1")) and selector function keys (dataSet.groupBy(_._1)) are very similar in a Scala DataSet or DataStream program. This is due to Scala's shortcut for defining lambda functions. However, both key types are handled differentl

Re: Introducing a PR template

sure. will take that into account. Thanks for the input. best regards martin Maximilian Michels schrieb am So., 21. Feb. 2016 um 13:49 Uhr: > Hi Martin, > > Thanks for the proposal. This is a great idea and will help new > contributors. > > How about having three sections and less check boxes?

Re: Testing Flink

Hi Michael, Flink contains already some infra for creating tests (see Flink's own integration tests). Also, there is another project which provides a set of tools for tests: https://github.com/ottogroup/flink-spector On Mon, Feb 22, 2016 at 10:29 PM, Graeber, Michael wrote: > Hello, > > What ar

Testing Flink

Hello, What are some popular test infrastructures and/or tools being used to test flink or solutions using flink? I have not been able to find much regarding this topic. Thank you, Michael

[jira] [Created] (FLINK-3472) JDBCInputFormat.nextRecord(..) has misleading message on NPE

Ken Geis created FLINK-3472: --- Summary: JDBCInputFormat.nextRecord(..) has misleading message on NPE Key: FLINK-3472 URL: https://issues.apache.org/jira/browse/FLINK-3472 Project: Flink Issue Type:

[jira] [Created] (FLINK-3471) JDBCInputFormat cannot handle null fields of certain types

Ken Geis created FLINK-3471: --- Summary: JDBCInputFormat cannot handle null fields of certain types Key: FLINK-3471 URL: https://issues.apache.org/jira/browse/FLINK-3471 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-3470) EventTime WindowAssigners should error on negative timestamps

Stephan Ewen created FLINK-3470: --- Summary: EventTime WindowAssigners should error on negative timestamps Key: FLINK-3470 URL: https://issues.apache.org/jira/browse/FLINK-3470 Project: Flink Is

Key expressions vs case class fields

Hi, Looking at the documentation for "Transformations on Grouped DataSet" [1], what differentiates a key expression from case class fields? Is there a special Scala capability or are we still just passing strings? [1] https://ci.apache.org/projects/flink/flink-docs-master/apis/batch/dataset_trans

[jira] [Created] (FLINK-3469) Fix documentation for grouping keys

Greg Hogan created FLINK-3469: - Summary: Fix documentation for grouping keys Key: FLINK-3469 URL: https://issues.apache.org/jira/browse/FLINK-3469 Project: Flink Issue Type: Bug Compone

[jira] [Created] (FLINK-3468) Change Timestamp Extractors to not support negative timestamps

Stephan Ewen created FLINK-3468: --- Summary: Change Timestamp Extractors to not support negative timestamps Key: FLINK-3468 URL: https://issues.apache.org/jira/browse/FLINK-3468 Project: Flink I

[jira] [Created] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke

Greg Hogan created FLINK-3467: - Summary: Remove superfluous objects from DataSourceTask.invoke Key: FLINK-3467 URL: https://issues.apache.org/jira/browse/FLINK-3467 Project: Flink Issue Type: Imp

Fix version

Hi, With 1.0.0 imminent there are 112 tickets with a "fix version" of 1.0.0, the earliest from 2014. From the ticket logs it looks like we typically bump the fix version once the target release has passed. Would it be better to wait to assign a fix version until achieving some combination of sever

[jira] [Created] (FLINK-3465) Add SBT template script

Till Rohrmann created FLINK-3465: Summary: Add SBT template script Key: FLINK-3465 URL: https://issues.apache.org/jira/browse/FLINK-3465 Project: Flink Issue Type: Improvement Rep

[jira] [Created] (FLINK-3464) Add SBT build tool description to quickstart documentation

Till Rohrmann created FLINK-3464: Summary: Add SBT build tool description to quickstart documentation Key: FLINK-3464 URL: https://issues.apache.org/jira/browse/FLINK-3464 Project: Flink Issu

[jira] [Created] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt

Robert Metzger created FLINK-3466: - Summary: Job might get stuck in restoreState() from HDFS due to interrupt Key: FLINK-3466 URL: https://issues.apache.org/jira/browse/FLINK-3466 Project: Flink

[jira] [Created] (FLINK-3463) Implement Calc Support

Vasia Kalavri created FLINK-3463: Summary: Implement Calc Support Key: FLINK-3463 URL: https://issues.apache.org/jira/browse/FLINK-3463 Project: Flink Issue Type: Sub-task Component

[jira] [Created] (FLINK-3462) Add position and magic number checks to record (de)serializers

Ufuk Celebi created FLINK-3462: -- Summary: Add position and magic number checks to record (de)serializers Key: FLINK-3462 URL: https://issues.apache.org/jira/browse/FLINK-3462 Project: Flink Iss

[jira] [Created] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService

Ufuk Celebi created FLINK-3461: -- Summary: Remove duplicate condition check in ZooKeeperLeaderElectionService Key: FLINK-3461 URL: https://issues.apache.org/jira/browse/FLINK-3461 Project: Flink