[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=15904650#comment-15904650 ] ASF GitHub Bot commented on FLINK-4565: --- Github user DmytroShkvyra closed the pull request at:

[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=15904651#comment-15904651 ] ASF GitHub Bot commented on FLINK-4565: --- GitHub user DmytroShkvyra reopened a pull request:

[jira] [Commented] (FLINK-6015) "Row too short" when reading CSV line with empty last field (i.e. ending in comma)

[ https://issues.apache.org/jira/browse/FLINK-6015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904615#comment-15904615 ] Luke Hutchison commented on FLINK-6015: --- Yes, this looks like the same bug. Thanks. > "Row too

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904580#comment-15904580 ] ASF GitHub Bot commented on FLINK-5658: --- Github user hongyuhong commented on a diff in the pull

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user hongyuhong commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105337481 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventtimeOverProcessFunction.scala --- @@ -0,0

[GitHub] flink pull request #3505: [backport-1.2] [FLINK-6006] [kafka] Always use com...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/3505 [backport-1.2] [FLINK-6006] [kafka] Always use complete restored state in FlinkKafkaConsumer (This PR is the fix of FLINK-6006 for Flink 1.2) Previously, the Kafka Consumer performs

[jira] [Commented] (FLINK-6015) "Row too short" when reading CSV line with empty last field (i.e. ending in comma)

[ https://issues.apache.org/jira/browse/FLINK-6015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904496#comment-15904496 ] Kurt Young commented on FLINK-6015: --- HI, i think this issue has been addressed by

[jira] [Updated] (FLINK-6018) Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method

[ https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6018: --- Description: The code snippet currently in the `AbstractKeyedStateBackend # getPartitionedState`

[jira] [Updated] (FLINK-6018) Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method

[ https://issues.apache.org/jira/browse/FLINK-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6018: --- Description: The code snippet currently in the `AbstractKeyedStateBackend # getPartitionedState`

[jira] [Created] (FLINK-6018) Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method

sunjincheng created FLINK-6018: -- Summary: Minor improvements about `AbstractKeyedStateBackend#getPartitionedState` method Key: FLINK-6018 URL: https://issues.apache.org/jira/browse/FLINK-6018 Project:

[jira] [Created] (FLINK-6017) CSV reader does not support quoted double quotes

Luke Hutchison created FLINK-6017: - Summary: CSV reader does not support quoted double quotes Key: FLINK-6017 URL: https://issues.apache.org/jira/browse/FLINK-6017 Project: Flink Issue Type:

[GitHub] flink pull request #3504: [FLINK-6010] Documentation: correct IntelliJ IDEA ...

GitHub user phoenixjiangnan opened a pull request: https://github.com/apache/flink/pull/3504 [FLINK-6010] Documentation: correct IntelliJ IDEA Plugins path in 'In… …stalling the Scala plugin' section You can merge this pull request into a Git repository by running: $ git

[jira] [Commented] (FLINK-6010) Documentation: correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section

[ https://issues.apache.org/jira/browse/FLINK-6010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904413#comment-15904413 ] ASF GitHub Bot commented on FLINK-6010: --- GitHub user phoenixjiangnan opened a pull request:

[jira] [Commented] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904396#comment-15904396 ] sunjincheng commented on FLINK-5995: HI, [~srichter] [~aljoscha] Thanks for your suggestions. I made a

[jira] [Commented] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904386#comment-15904386 ] ASF GitHub Bot commented on FLINK-5995: --- GitHub user sunjincheng121 opened a pull request:

[GitHub] flink pull request #3503: [FLINK-5995][checkpoints] fix Get a Exception when...

GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/3503 [FLINK-5995][checkpoints] fix Get a Exception when creating the ListS… …tateDescriptor with a TypeInformation Thanks for contributing to Apache Flink. Before you open your pull

[jira] [Created] (FLINK-6016) Newlines should be valid in quoted strings in CSV

Luke Hutchison created FLINK-6016: - Summary: Newlines should be valid in quoted strings in CSV Key: FLINK-6016 URL: https://issues.apache.org/jira/browse/FLINK-6016 Project: Flink Issue

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904367#comment-15904367 ] ASF GitHub Bot commented on FLINK-5658: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904363#comment-15904363 ] ASF GitHub Bot commented on FLINK-5658: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904368#comment-15904368 ] ASF GitHub Bot commented on FLINK-5658: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904365#comment-15904365 ] ASF GitHub Bot commented on FLINK-5658: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904366#comment-15904366 ] ASF GitHub Bot commented on FLINK-5658: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904371#comment-15904371 ] ASF GitHub Bot commented on FLINK-5658: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904369#comment-15904369 ] ASF GitHub Bot commented on FLINK-5658: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904370#comment-15904370 ] ASF GitHub Bot commented on FLINK-5658: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904364#comment-15904364 ] ASF GitHub Bot commented on FLINK-5658: --- Github user sunjincheng121 commented on a diff in the pull

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105323567 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventtimeOverProcessFunction.scala --- @@

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105324505 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventtimeOverProcessFunction.scala --- @@

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105322751 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/UnboundedRowtimeOverTest.scala --- @@ -0,0 +1,133

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105322914 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/UnboundedRowtimeOverTest.scala --- @@ -0,0 +1,133

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105322654 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/UnboundedRowtimeOverTest.scala --- @@ -0,0 +1,133

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105322866 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/UnboundedRowtimeOverTest.scala --- @@ -0,0 +1,133

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105325003 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventtimeOverProcessFunction.scala --- @@

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105323083 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/UnboundedRowtimeOverTest.scala --- @@ -0,0 +1,133

[GitHub] flink pull request #3386: [FLINK-5658][table] support unbounded eventtime ov...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3386#discussion_r105323410 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -80,6 +81,38 @@ object

[jira] [Created] (FLINK-6015) "Row too short" when reading CSV line with empty last field (i.e. ending in comma)

Luke Hutchison created FLINK-6015: - Summary: "Row too short" when reading CSV line with empty last field (i.e. ending in comma) Key: FLINK-6015 URL: https://issues.apache.org/jira/browse/FLINK-6015

[jira] [Commented] (FLINK-5861) TaskManager's components support updating JobManagerConnection

[ https://issues.apache.org/jira/browse/FLINK-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904310#comment-15904310 ] ASF GitHub Bot commented on FLINK-5861: --- Github user ifndef-SleePy commented on the issue:

[jira] [Commented] (FLINK-5861) TaskManager's components support updating JobManagerConnection

[ https://issues.apache.org/jira/browse/FLINK-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904311#comment-15904311 ] ASF GitHub Bot commented on FLINK-5861: --- Github user ifndef-SleePy closed the pull request at:

[GitHub] flink issue #3395: [FLINK-5861] Components of TaskManager support updating J...

Github user ifndef-SleePy commented on the issue: https://github.com/apache/flink/pull/3395 Hi Till, I almost miss this comments! I didn't see it until a few minutes ago. I fully understand your concern. Just let me explain more about your comments. 1. I agree most of

[GitHub] flink pull request #3395: [FLINK-5861] Components of TaskManager support upd...

Github user ifndef-SleePy closed the pull request at: https://github.com/apache/flink/pull/3395 --- 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] [Assigned] (FLINK-3849) Add FilterableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-3849: - Assignee: Kurt Young > Add FilterableTableSource interface and translation rule >

[GitHub] flink issue #3485: FLINK-5976 [tests] Deduplicate Tokenizer in tests

Github user liuyuzhong7 commented on the issue: https://github.com/apache/flink/pull/3485 @StephanEwen FlatMapFunction "Tokenizer" has move to org.apache.flink.test.testfunctions. Help me to review this. Thanks. And collect other reusable functions to

[jira] [Commented] (FLINK-5976) Refactoring duplicate Tokenizer in flink-test

[ https://issues.apache.org/jira/browse/FLINK-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904280#comment-15904280 ] ASF GitHub Bot commented on FLINK-5976: --- Github user liuyuzhong7 commented on the issue:

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904271#comment-15904271 ] Kurt Young commented on FLINK-5859: --- Hi [~fhueske], i can continue working on {{FilterableTableSource}}.

[jira] [Created] (FLINK-6014) Allow the registration of state objects in checkpoints

Xiaogang Shi created FLINK-6014: --- Summary: Allow the registration of state objects in checkpoints Key: FLINK-6014 URL: https://issues.apache.org/jira/browse/FLINK-6014 Project: Flink Issue

[jira] [Commented] (FLINK-5976) Refactoring duplicate Tokenizer in flink-test

[ https://issues.apache.org/jira/browse/FLINK-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904258#comment-15904258 ] ASF GitHub Bot commented on FLINK-5976: --- Github user liuyuzhong7 commented on the issue:

[GitHub] flink issue #3485: FLINK-5976 [tests] Deduplicate Tokenizer in tests

Github user liuyuzhong7 commented on the issue: https://github.com/apache/flink/pull/3485 OK, get it. So how about just do it now in flink-tests like this pull request? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink issue #3406: [flink-5568] [Table API & SQL]Introduce interface for cat...

Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3406 Hi @fhueske , i like your propose about moving the annotation from `TableSource` to `TableSourceConverter`. Lets do it this way. BTW, i noticed that you offered three possible methods to the

[GitHub] flink pull request #3406: [flink-5568] [Table API & SQL]Introduce interface ...

Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/3406#discussion_r105316858 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/table/annotation/ExternalCatalogCompatible.java --- @@ -0,0 +1,63 @@ +/* +

[jira] [Created] (FLINK-6013) Add Datadog HTTP metrics reporter

Bowen Li created FLINK-6013: --- Summary: Add Datadog HTTP metrics reporter Key: FLINK-6013 URL: https://issues.apache.org/jira/browse/FLINK-6013 Project: Flink Issue Type: Improvement

[GitHub] flink issue #3461: [FLINK-5954] Always assign names to the window in the Str...

Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3461 Hi, @haohui Thanks for your explanation, and I'll see the detail in the FLINK-5954. Thanks, SunJincheng --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-5954) Always assign names to the window in the Stream SQL API

[ https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904189#comment-15904189 ] ASF GitHub Bot commented on FLINK-5954: --- Github user sunjincheng121 commented on the issue:

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904089#comment-15904089 ] ASF GitHub Bot commented on FLINK-3257: --- Github user addisonj commented on the issue:

[GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I...

Github user addisonj commented on the issue: https://github.com/apache/flink/pull/1668 Very interested in this work. It sounds like there are few loose ends and then some cleanup before it might be ready for merge, @senorcarbone or @StephanEwen anything that can be supported by

[GitHub] flink pull request #3461: [FLINK-5954] Always assign names to the window in ...

GitHub user haohui reopened a pull request: https://github.com/apache/flink/pull/3461 [FLINK-5954] Always assign names to the window in the Stream SQL API. Please see jira for more details. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-5954) Always assign names to the window in the Stream SQL API

[ https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904050#comment-15904050 ] ASF GitHub Bot commented on FLINK-5954: --- GitHub user haohui reopened a pull request:

[jira] [Commented] (FLINK-5954) Always assign names to the window in the Stream SQL API

[ https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904048#comment-15904048 ] ASF GitHub Bot commented on FLINK-5954: --- Github user haohui commented on the issue:

[GitHub] flink issue #3461: [FLINK-5954] Always assign names to the window in the Str...

Github user haohui commented on the issue: https://github.com/apache/flink/pull/3461 Sorry for the late response. This is a prerequisite step for FLINK-6012 -- translating the group auxiliary functions (e.g., `TUMBLE_START`) to the corresponding Flink expressions (e.g.,

[jira] [Commented] (FLINK-5954) Always assign names to the window in the Stream SQL API

[ https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904042#comment-15904042 ] ASF GitHub Bot commented on FLINK-5954: --- Github user haohui closed the pull request at:

[GitHub] flink pull request #3461: [FLINK-5954] Always assign names to the window in ...

Github user haohui closed the pull request at: https://github.com/apache/flink/pull/3461 --- 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] [Created] (FLINK-6012) Support WindowStart / WindowEnd functions in stream SQL

Haohui Mai created FLINK-6012: - Summary: Support WindowStart / WindowEnd functions in stream SQL Key: FLINK-6012 URL: https://issues.apache.org/jira/browse/FLINK-6012 Project: Flink Issue Type:

[jira] [Created] (FLINK-6011) Support TUMBLE, HOP, SESSION window in streaming SQL

Haohui Mai created FLINK-6011: - Summary: Support TUMBLE, HOP, SESSION window in streaming SQL Key: FLINK-6011 URL: https://issues.apache.org/jira/browse/FLINK-6011 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-5829) Bump Calcite version to 1.12 once available

[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-5829: - Assignee: Haohui Mai > Bump Calcite version to 1.12 once available >

[jira] [Created] (FLINK-6010) Documentation: correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section

Bowen Li created FLINK-6010: --- Summary: Documentation: correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section Key: FLINK-6010 URL: https://issues.apache.org/jira/browse/FLINK-6010

[jira] [Created] (FLINK-6009) Deprecate DataSetUtils#checksumHashCode

Greg Hogan created FLINK-6009: - Summary: Deprecate DataSetUtils#checksumHashCode Key: FLINK-6009 URL: https://issues.apache.org/jira/browse/FLINK-6009 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #3502: [FLINK-4565] Support for SQL IN operator

GitHub user DmytroShkvyra opened a pull request: https://github.com/apache/flink/pull/3502 [FLINK-4565] Support for SQL IN operator [FLINK-4565] Support for SQL IN operator This PR is a part of work on SQL IN operator in Table API, which implements IN for literals. Two

[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=15903759#comment-15903759 ] ASF GitHub Bot commented on FLINK-4565: --- GitHub user DmytroShkvyra opened a pull request:

[GitHub] flink pull request #2870: [FLINK-4565] Support for SQL IN operator

Github user DmytroShkvyra commented on a diff in the pull request: https://github.com/apache/flink/pull/2870#discussion_r105244663 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala --- @@ -1101,6 +1101,45 @@

[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=15903654#comment-15903654 ] ASF GitHub Bot commented on FLINK-4565: --- Github user DmytroShkvyra commented on a diff in the pull

[GitHub] flink issue #3501: [FLINK-5874] Restrict key types in the DataStream API.

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3501 This should work and is well tested, good job. Had a bunch of minor comments, but nothing critical. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903645#comment-15903645 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903632#comment-15903632 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903631#comment-15903631 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903635#comment-15903635 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903628#comment-15903628 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903633#comment-15903633 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903629#comment-15903629 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903624#comment-15903624 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903637#comment-15903637 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903638#comment-15903638 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903634#comment-15903634 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903630#comment-15903630 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903626#comment-15903626 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903636#comment-15903636 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903639#comment-15903639 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903625#comment-15903625 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903627#comment-15903627 ] ASF GitHub Bot commented on FLINK-5874: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105241358 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java --- @@ -906,6 +919,256 @@ public void testChannelSelectors()

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105239687 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -114,9 +121,53 @@ public

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105241262 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java --- @@ -906,6 +919,256 @@ public void testChannelSelectors()

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105238457 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java --- @@ -906,6 +919,256 @@ public void testChannelSelectors()

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105241450 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java --- @@ -906,6 +919,256 @@ public void testChannelSelectors()

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105239060 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java --- @@ -906,6 +919,256 @@ public void testChannelSelectors()

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105239799 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -114,9 +121,53 @@ public

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105240820 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -114,9 +121,53 @@ public

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105242176 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java --- @@ -906,6 +919,256 @@ public void testChannelSelectors()

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105240936 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java --- @@ -906,6 +919,256 @@ public void testChannelSelectors()

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105240608 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java --- @@ -114,9 +121,53 @@ public

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105241562 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java --- @@ -906,6 +919,256 @@ public void testChannelSelectors()

[GitHub] flink pull request #3501: [FLINK-5874] Restrict key types in the DataStream ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3501#discussion_r105238197 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java --- @@ -906,6 +919,256 @@ public void testChannelSelectors()

  1   2   3   >