[jira] [Closed] (FLINK-8355) DataSet Should not union a NULL row for AGG without GROUP BY clause.

2018-01-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8355. Resolution: Fixed Assignee: sunjincheng Fix Version/s: 1.4.1

[jira] [Created] (FLINK-8457) Documentation for Building from Source is broken

2018-01-19 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8457: Summary: Documentation for Building from Source is broken Key: FLINK-8457 URL: https://issues.apache.org/jira/browse/FLINK-8457 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8284) Custom metrics not being exposed for Prometheus

2018-01-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330490#comment-16330490 ] Fabian Hueske commented on FLINK-8284: -- +1 to improve the docs. [~JBiason], would you mind to either

[jira] [Commented] (FLINK-8436) Allow implementing both RetractTableSink and BatchTableSink in one class

2018-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16326963#comment-16326963 ] Fabian Hueske commented on FLINK-8436: -- +1 > Allow implementing both RetractTableSink and

[jira] [Assigned] (FLINK-8230) NPE in OrcRowInputFormat on nested structs

2018-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8230: Assignee: Fabian Hueske > NPE in OrcRowInputFormat on nested structs >

[jira] [Updated] (FLINK-8230) NPE in OrcRowInputFormat on nested structs

2018-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8230: - Fix Version/s: 1.4.1 > NPE in OrcRowInputFormat on nested structs >

[jira] [Updated] (FLINK-8230) NPE in OrcRowInputFormat on nested structs

2018-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8230: - Priority: Blocker (was: Minor) > NPE in OrcRowInputFormat on nested structs >

[jira] [Created] (FLINK-8433) Update code example for "Managed Operator State" documentation

2018-01-14 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8433: Summary: Update code example for "Managed Operator State" documentation Key: FLINK-8433 URL: https://issues.apache.org/jira/browse/FLINK-8433 Project: Flink

[jira] [Commented] (FLINK-8413) Snapshot state of aggregated data is not maintained in flink's checkpointing

2018-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323645#comment-16323645 ] Fabian Hueske commented on FLINK-8413: -- This might also an issue with Beam's Flink runner. In this

[jira] [Commented] (FLINK-8405) Keyed State in broadcasted data steam.

2018-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321848#comment-16321848 ] Fabian Hueske commented on FLINK-8405: -- Connecting a keyed stream and a broadcasted stream is not

[jira] [Comment Edited] (FLINK-8355) DataSet Should not union a NULL row for AGG without GROUP BY clause.

2018-01-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318619#comment-16318619 ] Fabian Hueske edited comment on FLINK-8355 at 1/9/18 3:47 PM: -- The motivation

[jira] [Commented] (FLINK-8355) DataSet Should not union a NULL row for AGG without GROUP BY clause.

2018-01-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318619#comment-16318619 ] Fabian Hueske commented on FLINK-8355: -- The motivation for the {{DataSetAggregateWithNullValuesRule}}

[jira] [Created] (FLINK-8391) Improve dependency documentation for queryable state

2018-01-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8391: Summary: Improve dependency documentation for queryable state Key: FLINK-8391 URL: https://issues.apache.org/jira/browse/FLINK-8391 Project: Flink Issue

[jira] [Commented] (FLINK-8364) ListState should return empty iterator rather than null when it has no value

2018-01-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16312142#comment-16312142 ] Fabian Hueske commented on FLINK-8364: -- Changing the behavior of {{ListState.get()}} might break

[jira] [Created] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state

2017-12-29 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8331: Summary: FieldParsers do not correctly set EMPT_COLUMN error state Key: FLINK-8331 URL: https://issues.apache.org/jira/browse/FLINK-8331 Project: Flink

[jira] [Assigned] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-12-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-3655: Assignee: Fabian Hueske > Allow comma-separated or multiple directories to be specified

[jira] [Updated] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-12-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-3655: - Fix Version/s: 1.5.0 > Allow comma-separated or multiple directories to be specified for >

[jira] [Updated] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-12-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-3655: - Priority: Major (was: Minor) > Allow comma-separated or multiple directories to be specified for

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-12-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16306527#comment-16306527 ] Fabian Hueske commented on FLINK-3655: -- Hi [~sjwiesman], sorry for the delay. I just had a look at

[jira] [Closed] (FLINK-8278) Scala examples in Metric documentation do not compile

2017-12-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8278. Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 Fixed for 1.4.1 with

[jira] [Resolved] (FLINK-8310) Flink 1.4 Column 'rowtime' not found in any table

2017-12-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-8310. -- Resolution: Not A Problem I've answered [your question on Stack

[jira] [Created] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher

2017-12-22 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8308: Summary: Update yajl-ruby dependency to 1.3.1 or higher Key: FLINK-8308 URL: https://issues.apache.org/jira/browse/FLINK-8308 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources

2017-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16300222#comment-16300222 ] Fabian Hueske commented on FLINK-8240: -- Thanks for starting this discussion [~twalthr]. I agree, we

[jira] [Created] (FLINK-8303) Update Savepoint Compatibility Table for 1.4

2017-12-21 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8303: Summary: Update Savepoint Compatibility Table for 1.4 Key: FLINK-8303 URL: https://issues.apache.org/jira/browse/FLINK-8303 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8278) Scala examples in Metric documentation do not compile

2017-12-18 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8278: Summary: Scala examples in Metric documentation do not compile Key: FLINK-8278 URL: https://issues.apache.org/jira/browse/FLINK-8278 Project: Flink Issue

[jira] [Created] (FLINK-8260) Document API of Kafka 0.11 Producer

2017-12-14 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8260: Summary: Document API of Kafka 0.11 Producer Key: FLINK-8260 URL: https://issues.apache.org/jira/browse/FLINK-8260 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-8246) Download page must not link to dist.apache.org

2017-12-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-8246. -- Resolution: Fixed Thanks for reporting this issue [~s...@apache.org]. Fixed with

[jira] [Assigned] (FLINK-8246) Download page must not link to dist.apache.org

2017-12-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8246: Assignee: Fabian Hueske > Download page must not link to dist.apache.org >

[jira] [Created] (FLINK-8243) OrcTableSource should recursively read all files in nested directories of the input path.

2017-12-12 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8243: Summary: OrcTableSource should recursively read all files in nested directories of the input path. Key: FLINK-8243 URL: https://issues.apache.org/jira/browse/FLINK-8243

[jira] [Created] (FLINK-8242) ClassCastException in OrcTableSource.toOrcPredicate

2017-12-12 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8242: Summary: ClassCastException in OrcTableSource.toOrcPredicate Key: FLINK-8242 URL: https://issues.apache.org/jira/browse/FLINK-8242 Project: Flink Issue

[jira] [Commented] (FLINK-7934) Upgrade Calcite dependency to 1.15

2017-12-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285683#comment-16285683 ] Fabian Hueske commented on FLINK-7934: -- Calcite 1.15 has been released:

[jira] [Commented] (FLINK-8229) Cannot use broadcast in StreamingEnvironment

2017-12-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16285659#comment-16285659 ] Fabian Hueske commented on FLINK-8229: -- In the DataSet API, a broadcast variable is computed by an

[jira] [Commented] (FLINK-7129) Dynamically changing patterns

2017-12-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282185#comment-16282185 ] Fabian Hueske commented on FLINK-7129: -- It won't go into Flink 1.4.0 because feature freeze was more

[jira] [Created] (FLINK-8203) Make schema definition of DataStream/DataSet to Table conversion more flexible

2017-12-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8203: Summary: Make schema definition of DataStream/DataSet to Table conversion more flexible Key: FLINK-8203 URL: https://issues.apache.org/jira/browse/FLINK-8203

[jira] [Commented] (FLINK-8195) Add Redis Sink

2017-12-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277020#comment-16277020 ] Fabian Hueske commented on FLINK-8195: -- A Redis connector is available in the Apache Bahir project:

[jira] [Commented] (FLINK-7797) Add support for windowed outer joins for streaming tables

2017-12-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276856#comment-16276856 ] Fabian Hueske commented on FLINK-7797: -- This sounds good! +1 for adding the boolean flag. I think we

[jira] [Comment Edited] (FLINK-8164) JobManager's archiving does not work on S3

2017-12-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276651#comment-16276651 ] Fabian Hueske edited comment on FLINK-8164 at 12/4/17 12:53 PM: This is

[jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

2017-12-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276692#comment-16276692 ] Fabian Hueske commented on FLINK-8182: -- The {{TextInputFormat}} recursively lists files in the

[jira] [Commented] (FLINK-8177) Flink cannot be built for Hadoop 2.9.0

2017-12-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276469#comment-16276469 ] Fabian Hueske commented on FLINK-8177: -- +1 for mocking the `Container` as proposed by [~aljoscha]. >

[jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

2017-12-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274223#comment-16274223 ] Fabian Hueske commented on FLINK-8182: -- Does it fail at some point with an exception? > Unable to

[jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

2017-12-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274206#comment-16274206 ] Fabian Hueske commented on FLINK-8182: -- yes > Unable to read hdfs file system directory(which

[jira] [Commented] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

2017-12-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274168#comment-16274168 ] Fabian Hueske commented on FLINK-8182: -- There is no built-in shortcut for that but the

[jira] [Closed] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

2017-12-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8182. Resolution: Fixed > Unable to read hdfs file system directory(which contains sub directories) >

[jira] [Reopened] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively

2017-12-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-8182: -- > Unable to read hdfs file system directory(which contains sub directories) > recursively >

[jira] [Comment Edited] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-11-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272512#comment-16272512 ] Fabian Hueske edited comment on FLINK-8173 at 11/30/17 10:52 AM: - Yes, you

[jira] [Comment Edited] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-11-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272512#comment-16272512 ] Fabian Hueske edited comment on FLINK-8173 at 11/30/17 10:51 AM: - Yes, you

[jira] [Commented] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-11-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272512#comment-16272512 ] Fabian Hueske commented on FLINK-8173: -- Yes, you should change

[jira] [Created] (FLINK-8179) Convert CharSequence to String when registering / converting a Table

2017-11-30 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8179: Summary: Convert CharSequence to String when registering / converting a Table Key: FLINK-8179 URL: https://issues.apache.org/jira/browse/FLINK-8179 Project: Flink

[jira] [Created] (FLINK-8177) Flink cannot be built for Hadoop 2.9.0

2017-11-30 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8177: Summary: Flink cannot be built for Hadoop 2.9.0 Key: FLINK-8177 URL: https://issues.apache.org/jira/browse/FLINK-8177 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8158) Rowtime window inner join emits late data

2017-11-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268409#comment-16268409 ] Fabian Hueske commented on FLINK-8158: -- Hi [~hequn8128], thanks for looking into this! Can you

[jira] [Commented] (FLINK-8144) Optimize the timer logic in RowTimeUnboundedOver

2017-11-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16265088#comment-16265088 ] Fabian Hueske commented on FLINK-8144: -- Did you observe this behavior in practice, i.e., while

[jira] [Created] (FLINK-8140) Add AppendStreamTableSink for bucketed CSV files

2017-11-23 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8140: Summary: Add AppendStreamTableSink for bucketed CSV files Key: FLINK-8140 URL: https://issues.apache.org/jira/browse/FLINK-8140 Project: Flink Issue Type:

[jira] [Created] (FLINK-8141) Add AppendStreamTableSink for bucketed ORC files

2017-11-23 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8141: Summary: Add AppendStreamTableSink for bucketed ORC files Key: FLINK-8141 URL: https://issues.apache.org/jira/browse/FLINK-8141 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6101) GroupBy fields with arithmetic expression (include UDF) can not be selected

2017-11-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16263908#comment-16263908 ] Fabian Hueske commented on FLINK-6101: -- In the example you gave, I'd think that {{'adId}} in

[jira] [Closed] (FLINK-2170) Add OrcTableSource

2017-11-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2170. Resolution: Implemented Fix Version/s: 1.5.0 1.4.0 Implemented for 1.4.0

[jira] [Commented] (FLINK-6101) GroupBy fields with arithmetic expression (include UDF) can not be selected

2017-11-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262540#comment-16262540 ] Fabian Hueske commented on FLINK-6101: -- You are right that SQL doesn't support `AS`. But also SQL is

[jira] [Commented] (FLINK-8118) Allow to specify the offsets of KafkaTableSources

2017-11-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262211#comment-16262211 ] Fabian Hueske commented on FLINK-8118: -- Hi [~xccui], 1. I think offsets should be configured via the

[jira] [Commented] (FLINK-6101) GroupBy fields with arithmetic expression (include UDF) can not be selected

2017-11-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262199#comment-16262199 ] Fabian Hueske commented on FLINK-6101: -- Thanks for working on this [~lincoln.86xy]! I think support

[jira] [Commented] (FLINK-7797) Add support for windowed outer joins for streaming tables

2017-11-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262185#comment-16262185 ] Fabian Hueske commented on FLINK-7797: -- Excellent! Thank you! :-) > Add support for windowed outer

[jira] [Assigned] (FLINK-7797) Add support for windowed outer joins for streaming tables

2017-11-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7797: Assignee: Xingcan Cui > Add support for windowed outer joins for streaming tables >

[jira] [Commented] (FLINK-7797) Add support for windowed outer joins for streaming tables

2017-11-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262171#comment-16262171 ] Fabian Hueske commented on FLINK-7797: -- [~xccui], you implemented the INNER JOIN. Do you want to work

[jira] [Created] (FLINK-8128) Add Latency/Throughput Section to Table API / SQL docs

2017-11-22 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8128: Summary: Add Latency/Throughput Section to Table API / SQL docs Key: FLINK-8128 URL: https://issues.apache.org/jira/browse/FLINK-8128 Project: Flink Issue

[jira] [Closed] (FLINK-4575) DataSet aggregate methods should support POJOs

2017-11-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4575. Resolution: Won't Fix Won't fix because the Table API / SQL integration offer many built-in

[jira] [Commented] (FLINK-8094) Support other types for ExistingField rowtime extractor

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16255516#comment-16255516 ] Fabian Hueske commented on FLINK-8094: -- +1 for having a rowtime extractor for string fields. As a

[jira] [Closed] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8069. Resolution: Implemented Fix Version/s: 1.5.0 1.4.0 Implemented for 1.4.0

[jira] [Closed] (FLINK-7389) Remove Calcite PushProjector

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7389. Resolution: Fixed Fix Version/s: 1.5.0 1.4.0 Fixed for 1.4.0 with

[jira] [Closed] (FLINK-8014) Add Kafka010JsonTableSink

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8014. Resolution: Implemented Fix Version/s: 1.5.0 Implemented for 1.4.0 with

[jira] [Closed] (FLINK-7003) "select * from" in Flink SQL should not flatten all fields in the table by default

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7003. Resolution: Fixed Fix Version/s: 1.5.0 1.4.0 Fixed for 1.4.0 with

[jira] [Closed] (FLINK-7051) Bump up Calcite version to 1.14

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7051. Resolution: Done Fix Version/s: 1.5.0 > Bump up Calcite version to 1.14 >

[jira] [Closed] (FLINK-8016) Add documentation for KafkaJsonTableSink

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8016. Resolution: Done Fix Version/s: 1.5.0 Done for 1.4.0 with

[jira] [Commented] (FLINK-3656) Rework Table API tests

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16255075#comment-16255075 ] Fabian Hueske commented on FLINK-3656: -- There's still a bit of duplication, but I agree. We can close

[jira] [Commented] (FLINK-5270) Refactor the batch Scala-expression Table API tests

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16255074#comment-16255074 ] Fabian Hueske commented on FLINK-5270: -- +1 > Refactor the batch Scala-expression Table API tests >

[jira] [Commented] (FLINK-5272) Refactor the stream Scala-expression Table API tests

2017-11-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16255073#comment-16255073 ] Fabian Hueske commented on FLINK-5272: -- +1 > Refactor the stream Scala-expression Table API tests >

[jira] [Commented] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254863#comment-16254863 ] Fabian Hueske commented on FLINK-7962: -- Implemented for 1.5.0 with

[jira] [Closed] (FLINK-7848) Allow time attributes for atomic types

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7848. Resolution: Fixed Fix Version/s: 1.4.0 Fixed for 1.4.0 with

[jira] [Updated] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7962: - Fix Version/s: 1.5.0 > Add built-in support for min/max aggregation for Timestamp >

[jira] [Updated] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7962: - Issue Type: Sub-task (was: Task) Parent: FLINK-4600 > Add built-in support for min/max

[jira] [Updated] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7962: - Component/s: Table API & SQL > Add built-in support for min/max aggregation for Timestamp >

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253258#comment-16253258 ] Fabian Hueske commented on FLINK-7923: -- Great, thanks! > SQL parser exception when accessing

[jira] [Commented] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253152#comment-16253152 ] Fabian Hueske commented on FLINK-7490: -- I had a look at it and it seems that the wrong classloader is

[jira] [Assigned] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7490: Assignee: Fabian Hueske > UDF Agg throws Exception when flink-table is loaded with

[jira] [Updated] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7490: - Priority: Blocker (was: Major) > UDF Agg throws Exception when flink-table is loaded with

[jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs

2017-11-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249312#comment-16249312 ] Fabian Hueske commented on FLINK-4575: -- I'm not sure about extending the DataSet API for such special

[jira] [Commented] (FLINK-7919) Join with Solution Set fails with NPE if Solution Set has no entry

2017-11-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247736#comment-16247736 ] Fabian Hueske commented on FLINK-7919: -- Hi [~greghogan], yes that would be an option as well. This

[jira] [Commented] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

2017-11-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16245513#comment-16245513 ] Fabian Hueske commented on FLINK-8008: -- Except for nested field, {{CsvTableSink}} simply calls

[jira] [Commented] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

2017-11-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16245509#comment-16245509 ] Fabian Hueske commented on FLINK-8008: -- Depends on the TableSink. {{CsvTableSink}} will write the

[jira] [Commented] (FLINK-8036) Consider using gradle to build Flink

2017-11-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16245390#comment-16245390 ] Fabian Hueske commented on FLINK-8036: -- I think this will be very hard. Flink's build management

[jira] [Closed] (FLINK-7996) Add support for (left.time = right.time) predicates to window join.

2017-11-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7996. Resolution: Fixed Fix Version/s: 1.5.0 Fixed for 1.4.0 with

[jira] [Closed] (FLINK-8002) Incorrect join window boundaries for LESS_THAN and GREATER_THAN predicates

2017-11-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8002. Resolution: Fixed Fix Version/s: 1.5.0 Fixed for 1.4.0 with

[jira] [Closed] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2017-11-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7922. Resolution: Fixed Fix Version/s: 1.5.0 1.3.3 1.4.0

[jira] [Closed] (FLINK-8012) Table with time attribute cannot be written to CsvTableSink

2017-11-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8012. Resolution: Fixed Fix Version/s: 1.5.0 Fixed for 1.3.3 with

[jira] [Closed] (FLINK-7971) Fix potential NPE with inconsistent state

2017-11-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7971. Resolution: Fixed Fix Version/s: 1.5.0 1.3.3 1.4.0

[jira] [Created] (FLINK-8016) Add documentation for KafkaJsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8016: Summary: Add documentation for KafkaJsonTableSink Key: FLINK-8016 URL: https://issues.apache.org/jira/browse/FLINK-8016 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8015) Add Kafka011JsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8015: - Issue Type: New Feature (was: Improvement) > Add Kafka011JsonTableSink >

[jira] [Created] (FLINK-8015) Add Kafka011JsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8015: Summary: Add Kafka011JsonTableSink Key: FLINK-8015 URL: https://issues.apache.org/jira/browse/FLINK-8015 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8014) Add Kafka010JsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8014: Summary: Add Kafka010JsonTableSink Key: FLINK-8014 URL: https://issues.apache.org/jira/browse/FLINK-8014 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8013) Check of AggregateFunction merge function signature is too strict.

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8013: Summary: Check of AggregateFunction merge function signature is too strict. Key: FLINK-8013 URL: https://issues.apache.org/jira/browse/FLINK-8013 Project: Flink

[jira] [Created] (FLINK-8012) Table with time attribute cannot be written to CsvTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8012: Summary: Table with time attribute cannot be written to CsvTableSink Key: FLINK-8012 URL: https://issues.apache.org/jira/browse/FLINK-8012 Project: Flink

[jira] [Commented] (FLINK-7996) Add support for (left.time = right.time) predicates to window join.

2017-11-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241767#comment-16241767 ] Fabian Hueske commented on FLINK-7996: -- Yes, {{left.time = right.time + C}} should be supported as

[jira] [Created] (FLINK-8002) Incorrect join window boundaries for LESS_THAN and GREATER_THAN predicates

2017-11-06 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8002: Summary: Incorrect join window boundaries for LESS_THAN and GREATER_THAN predicates Key: FLINK-8002 URL: https://issues.apache.org/jira/browse/FLINK-8002 Project:

  1   2   3   4   5   6   7   8   9   10   >