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

[ 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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16323645#comment-16323645 ] Fabian Hueske commented on FLINK-8413: -- This might also an issue with Beam's Flink ru

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

[ https://issues.apache.org/jira/browse/FLINK-8405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16321848#comment-16321848 ] Fabian Hueske commented on FLINK-8405: -- Connecting a keyed stream and a broadcasted s

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

[ https://issues.apache.org/jira/browse/FLINK-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16318619#comment-16318619 ] Fabian Hueske edited comment on FLINK-8355 at 1/9/18 3:47 PM: --

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

[ https://issues.apache.org/jira/browse/FLINK-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16318619#comment-16318619 ] Fabian Hueske commented on FLINK-8355: -- The motivation for the {{DataSetAggregateWith

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

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 Type

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

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

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

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 Issue

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

[ 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 for

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

[ 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 > FileIn

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16306527#comment-16306527 ] Fabian Hueske commented on FLINK-3655: -- Hi [~sjwiesman], sorry for the delay. I just

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

[ 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 e42182d4

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

[ 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 Overflow|https://stackoverflow.

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

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: Task

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

[ https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16300222#comment-16300222 ] Fabian Hueske commented on FLINK-8240: -- Thanks for starting this discussion [~twalthr

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

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

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 Typ

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

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

[ 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 b286592a475393

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

[ 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.

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

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 Type:

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

[ https://issues.apache.org/jira/browse/FLINK-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285683#comment-16285683 ] Fabian Hueske commented on FLINK-7934: -- Calcite 1.15 has been released: [announcemen

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

[ https://issues.apache.org/jira/browse/FLINK-8229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285659#comment-16285659 ] Fabian Hueske commented on FLINK-8229: -- In the DataSet API, a broadcast variable is c

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

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282185#comment-16282185 ] Fabian Hueske commented on FLINK-7129: -- It won't go into Flink 1.4.0 because feature

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

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 Project:

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

[ https://issues.apache.org/jira/browse/FLINK-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277020#comment-16277020 ] Fabian Hueske commented on FLINK-8195: -- A Redis connector is available in the Apache

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

[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276856#comment-16276856 ] Fabian Hueske commented on FLINK-7797: -- This sounds good! +1 for adding the boolean

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

[ https://issues.apache.org/jira/browse/FLINK-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276651#comment-16276651 ] Fabian Hueske edited comment on FLINK-8164 at 12/4/17 12:53 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276692#comment-16276692 ] Fabian Hueske commented on FLINK-8182: -- The {{TextInputFormat}} recursively lists fil

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

[ https://issues.apache.org/jira/browse/FLINK-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276469#comment-16276469 ] Fabian Hueske commented on FLINK-8177: -- +1 for mocking the `Container` as proposed by

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

[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16274223#comment-16274223 ] Fabian Hueske commented on FLINK-8182: -- Does it fail at some point with an exception?

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

[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16274206#comment-16274206 ] Fabian Hueske commented on FLINK-8182: -- yes > Unable to read hdfs file system direct

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

[ https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16274168#comment-16274168 ] Fabian Hueske commented on FLINK-8182: -- There is no built-in shortcut for that but th

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

[ 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) > rec

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

[ 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.

[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16272512#comment-16272512 ] Fabian Hueske edited comment on FLINK-8173 at 11/30/17 10:52 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16272512#comment-16272512 ] Fabian Hueske edited comment on FLINK-8173 at 11/30/17 10:51 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16272512#comment-16272512 ] Fabian Hueske commented on FLINK-8173: -- Yes, you should change {{toAppendStream[org.a

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-8144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16265088#comment-16265088 ] Fabian Hueske commented on FLINK-8144: -- Did you observe this behavior in practice, i.

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

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: Ne

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

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: Ne

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

[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263908#comment-16263908 ] Fabian Hueske commented on FLINK-6101: -- In the example you gave, I'd think that {{'ad

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

[ 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 w

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

[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262540#comment-16262540 ] Fabian Hueske commented on FLINK-6101: -- You are right that SQL doesn't support `AS`.

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

[ https://issues.apache.org/jira/browse/FLINK-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262211#comment-16262211 ] Fabian Hueske commented on FLINK-8118: -- Hi [~xccui], 1. I think offsets should be con

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

[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262199#comment-16262199 ] Fabian Hueske commented on FLINK-6101: -- Thanks for working on this [~lincoln.86xy]!

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

[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262185#comment-16262185 ] Fabian Hueske commented on FLINK-7797: -- Excellent! Thank you! :-) > Add support for

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262171#comment-16262171 ] Fabian Hueske commented on FLINK-7797: -- [~xccui], you implemented the INNER JOIN. Do

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

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 Ty

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

[ 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 aggrega

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

[ https://issues.apache.org/jira/browse/FLINK-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16255516#comment-16255516 ] Fabian Hueske commented on FLINK-8094: -- +1 for having a rowtime extractor for string

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

[ 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 w

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

[ 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 8883fa2d

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

[ 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 2fd53112289ec9002b2c2

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

[ 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 b59fae3f

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

[ 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

[ 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 f14fcefbe1b30eb8178a5caa053c84e505c

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

[ https://issues.apache.org/jira/browse/FLINK-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16255075#comment-16255075 ] Fabian Hueske commented on FLINK-3656: -- There's still a bit of duplication, but I agr

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

[ https://issues.apache.org/jira/browse/FLINK-5270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16255074#comment-16255074 ] Fabian Hueske commented on FLINK-5270: -- +1 > Refactor the batch Scala-expression Tab

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

[ https://issues.apache.org/jira/browse/FLINK-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16255073#comment-16255073 ] Fabian Hueske commented on FLINK-5272: -- +1 > Refactor the stream Scala-expression Ta

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

[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16254863#comment-16254863 ] Fabian Hueske commented on FLINK-7962: -- Implemented for 1.5.0 with d0b2aa28db529a1c98

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

[ 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 9a2ba6e058e907aef65e0af8731ca5ec8

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

[ 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

[ 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 ag

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253258#comment-16253258 ] Fabian Hueske commented on FLINK-7923: -- Great, thanks! > SQL parser exception when a

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

[ https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253152#comment-16253152 ] Fabian Hueske commented on FLINK-7490: -- I had a look at it and it seems that the wron

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

[ 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 AppClass

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

[ 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 AppClas

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

[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16249312#comment-16249312 ] Fabian Hueske commented on FLINK-4575: -- I'm not sure about extending the DataSet API

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

[ https://issues.apache.org/jira/browse/FLINK-7919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247736#comment-16247736 ] Fabian Hueske commented on FLINK-7919: -- Hi [~greghogan], yes that would be an option

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

[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245513#comment-16245513 ] Fabian Hueske commented on FLINK-8008: -- Except for nested field, {{CsvTableSink}} sim

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

[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245509#comment-16245509 ] Fabian Hueske commented on FLINK-8008: -- Depends on the TableSink. {{CsvTableSink}} w

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

[ https://issues.apache.org/jira/browse/FLINK-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245390#comment-16245390 ] Fabian Hueske commented on FLINK-8036: -- I think this will be very hard. Flink's bui

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

[ 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 1b20f70dea3fddfaeaf00ceae44e4dc0f

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

[ 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 c7943291599260003304f003e89725352

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

[ 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 Fixe

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

[ 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 7893aba41ca2a3f7a26bf4ffa3b1966ee

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

[ 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 Fixe

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

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: Improvemen

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

[ 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

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 Com

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

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 Com

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

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

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 Is

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

[ https://issues.apache.org/jira/browse/FLINK-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16241767#comment-16241767 ] Fabian Hueske commented on FLINK-7996: -- Yes, {{left.time = right.time + C}} should be

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

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: Fli

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

Fabian Hueske created FLINK-7996: Summary: Add support for (left.time = right.time) predicates to window join. Key: FLINK-7996 URL: https://issues.apache.org/jira/browse/FLINK-7996 Project: Flink

[jira] [Updated] (FLINK-7990) Strange behavior when configuring Logback for logging

[ https://issues.apache.org/jira/browse/FLINK-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7990: - Affects Version/s: 1.3.2 > Strange behavior when configuring Logback for logging > ---

[jira] [Created] (FLINK-7990) Strange behavior when configuring Logback for logging

Fabian Hueske created FLINK-7990: Summary: Strange behavior when configuring Logback for logging Key: FLINK-7990 URL: https://issues.apache.org/jira/browse/FLINK-7990 Project: Flink Issue Typ

[jira] [Commented] (FLINK-7986) Introduce FilterSetOpTransposeRule to Flink

[ https://issues.apache.org/jira/browse/FLINK-7986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240113#comment-16240113 ] Fabian Hueske commented on FLINK-7986: -- Yes, this rule makes a lot of sense. > Intro

[jira] [Commented] (FLINK-7987) Use RexBuilder when converting Expression to RexNode

[ https://issues.apache.org/jira/browse/FLINK-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240064#comment-16240064 ] Fabian Hueske commented on FLINK-7987: -- Would we lose validation when there is no sch

<    3   4   5   6   7   8   9   10   11   12   >