[jira] [Assigned] (FLINK-8435) Adding BloomFilter/HyperLogLog state as Managed once

2018-01-16 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-8435: --- Assignee: Aegeaner > Adding BloomFilter/HyperLogLog state as Managed once >

[jira] [Assigned] (FLINK-8354) Flink Kafka connector ignores Kafka message headers

2018-01-16 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-8354: --- Assignee: Aegeaner > Flink Kafka connector ignores Kafka message headers >

[jira] [Assigned] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector

2017-12-04 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-8191: --- Assignee: Aegeaner > Add a RoundRobinPartitioner to be shipped with the Kafka connector >

[jira] [Commented] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-11-29 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16271988#comment-16271988 ] Aegeaner commented on FLINK-8173: - Assignment conversion not possible from type "java.lang.CharSequence"

[jira] [Commented] (FLINK-8139) Check for proper equals() and hashCode() when registering a table

2017-11-27 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268127#comment-16268127 ] Aegeaner commented on FLINK-8139: - know it, we can get the type class. > Check for proper equals() and

[jira] [Assigned] (FLINK-8139) Check for proper equals() and hashCode() when registering a table

2017-11-23 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-8139: --- Assignee: Aegeaner > Check for proper equals() and hashCode() when registering a table >

[jira] [Commented] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

2017-06-29 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16069385#comment-16069385 ] Aegeaner commented on FLINK-7036: - Hi [~jark] I have just created a skeleton but you can try it:

[jira] [Updated] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

2017-06-29 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner updated FLINK-7036: Affects Version/s: 1.4.0 > Type cast in ExpressionReducer's reduce broke CodeGen's compile stage >

[jira] [Updated] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

2017-06-29 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner updated FLINK-7036: Component/s: Table API & SQL > Type cast in ExpressionReducer's reduce broke CodeGen's compile stage >

[jira] [Updated] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

2017-06-29 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner updated FLINK-7032: Component/s: Build System > Intellij is constantly changing language level of sub projects back to 1.6 >

[jira] [Created] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

2017-06-29 Thread Aegeaner (JIRA)
Aegeaner created FLINK-7036: --- Summary: Type cast in ExpressionReducer's reduce broke CodeGen's compile stage Key: FLINK-7036 URL: https://issues.apache.org/jira/browse/FLINK-7036 Project: Flink

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2017-06-27 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065086#comment-16065086 ] Aegeaner commented on FLINK-6895: - I will try this. > Add STR_TO_DATE supported in SQL >

[jira] [Assigned] (FLINK-6895) Add STR_TO_DATE supported in SQL

2017-06-27 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-6895: --- Assignee: Aegeaner > Add STR_TO_DATE supported in SQL > > >

[jira] [Commented] (FLINK-6958) Async I/O timeout not work

2017-06-21 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057216#comment-16057216 ] Aegeaner commented on FLINK-6958: - Maybe you could set a CountDownLatch, and call countdown in case of

[jira] [Assigned] (FLINK-6579) Add proper support for BasicArrayTypeInfo

2017-05-15 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-6579: --- Assignee: (was: Aegeaner) > Add proper support for BasicArrayTypeInfo >

[jira] [Assigned] (FLINK-6579) Add proper support for BasicArrayTypeInfo

2017-05-15 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-6579: --- Assignee: Timo Walther > Add proper support for BasicArrayTypeInfo >

[jira] [Assigned] (FLINK-6579) Add proper support for BasicArrayTypeInfo

2017-05-15 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-6579: --- Assignee: Aegeaner (was: Timo Walther) > Add proper support for BasicArrayTypeInfo >