[
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 o
[
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 head
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155746723
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -721,6 +722,42 @@ abstract class
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155746766
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -721,6 +722,42 @@ abstract class
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155741290
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -721,6 +722,42 @@ abstract class
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155741244
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -411,6 +411,7 @@ abstract class
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155740555
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -98,7 +98,9 @@ abstract class
GitHub user Aegeaner opened a pull request:
https://github.com/apache/flink/pull/5116
[FLINK-8191] [Kafka Connector] Add a RoundRobinPartitioner to be shipped
with the Kafkaâ¦
Add a RoundRobinPartitioner to be shipped with the Kafka connector
*Thank you very much for
[
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 connec
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271988#comment-16271988
]
Aegeaner commented on FLINK-8173:
-
Assignment conversion not possible from
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268127#comment-16268127
]
Aegeaner commented on FLINK-8139:
-
know it, we can get the type class.
> Ch
Github user Aegeaner commented on the issue:
https://github.com/apache/flink/pull/5065
@twalthr But when registering a table/TableSource, we only got a
`TableSchema`, which is an array of `TypeInformation` ? How should I check the
instances of values?
---
Github user Aegeaner commented on the issue:
https://github.com/apache/flink/pull/5065
@fhueske I found `TypeInformation `class has abstract `equals()` and
`hashcode()` override methods defined, so any type info must implement these
methods. So is reflection check necessary?
---
Github user Aegeaner commented on the issue:
https://github.com/apache/flink/pull/5065
Hi @fhueske , thanks for review.
I will update` equals() `and `hashcode() `methods of Row, but I also
noticed that in `JoinOperator` and `KeySelector`, they used `RowComparator` to
compare row
GitHub user Aegeaner opened a pull request:
https://github.com/apache/flink/pull/5065
[FLINK-8139][table] Check for proper equals() and hashCode() when regâ¦
https://issues.apache.org/jira/browse/FLINK-8139
Check for proper equals() and hashCode() when registering a table
[
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 ta
[
https://issues.apache.org/jira/browse/FLINK-7036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069385#comment-16069385
]
Aegeaner commented on FLINK-7036:
-
Hi [~jark] I have just created a skeleton but you
[
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
[
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
[
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
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
Proj
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065086#comment-16065086
]
Aegeaner commented on FLINK-6895:
-
I will try this.
> Add STR_TO_DATE supported
[
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
[
https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16057216#comment-16057216
]
Aegeaner commented on FLINK-6958:
-
Maybe you could set a CountDownLatch, and
[
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 BasicArrayTypeI
[
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 BasicArrayTypeI
[
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 BasicArrayTypeI
27 matches
Mail list logo
