[jira] [Updated] (FLINK-8511) Remove legacy code for the TableType annotation

[ https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8511: - Priority: Critical (was: Major) > Remove legacy code for the TableType annotation > -

[jira] [Updated] (FLINK-8511) Remove legacy code for the TableType annotation

[ https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8511: - Affects Version/s: 1.6.0 > Remove legacy code for the TableType annotation > -

[jira] [Commented] (FLINK-9234) Commons Logging is missing from shaded Flink Table library

[ https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16473438#comment-16473438 ] Fabian Hueske commented on FLINK-9234: -- I tried to reproduce this issue for 1.5 but i

[jira] [Closed] (FLINK-9332) Fix Codegen error of CallGenerator

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

[jira] [Closed] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

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

[jira] [Assigned] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9138: Assignee: Lakshmi Rao > Enhance BucketingSink to also flush data by time interval > ---

[jira] [Commented] (FLINK-9341) Oracle: "Type is not supported: Date"

[ https://issues.apache.org/jira/browse/FLINK-9341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16472751#comment-16472751 ] Fabian Hueske commented on FLINK-9341: -- Hi, could you please include the full stacktr

[jira] [Commented] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source

[ https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16471749#comment-16471749 ] Fabian Hueske commented on FLINK-9329: -- I checked the code and could not reproduce th

[jira] [Commented] (FLINK-9289) Parallelism of generated operators should have max parallism of input

[ https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16471648#comment-16471648 ] Fabian Hueske commented on FLINK-9289: -- Hi [~xccui], the fix should go into {{KeyFunc

[jira] [Closed] (FLINK-8237) BucketingSink throws NPE when Writer.duplicate returns null

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

[jira] [Assigned] (FLINK-8237) BucketingSink throws NPE when Writer.duplicate returns null

[ https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8237: Assignee: Pavel Shvetsov > BucketingSink throws NPE when Writer.duplicate returns null > --

[jira] [Closed] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

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

[jira] [Created] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

Fabian Hueske created FLINK-9309: Summary: Recommend HA setup on Production Readiness Checklist Key: FLINK-9309 URL: https://issues.apache.org/jira/browse/FLINK-9309 Project: Flink Issue Type

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16465763#comment-16465763 ] Fabian Hueske commented on FLINK-2435: -- Hi [~dmitry_kober], thanks for the update! I

[jira] [Created] (FLINK-9296) Support distinct aggregation on non-windowed grouped streaming tables

Fabian Hueske created FLINK-9296: Summary: Support distinct aggregation on non-windowed grouped streaming tables Key: FLINK-9296 URL: https://issues.apache.org/jira/browse/FLINK-9296 Project: Flink

[jira] [Updated] (FLINK-9232) Add harness test for AggregationCodeGenerator

[ https://issues.apache.org/jira/browse/FLINK-9232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9232: - Component/s: Table API & SQL > Add harness test for AggregationCodeGenerator > --

[jira] [Updated] (FLINK-8691) Update table API to support distinct operator on data stream

[ https://issues.apache.org/jira/browse/FLINK-8691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8691: - Component/s: Table API & SQL > Update table API to support distinct operator on data stream >

[jira] [Updated] (FLINK-8739) Optimize runtime support for distinct filter

[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8739: - Component/s: Table API & SQL > Optimize runtime support for distinct filter >

[jira] [Closed] (FLINK-6335) Parse DISTINCT over grouped window in stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6335. Resolution: Duplicate Duplicate of FLINK-8690 > Parse DISTINCT over grouped window in stream SQL >

[jira] [Updated] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8690: - Summary: Support distinct aggregation on group windowed streaming tables. (was: Update logical ru

[jira] [Updated] (FLINK-8690) Support distinct aggregation on group windowed streaming tables.

[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8690: - Component/s: Table API & SQL > Support distinct aggregation on group windowed streaming tables. >

[jira] [Closed] (FLINK-6373) Add runtime support for distinct aggregation over grouped windows

[ https://issues.apache.org/jira/browse/FLINK-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6373. Resolution: Duplicate Was implemented as FLINK-8689. > Add runtime support for distinct aggregation

[jira] [Closed] (FLINK-6990) Poor performance with Sliding Time Windows

[ https://issues.apache.org/jira/browse/FLINK-6990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6990. Resolution: Duplicate Closing as a duplicate of FLINK-7001. > Poor performance with Sliding Time Wi

[jira] [Closed] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6719. Resolution: Fixed Fix Version/s: (was: 1.5.1) (was: 1.6.0)

[jira] [Commented] (FLINK-9273) Class cast exception

[ https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461060#comment-16461060 ] Fabian Hueske commented on FLINK-9273: -- Hi [~bob365], Flink cannot automatically ext

[jira] [Updated] (FLINK-9289) Parallelism of generated operators should have max parallism of input

[ https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9289: - Description: The DataSet API aims to chain generated operators such as key extraction mappers to

[jira] [Created] (FLINK-9289) Parallelism of generated operators should have max parallism of input

Fabian Hueske created FLINK-9289: Summary: Parallelism of generated operators should have max parallism of input Key: FLINK-9289 URL: https://issues.apache.org/jira/browse/FLINK-9289 Project: Flink

[jira] [Comment Edited] (FLINK-9278) Allow restore savepoint with some SQL queries added/removed

[ https://issues.apache.org/jira/browse/FLINK-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460972#comment-16460972 ] Fabian Hueske edited comment on FLINK-9278 at 5/2/18 12:49 PM: -

[jira] [Commented] (FLINK-9278) Allow restore savepoint with some SQL queries added/removed

[ https://issues.apache.org/jira/browse/FLINK-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460972#comment-16460972 ] Fabian Hueske commented on FLINK-9278: -- Hi [~ahains], This sounds like a very valuab

[jira] [Commented] (FLINK-8255) Key expressions on named row types do not work

[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460831#comment-16460831 ] Fabian Hueske commented on FLINK-8255: -- Thanks for digging into this issue [~Sergey N

[jira] [Assigned] (FLINK-8255) Key expressions on named row types do not work

[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8255: Assignee: Sergey Nuyanzin > Key expressions on named row types do not work > --

[jira] [Assigned] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9178: Assignee: Tarush Grover > Add rate control for kafka source > -

[jira] [Commented] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16456568#comment-16456568 ] Fabian Hueske commented on FLINK-9178: -- I'd suggest to first collect some feedback fr

[jira] [Closed] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6249. Resolution: Duplicate Fix Version/s: 1.6.0 Implemented via FLINK-8689 > Distinct Aggregates

[jira] [Closed] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

[ https://issues.apache.org/jira/browse/FLINK-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6388. Resolution: Duplicate Fix Version/s: 1.6.0 Implemented via FLINK-8689 > Add support for DIST

[jira] [Closed] (FLINK-8689) Add runtime support of distinct filter using MapView

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

[jira] [Comment Edited] (FLINK-9159) Sanity check default timeout values

[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16454535#comment-16454535 ] Fabian Hueske edited comment on FLINK-9159 at 4/26/18 4:56 PM: -

[jira] [Commented] (FLINK-9159) Sanity check default timeout values

[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16454535#comment-16454535 ] Fabian Hueske commented on FLINK-9159: -- By default Tez kills idle containers with a m

[jira] [Commented] (FLINK-9115) Support addition of part suffix in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-9115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16450069#comment-16450069 ] Fabian Hueske commented on FLINK-9115: -- Thanks for helping to keep the JIRA clean [~g

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16450012#comment-16450012 ] Fabian Hueske commented on FLINK-9219: -- I think we should implement a new built-in ty

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16450003#comment-16450003 ] Fabian Hueske commented on FLINK-9138: -- [~narayaruna], we'd probably add this feature

[jira] [Commented] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449502#comment-16449502 ] Fabian Hueske commented on FLINK-7484: -- Hi [~joshlemer], thanks for reporting the iss

[jira] [Commented] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct agg on DataStream

[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16445682#comment-16445682 ] Fabian Hueske commented on FLINK-8690: -- Hi [~walterddr] and [~hequn8128], Thanks for

[jira] [Commented] (FLINK-8646) Move docs directory to flink-docs

[ https://issues.apache.org/jira/browse/FLINK-8646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16443800#comment-16443800 ] Fabian Hueske commented on FLINK-8646: -- If we do that, we need to updated contributio

[jira] [Commented] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16442072#comment-16442072 ] Fabian Hueske commented on FLINK-9193: -- I can see how these methods can be useful for

[jira] [Closed] (FLINK-6924) ADD LOG(X) supported in TableAPI

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

[jira] [Closed] (FLINK-8366) Use Row instead of String as key when process upsert results

[ https://issues.apache.org/jira/browse/FLINK-8366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8366. Resolution: Fixed Fix Version/s: 1.5.0 Fixed on master with 3adc21d489d78cd34748f2132e4e7659f

[jira] [Closed] (FLINK-9089) Upgrade Orc dependency to 1.4.3

[ https://issues.apache.org/jira/browse/FLINK-9089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9089. Resolution: Fixed Fix Version/s: 1.5.0 Fixed on master with afad30a54fa92b90bbaa97d2559713fdc

[jira] [Closed] (FLINK-9183) Kafka consumer docs to warn about idle partitions

[ https://issues.apache.org/jira/browse/FLINK-9183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9183. Resolution: Fixed Fix Version/s: 1.4.3 1.5.0 Fixed on master with b005ea35

[jira] [Assigned] (FLINK-9183) Kafka consumer docs to warn about idle partitions

[ https://issues.apache.org/jira/browse/FLINK-9183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9183: Assignee: Juho Autio > Kafka consumer docs to warn about idle partitions >

[jira] [Comment Edited] (FLINK-9166) Performance issue with Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16439361#comment-16439361 ] Fabian Hueske edited comment on FLINK-9166 at 4/16/18 12:25 PM:

[jira] [Commented] (FLINK-9166) Performance issue with Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16439361#comment-16439361 ] Fabian Hueske commented on FLINK-9166: -- Thanks for opening this issue [~ssu...@gmail.

[jira] [Assigned] (FLINK-9182) async checkpoints for timer service

[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9182: Assignee: makeyang > async checkpoints for timer service >

[jira] [Closed] (FLINK-9068) Website documentation issue - html tag visible on screen

[ https://issues.apache.org/jira/browse/FLINK-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9068. Resolution: Fixed Fix Version/s: 1.4.3 1.5.0 Fixed for 1.6.0 with 2d872447

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16427224#comment-16427224 ] Fabian Hueske commented on FLINK-9138: -- Thank you [~glaksh100]! > Enhance BucketingS

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16427208#comment-16427208 ] Fabian Hueske commented on FLINK-9138: -- Hi [~narayaruna] and [~glaksh100], can you ch

[jira] [Commented] (FLINK-9055) WebUI shows job as Running although not enough resources are available

[ https://issues.apache.org/jira/browse/FLINK-9055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16427104#comment-16427104 ] Fabian Hueske commented on FLINK-9055: -- TBH, I'm not familiar with the details of the

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16426596#comment-16426596 ] Fabian Hueske commented on FLINK-9056: -- I assume that the following happens: The cl

[jira] [Created] (FLINK-9135) Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed

Fabian Hueske created FLINK-9135: Summary: Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed Key: FLINK-9135 URL: https://issues.apache.org/jira/browse/FLINK-9135 Project: Flink

[jira] [Updated] (FLINK-9031) DataSet Job result changes when adding rebalance after union

[ https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9031: - Fix Version/s: 1.3.4 > DataSet Job result changes when adding rebalance after union >

[jira] [Reopened] (FLINK-9031) DataSet Job result changes when adding rebalance after union

[ https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-9031: -- Added fix for Flink 1.3.4 > DataSet Job result changes when adding rebalance after union >

[jira] [Closed] (FLINK-9031) DataSet Job result changes when adding rebalance after union

[ https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9031. Resolution: Fixed > DataSet Job result changes when adding rebalance after union > -

[jira] [Commented] (FLINK-9031) DataSet Job result changes when adding rebalance after union

[ https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425774#comment-16425774 ] Fabian Hueske commented on FLINK-9031: -- Fixed for 1.3.4 with cb38b6defbea5f92b6f3a587

[jira] [Updated] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc

[ https://issues.apache.org/jira/browse/FLINK-9130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9130: - Priority: Minor (was: Critical) > Add cancel-job option to SavepointHandlers JavaDoc > --

[jira] [Commented] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc

[ https://issues.apache.org/jira/browse/FLINK-9130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425612#comment-16425612 ] Fabian Hueske commented on FLINK-9130: -- Thanks for the correction [~gjy]. I've change

[jira] [Updated] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc

[ https://issues.apache.org/jira/browse/FLINK-9130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9130: - Description: The Savepoint JavaDocs are missing the {{cancel-job}} option. See discussion on ML h

[jira] [Updated] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc

[ https://issues.apache.org/jira/browse/FLINK-9130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9130: - Summary: Add cancel-job option to SavepointHandlers JavaDoc (was: Add cancel-job option to Savepo

[jira] [Created] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc and regenerate REST docs

Fabian Hueske created FLINK-9130: Summary: Add cancel-job option to SavepointHandlers JavaDoc and regenerate REST docs Key: FLINK-9130 URL: https://issues.apache.org/jira/browse/FLINK-9130 Project: Fl

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425537#comment-16425537 ] Fabian Hueske commented on FLINK-9056: -- Sorry for the late reply. You should be able

[jira] [Commented] (FLINK-9031) DataSet Job result changes when adding rebalance after union

[ https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425437#comment-16425437 ] Fabian Hueske commented on FLINK-9031: -- Yes, that should be easy. The optimizer didn'

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

[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425432#comment-16425432 ] Fabian Hueske commented on FLINK-6895: -- Thank you [~wind_ljy]! > Add STR_TO_DATE sup

[jira] [Commented] (FLINK-9055) WebUI shows job as Running although not enough resources are available

[ https://issues.apache.org/jira/browse/FLINK-9055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425422#comment-16425422 ] Fabian Hueske commented on FLINK-9055: -- Hi [~sihuazhou], thanks for taking care of th

[jira] [Commented] (FLINK-9068) Website documentation issue - html tag visible on screen

[ https://issues.apache.org/jira/browse/FLINK-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425375#comment-16425375 ] Fabian Hueske commented on FLINK-9068: -- Hi [~shankarganesh1234], I gave you contribut

[jira] [Assigned] (FLINK-9068) Website documentation issue - html tag visible on screen

[ https://issues.apache.org/jira/browse/FLINK-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9068: Assignee: SHANKAR GANESH > Website documentation issue - html tag visible on screen > -

[jira] [Updated] (FLINK-9066) Add 'HOTSPOTS' function to Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9066: - Issue Type: New Feature (was: Improvement) > Add 'HOTSPOTS' function to Flink SQL > -

[jira] [Commented] (FLINK-9066) Add 'HOTSPOTS' function to Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425369#comment-16425369 ] Fabian Hueske commented on FLINK-9066: -- This definitely looks interesting! We'd have

[jira] [Updated] (FLINK-9066) Add 'HOTSPOTS' function to Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9066: - Priority: Minor (was: Major) > Add 'HOTSPOTS' function to Flink SQL > ---

[jira] [Commented] (FLINK-9119) example code error in Concepts & Common API

[ https://issues.apache.org/jira/browse/FLINK-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425352#comment-16425352 ] Fabian Hueske commented on FLINK-9119: -- Good catch [~chillon_m]! {{project(...)}}sho

[jira] [Created] (FLINK-9067) End-to-end test: Stream SQL query with failure and retry

Fabian Hueske created FLINK-9067: Summary: End-to-end test: Stream SQL query with failure and retry Key: FLINK-9067 URL: https://issues.apache.org/jira/browse/FLINK-9067 Project: Flink Issue

[jira] [Commented] (FLINK-6473) Add OVER window support for batch tables

[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16411093#comment-16411093 ] Fabian Hueske commented on FLINK-6473: -- Let's move this to the user mailing list. Ji

[jira] [Commented] (FLINK-6473) Add OVER window support for batch tables

[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16411060#comment-16411060 ] Fabian Hueske commented on FLINK-6473: -- I don't understand what you are asking for.

[jira] [Closed] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

[ https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8919. Resolution: Implemented Implemented in 1.6.0 with cc94090ea29b5f33a0a110d7af46dfc2c7e8610a > Add Ke

[jira] [Commented] (FLINK-6473) Add OVER window support for batch tables

[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410945#comment-16410945 ] Fabian Hueske commented on FLINK-6473: -- Have a look at the interface of the [user-def

[jira] [Comment Edited] (FLINK-6473) Add OVER window support for batch tables

[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410945#comment-16410945 ] Fabian Hueske edited comment on FLINK-6473 at 3/23/18 7:54 AM: -

[jira] [Comment Edited] (FLINK-6473) Add OVER window support for batch tables

[ https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16410799#comment-16410799 ] Fabian Hueske edited comment on FLINK-6473 at 3/23/18 7:52 AM: -

[jira] [Created] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

Fabian Hueske created FLINK-9056: Summary: Job submission fails with AskTimeoutException if not enough slots are available Key: FLINK-9056 URL: https://issues.apache.org/jira/browse/FLINK-9056 Project

[jira] [Created] (FLINK-9055) WebUI shows job as Running although not enough resources are available

Fabian Hueske created FLINK-9055: Summary: WebUI shows job as Running although not enough resources are available Key: FLINK-9055 URL: https://issues.apache.org/jira/browse/FLINK-9055 Project: Flink

[jira] [Closed] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8903. Resolution: Fixed Fixed for 1.5.0 with 555e80a089c7d4a5d2d69d9a2f05d606e12d2eff Fixed for 1.6.0 with

[jira] [Commented] (FLINK-9049) Create unified interfaces to configure and instatiate TableSink

[ https://issues.apache.org/jira/browse/FLINK-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409304#comment-16409304 ] Fabian Hueske commented on FLINK-9049: -- Thanks for the issue [~suez1224]. I think it

[jira] [Commented] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

[ https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409282#comment-16409282 ] Fabian Hueske commented on FLINK-6595: -- You don't need to separate the query (and I d

[jira] [Commented] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

[ https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408089#comment-16408089 ] Fabian Hueske commented on FLINK-6595: -- [~yinhua], the inner query does not forward a

[jira] [Commented] (FLINK-9031) DataSet Job result changes when adding rebalance after union

[ https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407683#comment-16407683 ] Fabian Hueske commented on FLINK-9031: -- Adding relevant information from the mail thr

[jira] [Created] (FLINK-9031) DataSet Job result changes when adding rebalance after union

Fabian Hueske created FLINK-9031: Summary: DataSet Job result changes when adding rebalance after union Key: FLINK-9031 URL: https://issues.apache.org/jira/browse/FLINK-9031 Project: Flink I

[jira] [Closed] (FLINK-9025) Problem with convert String to Row

[ https://issues.apache.org/jira/browse/FLINK-9025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9025. Resolution: Not A Problem The {{Row}} data type was not designed for flexible schemas. Closing as "

[jira] [Commented] (FLINK-9025) Problem with convert String to Row

[ https://issues.apache.org/jira/browse/FLINK-9025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405162#comment-16405162 ] Fabian Hueske commented on FLINK-9025: -- Rows have a schema with fixed data types like

[jira] [Closed] (FLINK-9021) org.apache.flink.table.codegen.CodeGenException: Unsupported call: TUMBLE

[ https://issues.apache.org/jira/browse/FLINK-9021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9021. Resolution: Not A Problem You can implement this functionality with a user-defined aggregate functio

[jira] [Assigned] (FLINK-8972) Create general purpose DataSet testing job

[ https://issues.apache.org/jira/browse/FLINK-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8972: Assignee: Fabian Hueske > Create general purpose DataSet testing job >

[jira] [Assigned] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8903: Assignee: Fabian Hueske (was: Shuyi Chen) > Built-in agg functions VAR_POP, VAR_SAMP, STDE

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16400963#comment-16400963 ] Fabian Hueske commented on FLINK-8903: -- Thanks Shuyi! In fact, I was curious how har

[jira] [Updated] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8903: - Description: The built-in aggregation functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are tran

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