[jira] [Updated] (FLINK-6813) Add TIMESTAMPDIFF supported in SQL

2017-06-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6813: --- Description: * Syntax TIMESTAMPDIFF ( datepart , startdate , enddate ) -datepart Is the part of

[jira] [Updated] (FLINK-6813) Add TIMESTAMPDIFF supported in SQL

2017-06-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6813: --- Description: * Syntax TIMESTAMPDIFF ( datepart , startdate , enddate ) -datepart Is the part of

[jira] [Commented] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-06-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16043935#comment-16043935 ] Ted Yu commented on FLINK-6772: --- {code} + for (String key: path.keySet()) { +

[jira] [Commented] (FLINK-6748) Table API / SQL Docs: Table API Page

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16043932#comment-16043932 ] ASF GitHub Bot commented on FLINK-6748: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #4093: [FLINK-6748] [table] [docs] Reworked Table API Pag...

2017-06-08 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/4093 [FLINK-6748] [table] [docs] Reworked Table API Page This is the first part of the reworked Table API page. I will create a second PR for the remaining TODOs. You can merge this pull request into a

[jira] [Updated] (FLINK-6813) Add TIMESTAMPDIFF supported in SQL

2017-06-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6813: --- Description: * Syntax TIMESTAMPDIFF ( datepart , startdate , enddate ) -datepart Is the part of

[jira] [Updated] (FLINK-6813) Add TIMESTAMPDIFF supported in SQL

2017-06-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6813: --- Description: * Syntax TIMESTAMPDIFF ( datepart , startdate , enddate ) -datepart Is the part of

[GitHub] flink pull request #4092: [FLINK-6876] [streaming] Correct the comments of D...

2017-06-08 Thread dianfu
GitHub user dianfu opened a pull request: https://github.com/apache/flink/pull/4092 [FLINK-6876] [streaming] Correct the comments of DataStream#assignTimestampsAndWatermarks This PR corrects the comments of DataStream#assignTimestampsAndWatermarks. Thanks for

[jira] [Commented] (FLINK-6876) The comment of DataStream#assignTimestampsAndWatermarks is incorrect

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16043888#comment-16043888 ] ASF GitHub Bot commented on FLINK-6876: --- GitHub user dianfu opened a pull request:

[jira] [Created] (FLINK-6876) The comment of DataStream#assignTimestampsAndWatermarks is incorrect

2017-06-08 Thread Dian Fu (JIRA)
Dian Fu created FLINK-6876: -- Summary: The comment of DataStream#assignTimestampsAndWatermarks is incorrect Key: FLINK-6876 URL: https://issues.apache.org/jira/browse/FLINK-6876 Project: Flink

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042989#comment-16042989 ] ASF GitHub Bot commented on FLINK-6749: --- Github user haohui closed the pull request at:

[GitHub] flink pull request #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Pag...

2017-06-08 Thread haohui
Github user haohui closed the pull request at: https://github.com/apache/flink/pull/4046 --- 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] [Updated] (FLINK-6873) Limit the number of open writers in file system connector

2017-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6873: -- Component/s: Streaming Connectors Local Runtime

[jira] [Updated] (FLINK-6738) HBaseConnectorITCase is flaky

2017-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6738: -- Component/s: Streaming Connectors > HBaseConnectorITCase is flaky >

[jira] [Updated] (FLINK-6848) Extend the managed state docs with a Scala example

2017-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6848: -- Component/s: State Backends, Checkpointing Documentation > Extend the managed

[jira] [Updated] (FLINK-6730) Activate strict checkstyle for flink-optimizer

2017-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6730: -- Component/s: Build System > Activate strict checkstyle for flink-optimizer >

[jira] [Updated] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6615: -- Component/s: Local Runtime > tmp directory not cleaned up on shutdown >

[jira] [Updated] (FLINK-6839) Improve SQL OVER alias When only one OVER window agg in selection.

2017-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6839: -- Component/s: Table API & SQL > Improve SQL OVER alias When only one OVER window agg in

[jira] [Updated] (FLINK-6698) Activate strict checkstyle

2017-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6698: -- Component/s: Build System > Activate strict checkstyle > -- > >

[jira] [Updated] (FLINK-6835) Document the checkstyle requirements

2017-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6835: -- Component/s: Documentation > Document the checkstyle requirements >

[jira] [Updated] (FLINK-6729) Activate strict checkstyle for flink-runtime

2017-06-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6729: -- Component/s: Build System > Activate strict checkstyle for flink-runtime >

[jira] [Comment Edited] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

2017-06-08 Thread SmedbergM (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042807#comment-16042807 ] SmedbergM edited comment on FLINK-6866 at 6/8/17 4:20 PM: -- In Scala 2.11 and

[jira] [Commented] (FLINK-6692) The flink-dist jar contains unshaded netty jar

2017-06-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042899#comment-16042899 ] Nico Kruber commented on FLINK-6692: I tried shading netty in runtime but other modules use

[jira] [Comment Edited] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042864#comment-16042864 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6857 at 6/8/17 3:38 PM:

[jira] [Comment Edited] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042864#comment-16042864 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6857 at 6/8/17 3:38 PM:

[jira] [Comment Edited] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042864#comment-16042864 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6857 at 6/8/17 3:36 PM:

[jira] [Commented] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042866#comment-16042866 ] Tzu-Li (Gordon) Tai commented on FLINK-6857: The JIRA would therefore also entail adding the

[jira] [Commented] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042864#comment-16042864 ] Tzu-Li (Gordon) Tai commented on FLINK-6857: [~StephanEwen] no, the current

[jira] [Comment Edited] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042864#comment-16042864 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6857 at 6/8/17 3:34 PM:

[jira] [Commented] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042855#comment-16042855 ] Stephan Ewen commented on FLINK-6857: - This exists in the {{ExecutionConfig}}, which is per

[jira] [Closed] (FLINK-6875) Remote DataSet API job submission timing out

2017-06-08 Thread Francisco Rosa (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francisco Rosa closed FLINK-6875. - Resolution: Invalid I believe this was a versioning issue. Version on server did not match client

[GitHub] flink pull request #3877: [backport] [FLINK-6514] [build] Create a proper se...

2017-06-08 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/3877 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042832#comment-16042832 ] ASF GitHub Bot commented on FLINK-6514: --- Github user StephanEwen closed the pull request at:

[jira] [Updated] (FLINK-6875) Remote DataSet API job submission timing out

2017-06-08 Thread Francisco Rosa (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francisco Rosa updated FLINK-6875: -- Description: When trying to submit a DataSet API job from a remote environment, Flink times

[jira] [Created] (FLINK-6875) Remote DataSet API job submission timing out

2017-06-08 Thread Francisco Rosa (JIRA)
Francisco Rosa created FLINK-6875: - Summary: Remote DataSet API job submission timing out Key: FLINK-6875 URL: https://issues.apache.org/jira/browse/FLINK-6875 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

2017-06-08 Thread SmedbergM (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042807#comment-16042807 ] SmedbergM commented on FLINK-6866: -- In Scala 2.11 and before, inner class

[GitHub] flink pull request #4091: [FLINK-6874] [docs] Static and transient fields ig...

2017-06-08 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/4091 [FLINK-6874] [docs] Static and transient fields ignored for POJOs Note that static and transient fields are ignored when TypeExtrator validates a POJO. You can merge this pull request into a Git

[jira] [Commented] (FLINK-6874) Static and transient fields ignored for POJOs

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042803#comment-16042803 ] ASF GitHub Bot commented on FLINK-6874: --- GitHub user greghogan opened a pull request:

[jira] [Closed] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-06-08 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6772. - Resolution: Fixed Fix Version/s: 1.3.1 Merged at 5d3506e > Incorrect ordering of matched

[jira] [Updated] (FLINK-6874) Static and transient fields ignored for POJOs

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6874: -- Description: Update {{dev/types_serialization.html}} to note that static and transient fields are

[jira] [Updated] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

2017-06-08 Thread SmedbergM (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SmedbergM updated FLINK-6866: - Affects Version/s: 1.3.0 Environment: Scala 2.10.6, Scala 2.11.11 Does not appear using Scala

[jira] [Commented] (FLINK-6683) building with Scala 2.11 no longer uses change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042796#comment-16042796 ] Greg Hogan commented on FLINK-6683: --- Ah, so it was accidentally merged from master and then reverted. >

[jira] [Updated] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6414: -- Fix Version/s: (was: 1.3.0) > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Closed] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6414. - Resolution: Fixed > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Reopened] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reopened FLINK-6414: --- > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Created] (FLINK-6874) Static and transient fields ignored for POJOs

2017-06-08 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6874: - Summary: Static and transient fields ignored for POJOs Key: FLINK-6874 URL: https://issues.apache.org/jira/browse/FLINK-6874 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042789#comment-16042789 ] ASF GitHub Bot commented on FLINK-6749: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Page

2017-06-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4046 Hi @haohui, I merged the PR to the `tableDocs` branch. Can you close it? Thanks! --- 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-6683) building with Scala 2.11 no longer uses change-scala-version.sh

2017-06-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042786#comment-16042786 ] Stephan Ewen commented on FLINK-6683: - Okay, I am confused now. When I browse the code in the

[jira] [Resolved] (FLINK-6871) Obsolete instruction for changing scala version for build

2017-06-08 Thread William Saar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] William Saar resolved FLINK-6871. - Resolution: Duplicate Correct, refers to master and duplicates issue, sorry for missing that one.

[jira] [Commented] (FLINK-6683) building with Scala 2.11 no longer uses change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042766#comment-16042766 ] Greg Hogan commented on FLINK-6683: --- FLINK-6414 was committed to both 1.3

[jira] [Closed] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6414. - Resolution: Fixed > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Updated] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6414: -- Fix Version/s: 1.4.0 > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Reopened] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reopened FLINK-6414: --- > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Updated] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6414: -- Fix Version/s: (was: 1.4.0) > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Reopened] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reopened FLINK-6414: --- > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Updated] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6414: -- Fix Version/s: 1.3.0 > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Reopened] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reopened FLINK-6414: --- > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Closed] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6414. - Resolution: Fixed > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Closed] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6414. - Resolution: Fixed > Use scala.binary.version in place of change-scala-version.sh >

[jira] [Created] (FLINK-6873) Limit the number of open writers in file system connector

2017-06-08 Thread Mu Kong (JIRA)
Mu Kong created FLINK-6873: -- Summary: Limit the number of open writers in file system connector Key: FLINK-6873 URL: https://issues.apache.org/jira/browse/FLINK-6873 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6683) building with Scala 2.11 no longer uses change-scala-version.sh

2017-06-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042752#comment-16042752 ] Stephan Ewen commented on FLINK-6683: - The update for the Scala version actually affects the master

[jira] [Commented] (FLINK-6871) Obsolete instruction for changing scala version for build

2017-06-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042753#comment-16042753 ] Stephan Ewen commented on FLINK-6871: - This refers to the {{master}} branch, not the {{1.3}} release?

[jira] [Commented] (FLINK-6683) building with Scala 2.11 no longer uses change-scala-version.sh

2017-06-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042748#comment-16042748 ] Stephan Ewen commented on FLINK-6683: - +1 to say Scala 2.12 does not work (only 2.10 and 2.11 work at

[jira] [Closed] (FLINK-6872) Add MissingOverride to checkstyle

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6872. - Resolution: Won't Fix Hmm, you're right, that isn't what I wanted. > Add MissingOverride to checkstyle >

[jira] [Commented] (FLINK-6869) Scala serializers do not have the serialVersionUID specified

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042744#comment-16042744 ] ASF GitHub Bot commented on FLINK-6869: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #4090: [FLINK-6869] [scala] Specify serialVersionUID for all Sca...

2017-06-08 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4090 Overall, I think this is ok as a best effort until we have some eager registration that helps with the remaining problems in the heap backend. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-6872) Add MissingOverride to checkstyle

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042743#comment-16042743 ] Chesnay Schepler commented on FLINK-6872: - the {{@inheridDoc}} tag seems to be rarely used in

[jira] [Commented] (FLINK-6871) Obsolete instruction for changing scala version for build

2017-06-08 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042736#comment-16042736 ] David Anderson commented on FLINK-6871: --- This issue duplicates FLINK-6683 > Obsolete instruction

[jira] [Created] (FLINK-6872) Add MissingOverride to checkstyle

2017-06-08 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6872: - Summary: Add MissingOverride to checkstyle Key: FLINK-6872 URL: https://issues.apache.org/jira/browse/FLINK-6872 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-6869) Scala serializers do not have the serialVersionUID specified

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042720#comment-16042720 ] ASF GitHub Bot commented on FLINK-6869: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4090: [FLINK-6869] [scala] Specify serialVersionUID for all Sca...

2017-06-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4090 One caveat that this PR does not yet fully fix: the deserialization of the anonymous class serializers (`CaseClassSerializer` and `TraversableSerializer`), even with the `serialVersionUID`

[jira] [Commented] (FLINK-6871) Obsolete instruction for changing scala version for build

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042719#comment-16042719 ] Greg Hogan commented on FLINK-6871: --- This should be corrected. The change-scala-version script is no

[jira] [Commented] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042718#comment-16042718 ] ASF GitHub Bot commented on FLINK-6772: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4084: [FLINK-6772] [cep] Fix ordering (by timestamp) of ...

2017-06-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4084 --- 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-6869) Scala serializers do not have the serialVersionUID specified

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042717#comment-16042717 ] ASF GitHub Bot commented on FLINK-6869: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4090: [FLINK-6869] [scala] Specify serialVersionUID for all Sca...

2017-06-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4090 R: @StefanRRichter @aljoscha tagging you because I talked to you about the issue offline :) Could you have a quick look? --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-6869) Scala serializers do not have the serialVersionUID specified

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042715#comment-16042715 ] ASF GitHub Bot commented on FLINK-6869: --- GitHub user tzulitai opened a pull request:

[GitHub] flink pull request #4090: [FLINK-6869] [scala] Specify serialVersionUID for ...

2017-06-08 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4090 [FLINK-6869] [scala] Specify serialVersionUID for all Scala serializers This PR fixes 2 issues: 1. Configuration snapshots of Scala serializers were not readable: Prior to this PR, the

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042691#comment-16042691 ] ASF GitHub Bot commented on FLINK-6783: --- Github user greghogan commented on the issue:

[GitHub] flink issue #4089: [FLINK-6783][hotfix] Removed lamba indices for abstract c...

2017-06-08 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4089 A hotfix is for when no FLINK ticket has been created, and typically no PR. This commit header should be something like `[FLINK-6783] [streaming]`. --- If your project is set up for it, you can

[jira] [Created] (FLINK-6871) Obsolete instruction for changing scala version for build

2017-06-08 Thread William Saar (JIRA)
William Saar created FLINK-6871: --- Summary: Obsolete instruction for changing scala version for build Key: FLINK-6871 URL: https://issues.apache.org/jira/browse/FLINK-6871 Project: Flink Issue

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6868: -- Priority: Critical (was: Blocker) > Using `scala.binary.version` for `flink-streaming-scala` in

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6868: -- Affects Version/s: (was: 1.3.0) 1.4.0 > Using `scala.binary.version` for

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6868: -- Priority: Blocker (was: Critical) > Using `scala.binary.version` for `flink-streaming-scala` in

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6868: -- Fix Version/s: (was: 1.3.1) > Using `scala.binary.version` for `flink-streaming-scala` in

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6868: -- Issue Type: Bug (was: Improvement) > Using `scala.binary.version` for `flink-streaming-scala` in

[jira] [Commented] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042682#comment-16042682 ] Greg Hogan commented on FLINK-6868: --- The affected code was added by FLINK-4497 in the master branch for

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042678#comment-16042678 ] ASF GitHub Bot commented on FLINK-6783: --- Github user dawidwys closed the pull request at:

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042677#comment-16042677 ] ASF GitHub Bot commented on FLINK-6783: --- Github user dawidwys commented on the issue:

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

2017-06-08 Thread dawidwys
Github user dawidwys closed the pull request at: https://github.com/apache/flink/pull/4039 --- 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 issue #4039: [FLINK-6783] Changed passing index of type argument while...

2017-06-08 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4039 I created a hotfix for the discussed issue: #4089 . I will close this PR then. --- 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-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042675#comment-16042675 ] ASF GitHub Bot commented on FLINK-6783: --- GitHub user dawidwys opened a pull request:

[GitHub] flink pull request #4089: [FLINK-6783][hotfix] Removed lamba indices for abs...

2017-06-08 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/4089 [FLINK-6783][hotfix] Removed lamba indices for abstract classes Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042665#comment-16042665 ] ASF GitHub Bot commented on FLINK-6783: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

2017-06-08 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120882223 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java --- @@ -507,12 +505,41 @@ public

[jira] [Updated] (FLINK-6870) Combined batch and stream TableSource can not produce same time attributes

2017-06-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6870: Affects Version/s: 1.4.0 > Combined batch and stream TableSource can not produce same time

[jira] [Created] (FLINK-6870) Combined batch and stream TableSource can not produce same time attributes

2017-06-08 Thread Timo Walther (JIRA)
Timo Walther created FLINK-6870: --- Summary: Combined batch and stream TableSource can not produce same time attributes Key: FLINK-6870 URL: https://issues.apache.org/jira/browse/FLINK-6870 Project:

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042628#comment-16042628 ] ASF GitHub Bot commented on FLINK-6783: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

2017-06-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120875203 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java --- @@ -507,12 +505,41 @@ public

  1   2   >