[jira] [Updated] (FLINK-6462) Add requiresOver interface for AggregateFunction

[ https://issues.apache.org/jira/browse/FLINK-6462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6462: - Fix Version/s: 1.3.0 > Add requiresOver interface for AggregateFunction > ---

[jira] [Commented] (FLINK-6542) Non-keyed, non-windowed aggregation fails

[ https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007811#comment-16007811 ] Fabian Hueske commented on FLINK-6542: -- Thanks for looking into this [~xccui]! I thin

[jira] [Resolved] (FLINK-6542) Non-keyed, non-windowed aggregation fails

[ https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-6542. -- Resolution: Not A Problem > Non-keyed, non-windowed aggregation fails >

[jira] [Assigned] (FLINK-1750) Add canonical correlation analysis (CCA) to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1750: Assignee: Alex De Castro > Add canonical correlation analysis (CCA) to machine learning lib

[jira] [Commented] (FLINK-6563) Expose time indicator attributes in the KafkaTableSource

[ https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007997#comment-16007997 ] Fabian Hueske commented on FLINK-6563: -- Actually, the missing {{DefinedProctimeAttrib

[jira] [Assigned] (FLINK-6564) Build fails on file systems that do not distinguish between upper and lower case

[ https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6564: Assignee: Fabian Hueske > Build fails on file systems that do not distinguish between upper

[jira] [Commented] (FLINK-6564) Build fails on file systems that do not distinguish between upper and lower case

[ https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008027#comment-16008027 ] Fabian Hueske commented on FLINK-6564: -- Will rename the `license` folder to `licenses

[jira] [Closed] (FLINK-6564) Build fails on file systems that do not distinguish between upper and lower case

[ https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6564. Resolution: Fixed Fixed on 1.3 with fddc8b10e2ed4d9bb920073e4fe86603ce09beed Fixed on 1.4 with c9ffa

[jira] [Updated] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6569: - Fix Version/s: 1.3.0 > flink-table KafkaJsonTableSource example doesn't work > ---

[jira] [Updated] (FLINK-6568) flink-table doesn't work without flink-streaming-scala dependency

[ https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6568: - Fix Version/s: 1.3.0 > flink-table doesn't work without flink-streaming-scala dependency > ---

[jira] [Created] (FLINK-4676) Merge flink-batch-con

Fabian Hueske created FLINK-4676: Summary: Merge flink-batch-con Key: FLINK-4676 URL: https://issues.apache.org/jira/browse/FLINK-4676 Project: Flink Issue Type: Task Reporter: Fa

[jira] [Updated] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules

[ https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4676: - Affects Version/s: 1.2.0 > Merge flink-batch-connectors and flink-streaming-connectors modules > -

[jira] [Updated] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules

[ https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4676: - Summary: Merge flink-batch-connectors and flink-streaming-connectors modules (was: Merge flink-ba

[jira] [Updated] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules

[ https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4676: - Component/s: Build System > Merge flink-batch-connectors and flink-streaming-connectors modules >

[jira] [Updated] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules

[ https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4676: - Priority: Minor (was: Major) > Merge flink-batch-connectors and flink-streaming-connectors module

[jira] [Updated] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules

[ https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4676: - Fix Version/s: 1.2.0 > Merge flink-batch-connectors and flink-streaming-connectors modules > -

[jira] [Updated] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules

[ https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4676: - Description: We have two separate Maven modules for batch and streaming connectors (flink-batch-c

[jira] [Created] (FLINK-4678) Add SessionRow row-windows for streaming tables (FLIP-11)

Fabian Hueske created FLINK-4678: Summary: Add SessionRow row-windows for streaming tables (FLIP-11) Key: FLINK-4678 URL: https://issues.apache.org/jira/browse/FLINK-4678 Project: Flink Issue

[jira] [Updated] (FLINK-4678) Add SessionRow row-windows for streaming tables (FLIP-11)

[ https://issues.apache.org/jira/browse/FLINK-4678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4678: - Description: Add SessionRow row-windows for streaming tables as described in [FLIP-11|https://cwi

[jira] [Created] (FLINK-4679) Add TumbleRow row-windows for streaming tables

Fabian Hueske created FLINK-4679: Summary: Add TumbleRow row-windows for streaming tables Key: FLINK-4679 URL: https://issues.apache.org/jira/browse/FLINK-4679 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-4680) Add SlidingRow row-windows for streaming tables

Fabian Hueske created FLINK-4680: Summary: Add SlidingRow row-windows for streaming tables Key: FLINK-4680 URL: https://issues.apache.org/jira/browse/FLINK-4680 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-4681) Add SessionRow row-windows for batch tables.

Fabian Hueske created FLINK-4681: Summary: Add SessionRow row-windows for batch tables. Key: FLINK-4681 URL: https://issues.apache.org/jira/browse/FLINK-4681 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-4682) Add TumbleRow row-windows for batch tables.

Fabian Hueske created FLINK-4682: Summary: Add TumbleRow row-windows for batch tables. Key: FLINK-4682 URL: https://issues.apache.org/jira/browse/FLINK-4682 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-4683) Add SlideRow row-windows for batch tables

Fabian Hueske created FLINK-4683: Summary: Add SlideRow row-windows for batch tables Key: FLINK-4683 URL: https://issues.apache.org/jira/browse/FLINK-4683 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans

Fabian Hueske created FLINK-4688: Summary: Optimizer hangs for hours when optimizing complex plans Key: FLINK-4688 URL: https://issues.apache.org/jira/browse/FLINK-4688 Project: Flink Issue T

[jira] [Updated] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans

[ https://issues.apache.org/jira/browse/FLINK-4688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4688: - Attachment: stacktrace_32minsAfterSubmission.java Stacktrace 32 mins after submission > Optimize

[jira] [Updated] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans

[ https://issues.apache.org/jira/browse/FLINK-4688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4688: - Attachment: stacktrace_shortlyAfterSubmission.java Stacktrace shortly after submission > Optimize

[jira] [Updated] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans

[ https://issues.apache.org/jira/browse/FLINK-4688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4688: - Attachment: stacktrace_76minsAfterSubmission.java Stacktrace 76 mins after submission > Optimizer

[jira] [Commented] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525712#comment-15525712 ] Fabian Hueske commented on FLINK-2765: -- At the moment, we have two open PRs that use

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

[ https://issues.apache.org/jira/browse/FLINK-4699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527013#comment-15527013 ] Fabian Hueske commented on FLINK-4699: -- There is a pull request to convert the KafkaJ

[jira] [Updated] (FLINK-4636) AbstractCEPPatternOperator fails to restore state

[ https://issues.apache.org/jira/browse/FLINK-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4636: - Assignee: Jagadish Bihani > AbstractCEPPatternOperator fails to restore state > --

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545404#comment-15545404 ] Fabian Hueske commented on FLINK-4311: -- Merged for Flink 1.1 as 98b399d4b4ddc9ab5d01e

[jira] [Updated] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4311: - Fix Version/s: 1.1.3 > TableInputFormat fails when reused on next split >

[jira] [Updated] (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:all-tabpanel ] Fabian Hueske updated FLINK-4743: - Assignee: Anton Solovev > The sqrt/power function not accept the real data types. > --

[jira] [Updated] (FLINK-4785) Flink string parser doesn't handle string fields containing double quotes

[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4785: - Issue Type: Improvement (was: Bug) > Flink string parser doesn't handle string fields containing

[jira] [Commented] (FLINK-4781) Add User Defined Function(UDF) API for Table API

[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15562063#comment-15562063 ] Fabian Hueske commented on FLINK-4781: -- [~sunjincheng121] Can you check if the featur

[jira] [Closed] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

[ https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4778. Resolution: Fixed Fix Version/s: 1.2.0 1.1.4 Fixed for 1.1.x with 2203f743

[jira] [Closed] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4311. Resolution: Fixed Fix Version/s: 1.2.0 Fixed for 1.2.0 with 3f8727921e944d1d89714f5885c2de636

[jira] [Closed] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2765. Resolution: Fixed Assignee: Fabian Hueske Fix Version/s: 1.2.0 Fixed for 1.2.0 with

[jira] [Updated] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4283: - Assignee: Alexander Shoshin > ExecutionGraphRestartTest fails > --- >

[jira] [Updated] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1890: - Labels: starter (was: ) > Add note to docs that ReadFields annotations are currently not evaluate

[jira] [Commented] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572810#comment-15572810 ] Fabian Hueske commented on FLINK-1890: -- I'd keep the issue open. I'll add the starter

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15575192#comment-15575192 ] Fabian Hueske commented on FLINK-4315: -- Hi [~kenmy], while discussing to drop Hadoo

[jira] [Updated] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4315: - Issue Type: Task (was: Sub-task) Parent: (was: FLINK-3957) > Remove Hadoop Dependency

[jira] [Updated] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4315: - Summary: Deprecate Hadoop dependent methods in flink-java (was: Remove Hadoop Dependency from fli

[jira] [Updated] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4315: - Description: The API projects should be independent of Hadoop, because Hadoop is not an integral

[jira] [Commented] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15575288#comment-15575288 ] Fabian Hueske commented on FLINK-4315: -- Thanks, [~kenmy]! I move this method from th

[jira] [Commented] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15575290#comment-15575290 ] Fabian Hueske commented on FLINK-4048: -- I updated FLINK-4315 to deprecate the methods

[jira] [Updated] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4785: - Summary: Flink string parser doesn't handle string fields containing two consecutive double quotes

[jira] [Commented] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15575710#comment-15575710 ] Fabian Hueske commented on FLINK-4785: -- The {{StringParser}} can parse enclosed by a

[jira] [Reopened] (FLINK-4593) Fix PageRank algorithm example

[ https://issues.apache.org/jira/browse/FLINK-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-4593: -- Assignee: Alexander Pivovarov (was: Greg Hogan) > Fix PageRank algorithm example > --

[jira] [Closed] (FLINK-4593) Fix PageRank algorithm example

[ https://issues.apache.org/jira/browse/FLINK-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4593. Resolution: Fixed > Fix PageRank algorithm example > -- > >

[jira] [Commented] (FLINK-4593) Fix PageRank algorithm example

[ https://issues.apache.org/jira/browse/FLINK-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15576226#comment-15576226 ] Fabian Hueske commented on FLINK-4593: -- [~apivovarov] I assigned the issue to you and

[jira] [Closed] (FLINK-4771) Compression for AvroOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4771. Resolution: Fixed Assignee: Lars Bachmann Fix Version/s: 1.2.0 Implemented for 1.2.0

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

[ https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-4108. -- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 Fixed for 1.1.4 with 9f72

[jira] [Resolved] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true

[ https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-4506. -- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 Fixed for 1.1.4 with 9591

[jira] [Created] (FLINK-4864) Shade Calcite dependency in flink-table

Fabian Hueske created FLINK-4864: Summary: Shade Calcite dependency in flink-table Key: FLINK-4864 URL: https://issues.apache.org/jira/browse/FLINK-4864 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-4874) Enabling Flink web interface in local execution

[ https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4874: - Flags: (was: Important) > Enabling Flink web interface in local execution >

[jira] [Commented] (FLINK-4874) Enabling Flink web interface in local execution

[ https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594393#comment-15594393 ] Fabian Hueske commented on FLINK-4874: -- That's a good suggestion. The [Local Executi

[jira] [Updated] (FLINK-4874) Enabling Flink web interface in local execution

[ https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4874: - Component/s: (was: Webfrontend) Documentation > Enabling Flink web interface

[jira] [Updated] (FLINK-4874) Document how to enable Flink web interface in local execution

[ https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4874: - Summary: Document how to enable Flink web interface in local execution (was: Enabling Flink web i

[jira] [Updated] (FLINK-4874) Enabling Flink web interface in local execution

[ https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4874: - Affects Version/s: 1.2.0 > Enabling Flink web interface in local execution > -

[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&focusedCommentId=15595029#comment-15595029 ] Fabian Hueske commented on FLINK-4743: -- Hi [~tonycox], Thanks for looking into this

[jira] [Closed] (FLINK-2118) Table API fails on composite filter conditions

[ https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2118. Resolution: Not A Bug Hi Alexander, I agree and will close the issue. Thanks for looking into this!

[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&focusedCommentId=15595581#comment-15595581 ] Fabian Hueske commented on FLINK-4604: -- Hi [~anmu], I think we can implement and add

[jira] [Closed] (FLINK-4581) Table API throws "No suitable driver found for jdbc:calcite"

[ https://issues.apache.org/jira/browse/FLINK-4581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4581. Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 Fixed for 1.1.4 with 5731672e

[jira] [Closed] (FLINK-4838) remove STREAM keyword in StreamSQLExample

[ https://issues.apache.org/jira/browse/FLINK-4838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4838. Resolution: Fixed Assignee: Manu Zhang Fix Version/s: 1.2.0 Fixed for 1.2.0 with 227

[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&focusedCommentId=15602184#comment-15602184 ] Fabian Hueske commented on FLINK-4832: -- [~jark] is right. A zero count is only necess

[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&focusedCommentId=15602830#comment-15602830 ] Fabian Hueske commented on FLINK-4469: -- Thanks for the comments [~ShaoxuanWang] and [

[jira] [Reopened] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-2662: -- Reopened due to the bug reported by [~ymarzougui]. > CompilerException: "Bug: Plan generation for U

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

[ https://issues.apache.org/jira/browse/FLINK-4639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4639. Resolution: Fixed Fix Version/s: 1.2.0 Fixed for 1.2.0 with dc0b3430f8d243b1876125e4949e733ae

[jira] [Closed] (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 ] Fabian Hueske closed FLINK-4762. Resolution: Implemented Fix Version/s: 1.2.0 Implemented for 1.2.0 with 11fa089d6ae8ef8f8a884

[jira] [Closed] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3035. Resolution: Won't Fix Closed because Redis is not a good fit to serve as a state backend for Flink

[jira] [Commented] (FLINK-4917) Deprecate "CheckpointedAsynchronously" interface

[ https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609660#comment-15609660 ] Fabian Hueske commented on FLINK-4917: -- When deprecating interfaces it is good practi

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

[ https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4691. Resolution: Implemented Fix Version/s: 1.2.0 Implemented for 1.2.0 with 44f3977e7fee44a3601b6

[jira] [Created] (FLINK-4937) Add incremental group window aggregation for streaming Table API

Fabian Hueske created FLINK-4937: Summary: Add incremental group window aggregation for streaming Table API Key: FLINK-4937 URL: https://issues.apache.org/jira/browse/FLINK-4937 Project: Flink

[jira] [Updated] (FLINK-4937) Add incremental group window aggregation for streaming Table API

[ https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4937: - Description: Group-window aggregates for streaming tables are currently not done in an incrementa

[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&focusedCommentId=15615695#comment-15615695 ] Fabian Hueske commented on FLINK-4469: -- Thanks [~jark], this is great news! How do w

[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&focusedCommentId=15615730#comment-15615730 ] Fabian Hueske commented on FLINK-4604: -- Hi [~anmu], thanks for digging into this. Re

[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&focusedCommentId=15626549#comment-15626549 ] Fabian Hueske commented on FLINK-4832: -- Currently, a {{DataSetAggregate}} is translat

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15629062#comment-15629062 ] Fabian Hueske commented on FLINK-3869: -- I like that idea, [~aljoscha]. +1 from me to

[jira] [Closed] (FLINK-4996) Make CrossHint @Public

[ https://issues.apache.org/jira/browse/FLINK-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4996. Resolution: Fixed Fix Version/s: 1.1.4 Fixed for 1.2.0 with 6346a89972416489bc43ee30946078341

[jira] [Closed] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN

[ https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4943. Resolution: Fixed Assignee: Mischa Krüger Fix Version/s: 1.2.0 Fixed for 1.2.0 with

[jira] [Closed] (FLINK-4623) Create Physical Execution Plan of a DataStream

[ https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4623. Resolution: Fixed Fix Version/s: 1.2.0 Fixed for 1.2.0 with d60fe723aa357733c6ad8715b0e8c4e55

[jira] [Closed] (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:all-tabpanel ] Fabian Hueske closed FLINK-4743. Resolution: Fixed Fix Version/s: 1.2.0 Fixed for 1.2.0 with 4565170088595838ec53f3ca9b898126c

[jira] [Resolved] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-4315. -- Resolution: Done Fix Version/s: (was: 2.0.0) 1.2.0 Done for 1.2.0

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635776#comment-15635776 ] Fabian Hueske commented on FLINK-3617: -- I agree, {{Option}}'s purpose is to avoid {{n

[jira] [Commented] (FLINK-5025) Job fails because of Optimizer bug

[ https://issues.apache.org/jira/browse/FLINK-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643784#comment-15643784 ] Fabian Hueske commented on FLINK-5025: -- Thanks for reporting the bug [~nielsbasjes].

[jira] [Commented] (FLINK-5025) Job fails because of Optimizer bug

[ https://issues.apache.org/jira/browse/FLINK-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643788#comment-15643788 ] Fabian Hueske commented on FLINK-5025: -- OK, [~Zentol] did that already. :-) > Job fa

[jira] [Created] (FLINK-5031) Consecutive DataStream.split() ignored

Fabian Hueske created FLINK-5031: Summary: Consecutive DataStream.split() ignored Key: FLINK-5031 URL: https://issues.apache.org/jira/browse/FLINK-5031 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

[ https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15647147#comment-15647147 ] Fabian Hueske commented on FLINK-5013: -- This might also be cause by using the wrong M

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15862996#comment-15862996 ] Fabian Hueske commented on FLINK-2184: -- Hi [~johnmu], Seems like the PR is stale an

[jira] [Commented] (FLINK-5564) User Defined Aggregates

[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15862999#comment-15862999 ] Fabian Hueske commented on FLINK-5564: -- Hi [~shaoxuan], My proposal is to add the fol

[jira] [Commented] (FLINK-5752) Support push down projections for HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863007#comment-15863007 ] Fabian Hueske commented on FLINK-5752: -- Hi [~ram_krish], I think the result of our

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863015#comment-15863015 ] Fabian Hueske commented on FLINK-5654: -- Eventually, we will go for code generation. H

[jira] [Assigned] (FLINK-5771) DelimitedInputFormat does not correctly handle multi-byte delimiters

[ https://issues.apache.org/jira/browse/FLINK-5771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-5771: Assignee: Fabian Hueske > DelimitedInputFormat does not correctly handle multi-byte delimit

[jira] [Commented] (FLINK-5771) DelimitedInputFormat does not correctly handle multi-byte delimiters

[ https://issues.apache.org/jira/browse/FLINK-5771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863507#comment-15863507 ] Fabian Hueske commented on FLINK-5771: -- Thanks for reporting this issue [~colinbreame

[jira] [Commented] (FLINK-5752) Support push down projections for HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863608#comment-15863608 ] Fabian Hueske commented on FLINK-5752: -- I see. Thanks for the explanation. Could you

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

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863624#comment-15863624 ] Fabian Hueske commented on FLINK-5657: -- Hi [~sunjincheng121], thanks for sketching th

[jira] [Commented] (FLINK-5737) Fix the bug when TableSource contains a field of byte[] type

[ https://issues.apache.org/jira/browse/FLINK-5737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863664#comment-15863664 ] Fabian Hueske commented on FLINK-5737: -- Hi [~jinyu.zj], can you check on which versio

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