[jira] [Closed] (FLINK-9742) Expose Expression.resultType to public

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

[jira] [Assigned] (FLINK-9742) Expose Expression.resultType to public

[ https://issues.apache.org/jira/browse/FLINK-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9742: Assignee: Jungtaek Lim > Expose Expression.resultType to public >

[jira] [Reopened] (FLINK-9742) Expose Expression.resultType to public

[ https://issues.apache.org/jira/browse/FLINK-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-9742: -- > Expose Expression.resultType to public > -- > >

[jira] [Closed] (FLINK-9742) Expose Expression.resultType to public

[ https://issues.apache.org/jira/browse/FLINK-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9742. Resolution: Fixed > Expose Expression.resultType to public > --

[jira] [Closed] (FLINK-9581) Redundant spaces for Collect at sql.md

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

[jira] [Commented] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16532437#comment-16532437 ] Fabian Hueske commented on FLINK-9737: -- I think the syntax should be coordinated wit

[jira] [Comment Edited] (FLINK-9738) Provide a way to define Table Version Functions in Table API

[ https://issues.apache.org/jira/browse/FLINK-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16532406#comment-16532406 ] Fabian Hueske edited comment on FLINK-9738 at 7/4/18 8:50 AM: -

[jira] [Commented] (FLINK-9738) Provide a way to define Table Version Functions in Table API

[ https://issues.apache.org/jira/browse/FLINK-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16532406#comment-16532406 ] Fabian Hueske commented on FLINK-9738: -- I think the syntax should be coordinated wit

[jira] [Commented] (FLINK-9717) Flush state of one side of the join if other side is bounded

[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531172#comment-16531172 ] Fabian Hueske commented on FLINK-9717: -- There is another aspect to consider when imp

[jira] [Commented] (FLINK-9699) Add api to replace registered table

[ https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16531004#comment-16531004 ] Fabian Hueske commented on FLINK-9699: -- It might be possible to change the translati

[jira] [Commented] (FLINK-7593) Generated plan does not create correct groups

[ https://issues.apache.org/jira/browse/FLINK-7593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16530995#comment-16530995 ] Fabian Hueske commented on FLINK-7593: -- Thanks for the feedback and the effort to re

[jira] [Commented] (FLINK-9519) table example jar did not copy into example dir

[ https://issues.apache.org/jira/browse/FLINK-9519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16530055#comment-16530055 ] Fabian Hueske commented on FLINK-9519: -- Hi [~yanghua], should we close this issue as

[jira] [Closed] (FLINK-8650) Add tests and documentation for WINDOW clause

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

[jira] [Commented] (FLINK-9681) Make sure minRetentionTime not equal to maxRetentionTime

[ https://issues.apache.org/jira/browse/FLINK-9681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529850#comment-16529850 ] Fabian Hueske commented on FLINK-9681: -- Hi [~hequn8128], You are right. Setting bot

[jira] [Commented] (FLINK-9699) Add api to replace registered table

[ https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529664#comment-16529664 ] Fabian Hueske commented on FLINK-9699: -- I understand the motivation for this feature

[jira] [Commented] (FLINK-7593) Generated plan does not create correct groups

[ https://issues.apache.org/jira/browse/FLINK-7593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529491#comment-16529491 ] Fabian Hueske commented on FLINK-7593: -- I'm not aware of any efforts to resolve this

[jira] [Closed] (FLINK-9627) Extending 'KafkaJsonTableSource' according to comments will result in NPE

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

[jira] [Commented] (FLINK-9688) ATAN2 Sql Function support

[ https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16526175#comment-16526175 ] Fabian Hueske commented on FLINK-9688: -- We aim of course for a large set of built-in

[jira] [Commented] (FLINK-9688) ATAN2 Sql Function support

[ https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16526161#comment-16526161 ] Fabian Hueske commented on FLINK-9688: -- This is issue requests a new feature. The {{

[jira] [Updated] (FLINK-9688) ATAN2 Sql Function support

[ https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9688: - Issue Type: New Feature (was: Bug) > ATAN2 Sql Function support > -- > >

[jira] [Updated] (FLINK-9688) ATAN2 Sql Function support

[ https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9688: - Priority: Minor (was: Major) > ATAN2 Sql Function support > -- > >

[jira] [Updated] (FLINK-9688) ATAN2 Sql Function support

[ https://issues.apache.org/jira/browse/FLINK-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9688: - Issue Type: New Feature (was: Bug) > ATAN2 Sql Function support > -- > >

[jira] [Closed] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

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

[jira] [Commented] (FLINK-9565) Evaluating scalar UDFs in parallel

[ https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524814#comment-16524814 ] Fabian Hueske commented on FLINK-9565: -- I agree, we should follow a consistent style

[jira] [Updated] (FLINK-9673) Improve State efficiency of bounded OVER window operators

[ https://issues.apache.org/jira/browse/FLINK-9673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9673: - Description: Currently, the implementations of bounded OVER window aggregations store the comple

[jira] [Created] (FLINK-9673) Improve State efficiency of bounded OVER window operators

Fabian Hueske created FLINK-9673: Summary: Improve State efficiency of bounded OVER window operators Key: FLINK-9673 URL: https://issues.apache.org/jira/browse/FLINK-9673 Project: Flink Issue

[jira] [Commented] (FLINK-6962) SQL DDL for input and output tables

[ https://issues.apache.org/jira/browse/FLINK-6962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524748#comment-16524748 ] Fabian Hueske commented on FLINK-6962: -- Hi, [~suez1224] and [~walterddr] are workin

[jira] [Commented] (FLINK-9644) Restore a job from savepoint in a local stream environment

[ https://issues.apache.org/jira/browse/FLINK-9644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520341#comment-16520341 ] Fabian Hueske commented on FLINK-9644: -- The {{AbstractOperatorRestoreTestBase}} show

[jira] [Commented] (FLINK-4301) Parameterize Flink version in Quickstart bash script

[ https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520082#comment-16520082 ] Fabian Hueske commented on FLINK-4301: -- Yes, this issue refers to that script. It is

[jira] [Closed] (FLINK-9522) Rework Flink website

[ https://issues.apache.org/jira/browse/FLINK-9522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9522. Resolution: Done Assignee: Fabian Hueske Merged to flink-web/asf-site with df053d4300aec40ae6

[jira] [Commented] (FLINK-9565) Evaluating scalar UDFs in parallel

[ https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16519212#comment-16519212 ] Fabian Hueske commented on FLINK-9565: -- Hi [~yinhua], These are the relevant guides

[jira] [Commented] (FLINK-9565) Evaluating scalar UDFs in parallel

[ https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517975#comment-16517975 ] Fabian Hueske commented on FLINK-9565: -- This seems to be a rather specific issue. [

[jira] [Commented] (FLINK-9615) Add possibility to use Connectors as Sinks in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-9615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517128#comment-16517128 ] Fabian Hueske commented on FLINK-9615: -- Thanks for opening this issue! This is (part

[jira] [Closed] (FLINK-9606) Support ParquetTableSource

[ https://issues.apache.org/jira/browse/FLINK-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9606. Resolution: Duplicate Closing as duplicate of FLINK-2169. > Support ParquetTableSource > -

[jira] [Commented] (FLINK-9597) Flink application does not scale as expected

[ https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514734#comment-16514734 ] Fabian Hueske commented on FLINK-9597: -- Thanks für starting the thread on the mailin

[jira] [Commented] (FLINK-9597) Flink application does not scale as expected

[ https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514124#comment-16514124 ] Fabian Hueske commented on FLINK-9597: -- Hi [~yow], To be honest, this seems to be r

[jira] [Updated] (FLINK-9597) Flink application does not scale as expected

[ https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9597: - Summary: Flink application does not scale as expected (was: Flink fail to scale!) > Flink appli

[jira] [Comment Edited] (FLINK-9597) Flink fail to scale!

[ https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513950#comment-16513950 ] Fabian Hueske edited comment on FLINK-9597 at 6/15/18 3:17 PM:

[jira] [Commented] (FLINK-9597) Flink fail to scale!

[ https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513950#comment-16513950 ] Fabian Hueske commented on FLINK-9597: -- Can add a few more details about the environ

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

[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9159: Assignee: (was: Fabian Hueske) > Sanity check default timeout values > ---

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16512534#comment-16512534 ] Fabian Hueske commented on FLINK-9528: -- I don't think we need state in all Filters w

[jira] [Commented] (FLINK-9548) Flink Apache Kudu Connector

[ https://issues.apache.org/jira/browse/FLINK-9548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511379#comment-16511379 ] Fabian Hueske commented on FLINK-9548: -- Yes, I know what Kudu is. But I think it wou

[jira] [Commented] (FLINK-9548) Flink Apache Kudu Connector

[ https://issues.apache.org/jira/browse/FLINK-9548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511371#comment-16511371 ] Fabian Hueske commented on FLINK-9548: -- Hi [~sanysand...@gmail.com], I assigned the

[jira] [Assigned] (FLINK-9548) Flink Apache Kudu Connector

[ https://issues.apache.org/jira/browse/FLINK-9548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9548: Assignee: Sandish Kumar HN > Flink Apache Kudu Connector > --- > >

[jira] [Commented] (FLINK-9220) Table program cannot be compiled

[ https://issues.apache.org/jira/browse/FLINK-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16511290#comment-16511290 ] Fabian Hueske commented on FLINK-9220: -- In my case the UDF class was not present in

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16509320#comment-16509320 ] Fabian Hueske commented on FLINK-9528: -- I think we can provide efficient implementat

[jira] [Commented] (FLINK-9565) Evaluating scalar UDFs in parallel

[ https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16509306#comment-16509306 ] Fabian Hueske commented on FLINK-9565: -- One option to add such a feature could be to

[jira] [Closed] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-8256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8256. Resolution: Not A Bug > Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

[jira] [Closed] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6977. Resolution: Implemented Fixed in 1.6.0: 5544ab5df5d805511a40f2e4007b3afee06d15af & d5de2bcf122fd93

[jira] [Commented] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507474#comment-16507474 ] Fabian Hueske commented on FLINK-6977: -- [~alex.arkhipov], you're right. Thanks for t

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504489#comment-16504489 ] Fabian Hueske commented on FLINK-9528: -- True, highly-selective filters would definit

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16503155#comment-16503155 ] Fabian Hueske commented on FLINK-9528: -- Hi [~hequn8128], can you explain in more det

[jira] [Created] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

Fabian Hueske created FLINK-9541: Summary: Add robots.txt and sitemap.xml to Flink website Key: FLINK-9541 URL: https://issues.apache.org/jira/browse/FLINK-9541 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501716#comment-16501716 ] Fabian Hueske commented on FLINK-9528: -- It is correct that a Filter might emit dupli

[jira] [Assigned] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9524: Assignee: yan zhou > NPE from ProcTimeBoundedRangeOver.scala > ---

[jira] [Commented] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501564#comment-16501564 ] Fabian Hueske commented on FLINK-9524: -- Alright, I've found the reason for the {{nul

[jira] [Commented] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501555#comment-16501555 ] Fabian Hueske commented on FLINK-9524: -- Hi [~yzandrew], thanks for digging into this

[jira] [Created] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

Fabian Hueske created FLINK-9528: Summary: Incorrect results: Filter does not treat Upsert messages correctly. Key: FLINK-9528 URL: https://issues.apache.org/jira/browse/FLINK-9528 Project: Flink

[jira] [Commented] (FLINK-9448) contribute-code.html references Hadoop 1.x support

[ https://issues.apache.org/jira/browse/FLINK-9448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501470#comment-16501470 ] Fabian Hueske commented on FLINK-9448: -- Thanks for noticing and reporting this! Whi

[jira] [Created] (FLINK-9522) Rework Flink website

Fabian Hueske created FLINK-9522: Summary: Rework Flink website Key: FLINK-9522 URL: https://issues.apache.org/jira/browse/FLINK-9522 Project: Flink Issue Type: Improvement Componen

[jira] [Commented] (FLINK-9447) "sensible" vs. "sensitive" in Code Contribution Process

[ https://issues.apache.org/jira/browse/FLINK-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500777#comment-16500777 ] Fabian Hueske commented on FLINK-9447: -- Hi Andrew, thank for the question! You are

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16499356#comment-16499356 ] Fabian Hueske commented on FLINK-9506: -- Thanks for opening this issue. I have a few

[jira] [Updated] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9506: - Description: Hi, we found out application performance drop more than 100% when ReducingState.add

[jira] [Assigned] (FLINK-9482) Not applicable functions for TIME

[ https://issues.apache.org/jira/browse/FLINK-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9482: Assignee: Viktor Vlasov > Not applicable functions for TIME >

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495233#comment-16495233 ] Fabian Hueske commented on FLINK-9461: -- Why should the API depend on the connector?

[jira] [Assigned] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6977: Assignee: Alexandr Arkhipov > Add MD5/SHA1/SHA2 supported in TableAPI > --

[jira] [Commented] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16494890#comment-16494890 ] Fabian Hueske commented on FLINK-6977: -- Thanks you [~alex.arkhipov]. I've assigned t

[jira] [Commented] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493571#comment-16493571 ] Fabian Hueske commented on FLINK-9422: -- As for most relational operators, the user s

[jira] [Commented] (FLINK-9460) Redundant output in table & upsert semantics

[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493429#comment-16493429 ] Fabian Hueske commented on FLINK-9460: -- Yes, it is FLINK-9296 (see the parent issue

[jira] [Updated] (FLINK-9460) Redundant output in table & upsert semantics

[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9460: - Priority: Minor (was: Major) > Redundant output in table & upsert semantics > --

[jira] [Commented] (FLINK-9460) Redundant output in table & upsert semantics

[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493345#comment-16493345 ] Fabian Hueske commented on FLINK-9460: -- First of all, the result is correct. The se

[jira] [Updated] (FLINK-9460) Redundant output in table & upsert semantics

[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9460: - Issue Type: Improvement (was: Bug) > Redundant output in table & upsert semantics >

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493214#comment-16493214 ] Fabian Hueske commented on FLINK-9461: -- I think this (and similar) issues should be

[jira] [Commented] (FLINK-5750) Incorrect parse of brackets inside VALUES subquery

[ https://issues.apache.org/jira/browse/FLINK-5750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16492532#comment-16492532 ] Fabian Hueske commented on FLINK-5750: -- Hi [~Alexander_Koltsov], thanks for looking i

[jira] [Assigned] (FLINK-5750) Incorrect parse of brackets inside VALUES subquery

[ https://issues.apache.org/jira/browse/FLINK-5750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-5750: Assignee: Alexander Koltsov > Incorrect parse of brackets inside VALUES subquery >

[jira] [Commented] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

[ https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16492401#comment-16492401 ] Fabian Hueske commented on FLINK-9185: -- Done > Potential null dereference in > Prio

[jira] [Assigned] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

[ https://issues.apache.org/jira/browse/FLINK-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9185: Assignee: Stephen Jason > Potential null dereference in > PrioritizedOperatorSubtaskState#

[jira] [Commented] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16489081#comment-16489081 ] Fabian Hueske commented on FLINK-9422: -- [~hequn8128], you are right. The operator wou

[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=16489059#comment-16489059 ] Fabian Hueske commented on FLINK-9193: -- +1 > Deprecate non-well-defined output metho

[jira] [Commented] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487585#comment-16487585 ] Fabian Hueske commented on FLINK-9422: -- I think a dedicated operator would be good, e

[jira] [Closed] (FLINK-9419) UNION should not be treated as retraction producing operator

[ https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9419. Resolution: Duplicate Duplicate of FLINK-8594 > UNION should not be treated as retraction producing

[jira] [Commented] (FLINK-9419) UNION should not be treated as retraction producing operator

[ https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487539#comment-16487539 ] Fabian Hueske commented on FLINK-9419: -- Yes, you are right [~hequn8128]. This is a du

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

[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487210#comment-16487210 ] Fabian Hueske commented on FLINK-6016: -- That is of course correct. Splitting files is

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487168#comment-16487168 ] Fabian Hueske commented on FLINK-6016: -- Flink's {{FileInputFormat}} was designed to w

[jira] [Created] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes

Fabian Hueske created FLINK-9422: Summary: Dedicated operator for UNION on streaming tables with time attributes Key: FLINK-9422 URL: https://issues.apache.org/jira/browse/FLINK-9422 Project: Flink

[jira] [Created] (FLINK-9419) UNION should not be treated as retraction producing operator

Fabian Hueske created FLINK-9419: Summary: UNION should not be treated as retraction producing operator Key: FLINK-9419 URL: https://issues.apache.org/jira/browse/FLINK-9419 Project: Flink I

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

[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16486989#comment-16486989 ] Fabian Hueske edited comment on FLINK-6016 at 5/23/18 9:42 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16486989#comment-16486989 ] Fabian Hueske commented on FLINK-6016: -- This problem cannot be solve with the current

[jira] [Updated] (FLINK-9166) Performance issue with many topologies in a single job

[ https://issues.apache.org/jira/browse/FLINK-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9166: - Summary: Performance issue with many topologies in a single job (was: Performance issue with Flin

[jira] [Updated] (FLINK-9395) Outer Joins with array types on the outer join input fail

[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9395: - Description: Given a table {{a}} with a single column {{id}}, the following query {code:sql} SELE

[jira] [Updated] (FLINK-9395) Outer Joins with array types on the outer join input fail

[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-9395: - Summary: Outer Joins with array types on the outer join input fail (was: multiple left outer join

[jira] [Commented] (FLINK-9395) multiple left outer joins to subqueries with array values fail

[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480447#comment-16480447 ] Fabian Hueske commented on FLINK-9395: -- Hi [~kgeis], your analysis is correct. The pr

[jira] [Commented] (FLINK-8918) Introduce Runtime Filter Join

[ https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16477424#comment-16477424 ] Fabian Hueske commented on FLINK-8918: -- It's good to know that you were thinking abou

[jira] [Commented] (FLINK-8918) Introduce Runtime Filter Join

[ https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16477312#comment-16477312 ] Fabian Hueske commented on FLINK-8918: -- Hi [~sihuazhou], thanks for this proposal! I

[jira] [Commented] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

[ https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16477127#comment-16477127 ] Fabian Hueske commented on FLINK-8866: -- Regarding (3), originally, {{TableSink}} was

[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=16477066#comment-16477066 ] Fabian Hueske commented on FLINK-9341: -- Thanks for investigating the issue [~kgeis] a

[jira] [Commented] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

[ https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16474115#comment-16474115 ] Fabian Hueske commented on FLINK-8866: -- I think we should design the system propertie

[jira] [Closed] (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:all-tabpanel ] Fabian Hueske closed FLINK-9234. Resolution: Fixed Fix Version/s: 1.4.3 1.5.0 Fixed for 1.6.0 with f057ca9d

[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: - Description: We introduced the very generic TableSource factories that unify the definition of ta

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