[jira] [Resolved] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions.

[ https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4068. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in a71133945e66ec471b4cb07da0693d545c40923c

[jira] [Resolved] (FLINK-4546) Remove STREAM keyword in Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4546. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 72e6b760fd951764c3ecc6fc191dc99a42d55e0b.

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15556725#comment-15556725 ] Timo Walther commented on FLINK-4604: - I think a even nicer solution would be to check the aggregation

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15554766#comment-15554766 ] Timo Walther commented on FLINK-4604: - Yes, you are right. We have to make the costs for STDDEV_POP,

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15554774#comment-15554774 ] Timo Walther commented on FLINK-4743: - Just a small hint on this: It seems that

[jira] [Updated] (FLINK-4762) Use plural in time interval units

[ https://issues.apache.org/jira/browse/FLINK-4762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4762: Issue Type: Improvement (was: Bug) > Use plural in time interval units >

[jira] [Created] (FLINK-4762) Use plural in time interval units

Timo Walther created FLINK-4762: --- Summary: Use plural in time interval units Key: FLINK-4762 URL: https://issues.apache.org/jira/browse/FLINK-4762 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15551943#comment-15551943 ] Timo Walther edited comment on FLINK-4604 at 10/6/16 2:28 PM: -- Ok, it seems

[jira] [Commented] (FLINK-4790) FlinkML - Error of type while using readCsvFile

[ https://issues.apache.org/jira/browse/FLINK-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562316#comment-15562316 ] Timo Walther commented on FLINK-4790: - When using the Scala API, make sure to import the package:

[jira] [Commented] (FLINK-4790) FlinkML - Error of type while using readCsvFile

[ https://issues.apache.org/jira/browse/FLINK-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562442#comment-15562442 ] Timo Walther commented on FLINK-4790: - I will close the issue for now. But you are welcome to open a

[jira] [Closed] (FLINK-4790) FlinkML - Error of type while using readCsvFile

[ https://issues.apache.org/jira/browse/FLINK-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-4790. --- Resolution: Won't Fix > FlinkML - Error of type while using readCsvFile >

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15509376#comment-15509376 ] Timo Walther commented on FLINK-4624: - {{VertexGroupItem}} and {{VertexGroupItem}} are

[jira] [Assigned] (FLINK-4241) Cryptic expression parser exceptions

[ https://issues.apache.org/jira/browse/FLINK-4241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4241: --- Assignee: Timo Walther > Cryptic expression parser exceptions >

[jira] [Commented] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink"

[ https://issues.apache.org/jira/browse/FLINK-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15492738#comment-15492738 ] Timo Walther commented on FLINK-1135: - No this won't happen. I will close the issue. > Blog post with

[jira] [Closed] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink"

[ https://issues.apache.org/jira/browse/FLINK-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-1135. --- Resolution: Won't Fix > Blog post with topic "Accessing Data Stored in Hive with Flink" >

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15503481#comment-15503481 ] Timo Walther commented on FLINK-4565: - I looked into the code for this issue. It would be very tricky

[jira] [Resolved] (FLINK-3042) Define a way to let types create their own TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-3042. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 4cc38fd36f3190f9c0066e9cf94580669b2410cf.

[jira] [Resolved] (FLINK-3060) Add possibility to integrate custom types into the TypeExtractor

[ https://issues.apache.org/jira/browse/FLINK-3060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-3060. - Resolution: Fixed Assignee: Timo Walther Fix Version/s: 1.2.0 This has been fixed

[jira] [Created] (FLINK-4655) Add tests for validation of Expressions

Timo Walther created FLINK-4655: --- Summary: Add tests for validation of Expressions Key: FLINK-4655 URL: https://issues.apache.org/jira/browse/FLINK-4655 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-4621) Improve decimal literals of SQL API

Timo Walther created FLINK-4621: --- Summary: Improve decimal literals of SQL API Key: FLINK-4621 URL: https://issues.apache.org/jira/browse/FLINK-4621 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-4081) FieldParsers should support empty strings

[ https://issues.apache.org/jira/browse/FLINK-4081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4081. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 4b1a9c72e99125680035e5dadc148b187d9d4124.

[jira] [Created] (FLINK-4639) Make Calcite features more pluggable

Timo Walther created FLINK-4639: --- Summary: Make Calcite features more pluggable Key: FLINK-4639 URL: https://issues.apache.org/jira/browse/FLINK-4639 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-4557) Table API Stream Aggregations

[ https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15506053#comment-15506053 ] Timo Walther commented on FLINK-4557: - [~shijinkui] I will create issues for the subtasks once the

[jira] [Assigned] (FLINK-4639) Make Calcite features more pluggable

[ https://issues.apache.org/jira/browse/FLINK-4639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4639: --- Assignee: Timo Walther > Make Calcite features more pluggable >

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15506211#comment-15506211 ] Timo Walther commented on FLINK-4624: - You can get rid of the {{ClassCastException}} by using the

[jira] [Resolved] (FLINK-4549) Test and document implicitly supported SQL functions

[ https://issues.apache.org/jira/browse/FLINK-4549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4549. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 9a1bc021aed0a3eec8c6eabb843d15b8c2b0b43f.

[jira] [Created] (FLINK-4671) Table API can not be built

Timo Walther created FLINK-4671: --- Summary: Table API can not be built Key: FLINK-4671 URL: https://issues.apache.org/jira/browse/FLINK-4671 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513450#comment-15513450 ] Timo Walther commented on FLINK-4263: - I think they don't need to be basic types even though it is

[jira] [Resolved] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4248. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 3507d59f969485dd735487e6bf3eb893b2e3d8ed.

[jira] [Created] (FLINK-4662) Bump Calcite version up to 1.9

Timo Walther created FLINK-4662: --- Summary: Bump Calcite version up to 1.9 Key: FLINK-4662 URL: https://issues.apache.org/jira/browse/FLINK-4662 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-4268) Add a parsers for BigDecimal/BigInteger

[ https://issues.apache.org/jira/browse/FLINK-4268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4268. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 5c02988b05c56f524fc8c65b15e16b0c24278a5e.

[jira] [Resolved] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4247. - Resolution: Fixed Assignee: Timo Walther Fix Version/s: 1.2.0 Fixed in

[jira] [Closed] (FLINK-4393) Failed to serialize accumulators for task

[ https://issues.apache.org/jira/browse/FLINK-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-4393. --- Resolution: Won't Fix This issue does not describe a bug. > Failed to serialize accumulators for

[jira] [Assigned] (FLINK-4288) Make it possible to unregister tables

[ https://issues.apache.org/jira/browse/FLINK-4288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4288: --- Assignee: Timo Walther > Make it possible to unregister tables >

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469873#comment-15469873 ] Timo Walther commented on FLINK-4565: - Calcite translates the IN operator in

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469879#comment-15469879 ] Timo Walther commented on FLINK-4565: - It seems my answer was to late. Yes, I would also go for the

[jira] [Commented] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513311#comment-15513311 ] Timo Walther commented on FLINK-4661: - Today [~fhueske] and me also have problems in compiling

[jira] [Assigned] (FLINK-4554) Add support for array types

[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4554: --- Assignee: Timo Walther > Add support for array types > --- > >

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513302#comment-15513302 ] Timo Walther commented on FLINK-4263: - I also had a look at it. Replacing {{Seq[Row]}} field by

[jira] [Resolved] (FLINK-4189) Introduce symbols for internal use

[ https://issues.apache.org/jira/browse/FLINK-4189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4189. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in cc7450d1d1ee3b5189d92ba8642c7c6cffdf056a.

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445747#comment-15445747 ] Timo Walther commented on FLINK-4469: - Instead of using an `Iterable` as return type, I would define

[jira] [Resolved] (FLINK-4420) Introduce star(*) to select all of the columns in the table

[ https://issues.apache.org/jira/browse/FLINK-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4420. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 1f17886198eb67c8fdb53b96098ebb812029b3ba.

[jira] [Commented] (FLINK-4554) Add support for array types

[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526259#comment-15526259 ] Timo Walther commented on FLINK-4554: - [~kirill-morozov-epam] thanks for your interest. Unfortunately,

[jira] [Updated] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3

[ https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-3154: Description: Flink's Kryo version is outdated and could be updated to a newer version, e.g.

[jira] [Created] (FLINK-4704) Move Table API to org.apache.flink.table

Timo Walther created FLINK-4704: --- Summary: Move Table API to org.apache.flink.table Key: FLINK-4704 URL: https://issues.apache.org/jira/browse/FLINK-4704 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4699) Convert Kafka TableSource/TableSink tests to unit tests

Timo Walther created FLINK-4699: --- Summary: Convert Kafka TableSource/TableSink tests to unit tests Key: FLINK-4699 URL: https://issues.apache.org/jira/browse/FLINK-4699 Project: Flink Issue

[jira] [Resolved] (FLINK-4662) Bump Calcite version up to 1.9

[ https://issues.apache.org/jira/browse/FLINK-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4662. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 8fa313c39fbad7bb96327477544d1ec15e8dc0f6.

[jira] [Assigned] (FLINK-4671) Table API can not be built

[ https://issues.apache.org/jira/browse/FLINK-4671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4671: --- Assignee: Timo Walther > Table API can not be built > -- > >

[jira] [Resolved] (FLINK-4671) Table API can not be built

[ https://issues.apache.org/jira/browse/FLINK-4671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4671. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in e5d62da2c98ad9c6a5ca9c0782a7fea8a01d639a.

[jira] [Created] (FLINK-4691) Add group-windows for streaming tables

Timo Walther created FLINK-4691: --- Summary: Add group-windows for streaming tables Key: FLINK-4691 URL: https://issues.apache.org/jira/browse/FLINK-4691 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4692) Add tumbling and sliding group-windows for batch tables

Timo Walther created FLINK-4692: --- Summary: Add tumbling and sliding group-windows for batch tables Key: FLINK-4692 URL: https://issues.apache.org/jira/browse/FLINK-4692 Project: Flink Issue

[jira] [Created] (FLINK-4693) Add session group-windows for batch tables

Timo Walther created FLINK-4693: --- Summary: Add session group-windows for batch tables Key: FLINK-4693 URL: https://issues.apache.org/jira/browse/FLINK-4693 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575320#comment-15575320 ] Timo Walther commented on FLINK-4604: - The problem is that the rule translates not only into {{SUM}}

[jira] [Created] (FLINK-4832) Count/Sum 0 elements

Timo Walther created FLINK-4832: --- Summary: Count/Sum 0 elements Key: FLINK-4832 URL: https://issues.apache.org/jira/browse/FLINK-4832 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15666782#comment-15666782 ] Timo Walther commented on FLINK-4832: - We should first fix FLINK-4263 before we implement this issue.

[jira] [Assigned] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4263: --- Assignee: Timo Walther (was: Jark Wu) > SQL's VALUES does not work properly >

[jira] [Resolved] (FLINK-5124) Support more temporal arithmetic

[ https://issues.apache.org/jira/browse/FLINK-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-5124. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 4653ad388b05b3ba7e37982bb8af09e7fcbed6be.

[jira] [Created] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

Timo Walther created FLINK-5144: --- Summary: Error while applying rule AggregateJoinTransposeRule Key: FLINK-5144 URL: https://issues.apache.org/jira/browse/FLINK-5144 Project: Flink Issue Type:

[jira] [Created] (FLINK-5143) Add EXISTS to list of supported operators

Timo Walther created FLINK-5143: --- Summary: Add EXISTS to list of supported operators Key: FLINK-5143 URL: https://issues.apache.org/jira/browse/FLINK-5143 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5124) Support more temporal arithmetic

Timo Walther created FLINK-5124: --- Summary: Support more temporal arithmetic Key: FLINK-5124 URL: https://issues.apache.org/jira/browse/FLINK-5124 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-4294) Allow access of composite type fields

[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4294. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in e45096867a9542a756443310a535a971a6a29695.

[jira] [Created] (FLINK-5177) Improve nullability handling

Timo Walther created FLINK-5177: --- Summary: Improve nullability handling Key: FLINK-5177 URL: https://issues.apache.org/jira/browse/FLINK-5177 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation

[ https://issues.apache.org/jira/browse/FLINK-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15701687#comment-15701687 ] Timo Walther commented on FLINK-4825: - [~jark] unfortunately, there many other issues than just

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15667697#comment-15667697 ] Timo Walther commented on FLINK-4604: - I looked into the problem. If you take a look at

[jira] [Resolved] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4263. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 836fe9786631f35953c1423e2d92128e9f292621.

[jira] [Assigned] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4872: --- Assignee: Timo Walther > Type erasure problem exclusively on cluster execution >

[jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673725#comment-15673725 ] Timo Walther commented on FLINK-4872: - [~mju] thank you very much for reporting this issue and

[jira] [Created] (FLINK-5078) Introduce annotations for classes copied from Calcite

Timo Walther created FLINK-5078: --- Summary: Introduce annotations for classes copied from Calcite Key: FLINK-5078 URL: https://issues.apache.org/jira/browse/FLINK-5078 Project: Flink Issue

[jira] [Commented] (FLINK-4969) TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos.

[ https://issues.apache.org/jira/browse/FLINK-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15667040#comment-15667040 ] Timo Walther commented on FLINK-4969: - The definition of type information using Strings is deprecated.

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15666872#comment-15666872 ] Timo Walther commented on FLINK-4604: - I think the missing type for {{NULL}} is a Calcite issue.

[jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15667250#comment-15667250 ] Timo Walther commented on FLINK-4872: - [~mju] can you also give an example for the class {{UDF}}? Does

[jira] [Resolved] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions

[ https://issues.apache.org/jira/browse/FLINK-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4801. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 1.2.0 with

[jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15667216#comment-15667216 ] Timo Walther commented on FLINK-4872: - I will look into this issue. > Type erasure problem

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565447#comment-15565447 ] Timo Walther commented on FLINK-4743: - Power can basically express both. I would just implement power

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

[ https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565341#comment-15565341 ] Timo Walther commented on FLINK-4793: - I found another bug that I will fix in a upcoming PR. Now this

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

[ https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565337#comment-15565337 ] Timo Walther commented on FLINK-4793: - [~tdunning] which Flink version are you using? Your issue might

[jira] [Created] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions

Timo Walther created FLINK-4801: --- Summary: Input type inference is faulty with custom Tuples and RichFunctions Key: FLINK-4801 URL: https://issues.apache.org/jira/browse/FLINK-4801 Project: Flink

[jira] [Updated] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions

[ https://issues.apache.org/jira/browse/FLINK-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4801: Component/s: (was: Table API & SQL) Type Serialization System > Input type

[jira] [Updated] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation

[ https://issues.apache.org/jira/browse/FLINK-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4825: Description: The added {{ReduceExpressionRule}} leads to inconsistent behavior. Because some parts

[jira] [Resolved] (FLINK-4791) Fix issues caused by expression reduction

[ https://issues.apache.org/jira/browse/FLINK-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4791. - Resolution: Fixed Fix Version/s: 1.2.0 Temporarily fixed by disabling the rule in

[jira] [Resolved] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

[ https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4793. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 1dda3ad009667697a620359e997e83a5ba2447dd.

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569021#comment-15569021 ] Timo Walther commented on FLINK-4604: - You cannot use

[jira] [Created] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation

Timo Walther created FLINK-4825: --- Summary: Implement a RexExecutor that uses Flink's code generation Key: FLINK-4825 URL: https://issues.apache.org/jira/browse/FLINK-4825 Project: Flink Issue

[jira] [Commented] (FLINK-4783) Allow to register TypeInfoFactories manually

[ https://issues.apache.org/jira/browse/FLINK-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15561665#comment-15561665 ] Timo Walther commented on FLINK-4783: - Stephan and I had a discussion about globally assigned

[jira] [Resolved] (FLINK-4745) Convert KafkaTableSource test to unit tests

[ https://issues.apache.org/jira/browse/FLINK-4745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4745. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 5e30ba384934b08861a970744db64b5123cfeff8.

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15561815#comment-15561815 ] Timo Walther commented on FLINK-4604: - Yes, I mean {{matches}}. {{DataSetAggregate}} does not support

[jira] [Commented] (FLINK-4108) NPE in Row.productArity

[ https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15561763#comment-15561763 ] Timo Walther commented on FLINK-4108: - Actually, RowTypeInfo was intended for the Table API only. If

[jira] [Created] (FLINK-4791) Fix issues caused by expression reduction

Timo Walther created FLINK-4791: --- Summary: Fix issues caused by expression reduction Key: FLINK-4791 URL: https://issues.apache.org/jira/browse/FLINK-4791 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-4108) NPE in Row.productArity

[ https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4108: --- Assignee: Timo Walther > NPE in Row.productArity > --- > >

[jira] [Assigned] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

[ https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4793: --- Assignee: Timo Walther > Using a local method with :: notation in Java 8 causes index out of

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

[ https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564985#comment-15564985 ] Timo Walther commented on FLINK-4793: - I will look into this. > Using a local method with :: notation

[jira] [Resolved] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4872. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 3a27f55cfa03a96cb7aff5d25a6402a283be7b45.

[jira] [Resolved] (FLINK-4554) Add support for array types

[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4554. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 4414008551b2843d98b3caddbb171fa1934e1f40.

[jira] [Created] (FLINK-5289) NPE when using value state on non-keyed stream

Timo Walther created FLINK-5289: --- Summary: NPE when using value state on non-keyed stream Key: FLINK-5289 URL: https://issues.apache.org/jira/browse/FLINK-5289 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5304) Change method name from crossApply to join in Table API

[ https://issues.apache.org/jira/browse/FLINK-5304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15734941#comment-15734941 ] Timo Walther commented on FLINK-5304: - I'm fine with this change but what happens with {{outerApply}}?

[jira] [Assigned] (FLINK-5319) ClassCastException when reusing an inherited method reference as KeySelector for different classes

[ https://issues.apache.org/jira/browse/FLINK-5319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-5319: --- Assignee: Timo Walther > ClassCastException when reusing an inherited method reference as

[jira] [Commented] (FLINK-5319) ClassCastException when reusing an inherited method reference as KeySelector for different classes

[ https://issues.apache.org/jira/browse/FLINK-5319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747666#comment-15747666 ] Timo Walther commented on FLINK-5319: - I will look into this issue. > ClassCastException when reusing

[jira] [Commented] (FLINK-5319) ClassCastException when reusing an inherited method reference as KeySelector for different classes

[ https://issues.apache.org/jira/browse/FLINK-5319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747815#comment-15747815 ] Timo Walther commented on FLINK-5319: - This is not a type issue but a lambda serialization issue.

[jira] [Created] (FLINK-5333) Keep Windows scripts in sync with shell scripts

Timo Walther created FLINK-5333: --- Summary: Keep Windows scripts in sync with shell scripts Key: FLINK-5333 URL: https://issues.apache.org/jira/browse/FLINK-5333 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5319) ClassCastException when reusing an inherited method reference as KeySelector for different classes

[ https://issues.apache.org/jira/browse/FLINK-5319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747965#comment-15747965 ] Timo Walther commented on FLINK-5319: - Could you post this to one of the Java mailing lists? >

<    1   2   3   4   5   6   7   8   9   10   >