Fabian Hueske created FLINK-4077:
Summary: Register Pojo DataSet/DataStream as Table requires alias
expression.
Key: FLINK-4077
URL: https://issues.apache.org/jira/browse/FLINK-4077
Project: Flink
Fabian Hueske created FLINK-4068:
Summary: Move constant computations out of code-generated
`flatMap` functions.
Key: FLINK-4068
URL: https://issues.apache.org/jira/browse/FLINK-4068
Project: Flink
Fabian Hueske created FLINK-4047:
Summary: Fix documentation about determinism of KeySelectors
Key: FLINK-4047
URL: https://issues.apache.org/jira/browse/FLINK-4047
Project: Flink
Issue
Fabian Hueske created FLINK-3971:
Summary: Aggregates handle null values incorrectly.
Key: FLINK-3971
URL: https://issues.apache.org/jira/browse/FLINK-3971
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-3955:
Summary: Change Table.toSink() to Table.writeToSink()
Key: FLINK-3955
URL: https://issues.apache.org/jira/browse/FLINK-3955
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3944:
Summary: Add optimization rules to reorder Cartesian products and
joins
Key: FLINK-3944
URL: https://issues.apache.org/jira/browse/FLINK-3944
Project: Flink
Fabian Hueske created FLINK-3943:
Summary: Add support for EXCEPT (set minus)
Key: FLINK-3943
URL: https://issues.apache.org/jira/browse/FLINK-3943
Project: Flink
Issue Type: New Feature
Fabian Hueske created FLINK-3942:
Summary: Add support for INTERSECT
Key: FLINK-3942
URL: https://issues.apache.org/jira/browse/FLINK-3942
Project: Flink
Issue Type: New Feature
Fabian Hueske created FLINK-3899:
Summary: Document window processing with Reduce/FoldFunction +
WindowFunction
Key: FLINK-3899
URL: https://issues.apache.org/jira/browse/FLINK-3899
Project: Flink
Fabian Hueske created FLINK-3873:
Summary: Add a Kafka TableSink with Avro serialization
Key: FLINK-3873
URL: https://issues.apache.org/jira/browse/FLINK-3873
Project: Flink
Issue Type: New
Fabian Hueske created FLINK-3871:
Summary: Add Kafka TableSource with Avro serialization
Key: FLINK-3871
URL: https://issues.apache.org/jira/browse/FLINK-3871
Project: Flink
Issue Type: New
Fabian Hueske created FLINK-3857:
Summary: Add reconnect attempt to Elasticsearch host
Key: FLINK-3857
URL: https://issues.apache.org/jira/browse/FLINK-3857
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3835:
Summary: JSON execution plan not helpful to debug plans with
KeySelectors
Key: FLINK-3835
URL: https://issues.apache.org/jira/browse/FLINK-3835
Project: Flink
Fabian Hueske created FLINK-3811:
Summary: Refactor ExecutionEnvironment in TableEnvironment
Key: FLINK-3811
URL: https://issues.apache.org/jira/browse/FLINK-3811
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3759:
Summary: Table API should throw exception is null value is
encountered in non-null mode.
Key: FLINK-3759
URL: https://issues.apache.org/jira/browse/FLINK-3759
Fabian Hueske created FLINK-3665:
Summary: Range partitioning lacks support to define sort orders
Key: FLINK-3665
URL: https://issues.apache.org/jira/browse/FLINK-3665
Project: Flink
Issue
Fabian Hueske created FLINK-3622:
Summary: Improve error messages for invalid joins
Key: FLINK-3622
URL: https://issues.apache.org/jira/browse/FLINK-3622
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-3621:
Summary: Misleading documentation of memory configuration
parameters
Key: FLINK-3621
URL: https://issues.apache.org/jira/browse/FLINK-3621
Project: Flink
Fabian Hueske created FLINK-3631:
Summary: CodeGenerator does not check type compatibility for
equality expressions
Key: FLINK-3631
URL: https://issues.apache.org/jira/browse/FLINK-3631
Project:
Fabian Hueske created FLINK-3609:
Summary: Revisit selection of Calcite rules
Key: FLINK-3609
URL: https://issues.apache.org/jira/browse/FLINK-3609
Project: Flink
Issue Type: Task
Fabian Hueske created FLINK-3604:
Summary: Enable ignored Table API tests
Key: FLINK-3604
URL: https://issues.apache.org/jira/browse/FLINK-3604
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-3603:
Summary: Re-enable Table API explain
Key: FLINK-3603
URL: https://issues.apache.org/jira/browse/FLINK-3603
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-3597:
Summary: Table API operator names should reflect relational
expression
Key: FLINK-3597
URL: https://issues.apache.org/jira/browse/FLINK-3597
Project: Flink
Fabian Hueske created FLINK-3537:
Summary: Faulty code generation for disjunctions
Key: FLINK-3537
URL: https://issues.apache.org/jira/browse/FLINK-3537
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-3490:
Summary: Bump Chill version to 0.7.4
Key: FLINK-3490
URL: https://issues.apache.org/jira/browse/FLINK-3490
Project: Flink
Issue Type: Task
Fabian Hueske created FLINK-3480:
Summary: Add hash-based strategy for ReduceFunction
Key: FLINK-3480
URL: https://issues.apache.org/jira/browse/FLINK-3480
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3479:
Summary: Add hash-based strategy for CombineFunction
Key: FLINK-3479
URL: https://issues.apache.org/jira/browse/FLINK-3479
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3477:
Summary: Add hash-based combine strategy for ReduceFunction
Key: FLINK-3477
URL: https://issues.apache.org/jira/browse/FLINK-3477
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3367:
Summary: Annotate all user-facing API classes with @Public or
@PublicEvolving
Key: FLINK-3367
URL: https://issues.apache.org/jira/browse/FLINK-3367
Project: Flink
Fabian Hueske created FLINK-3366:
Summary: Rename @Experimental annotation to @PublicEvolving
Key: FLINK-3366
URL: https://issues.apache.org/jira/browse/FLINK-3366
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3254:
Summary: CombineFunction interface not respected
Key: FLINK-3254
URL: https://issues.apache.org/jira/browse/FLINK-3254
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-3233:
Summary: PartitionOperator does not support expression keys on
atomic types
Key: FLINK-3233
URL: https://issues.apache.org/jira/browse/FLINK-3233
Project: Flink
Fabian Hueske created FLINK-3221:
Summary: Move Table API on top of Apache Calcite
Key: FLINK-3221
URL: https://issues.apache.org/jira/browse/FLINK-3221
Project: Flink
Issue Type: Task
Fabian Hueske created FLINK-3223:
Summary: Translate Table API query into logical relational plans
for Apache Calcite
Key: FLINK-3223
URL: https://issues.apache.org/jira/browse/FLINK-3223
Project:
Fabian Hueske created FLINK-3225:
Summary: Optimize logical Table API plans in Calcite
Key: FLINK-3225
URL: https://issues.apache.org/jira/browse/FLINK-3225
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3226:
Summary: Translate optimized logical Table API plans into physical
plans representing DataSet programs
Key: FLINK-3226
URL: https://issues.apache.org/jira/browse/FLINK-3226
Fabian Hueske created FLINK-3227:
Summary: Translate physical Table API plan into DataSet program
Key: FLINK-3227
URL: https://issues.apache.org/jira/browse/FLINK-3227
Project: Flink
Issue
Fabian Hueske created FLINK-3198:
Summary: Rename Grouping.getDataSet() method and add JavaDocs
Key: FLINK-3198
URL: https://issues.apache.org/jira/browse/FLINK-3198
Project: Flink
Issue
Fabian Hueske created FLINK-3186:
Summary: Deprecate DataSink.sortLocalOutput() methods
Key: FLINK-3186
URL: https://issues.apache.org/jira/browse/FLINK-3186
Project: Flink
Issue Type: Task
Fabian Hueske created FLINK-3135:
Summary: Add chainable driver for UNARY_NO_OP strategy
Key: FLINK-3135
URL: https://issues.apache.org/jira/browse/FLINK-3135
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3113:
Summary: Remove unused global order methods from
GenericDataSinkBase
Key: FLINK-3113
URL: https://issues.apache.org/jira/browse/FLINK-3113
Project: Flink
Fabian Hueske created FLINK-3112:
Summary: Remove unused RecordModelPostPass class
Key: FLINK-3112
URL: https://issues.apache.org/jira/browse/FLINK-3112
Project: Flink
Issue Type: Task
Fabian Hueske created FLINK-3039:
Summary: Trigger KeyValueState cannot be Scala Int
Key: FLINK-3039
URL: https://issues.apache.org/jira/browse/FLINK-3039
Project: Flink
Issue Type:
Fabian Hueske created FLINK-3010:
Summary: Add link to powered-by wiki page to project website
Key: FLINK-3010
URL: https://issues.apache.org/jira/browse/FLINK-3010
Project: Flink
Issue
Fabian Hueske created FLINK-2999:
Summary: Support connected keyed streams
Key: FLINK-2999
URL: https://issues.apache.org/jira/browse/FLINK-2999
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-2972:
Summary: Remove Twitter Chill dependency from flink-java module
Key: FLINK-2972
URL: https://issues.apache.org/jira/browse/FLINK-2972
Project: Flink
Issue
Fabian Hueske created FLINK-2973:
Summary: Remove OpenJDK JMH dependency from flink-benchmark
Key: FLINK-2973
URL: https://issues.apache.org/jira/browse/FLINK-2973
Project: Flink
Issue Type:
Fabian Hueske created FLINK-2953:
Summary: Chained sortPartition() calls produce incorrect results
in Scala DataSet API
Key: FLINK-2953
URL: https://issues.apache.org/jira/browse/FLINK-2953
Project:
Fabian Hueske created FLINK-2944:
Summary: Collect, expose and display operator-specific stats
Key: FLINK-2944
URL: https://issues.apache.org/jira/browse/FLINK-2944
Project: Flink
Issue
Fabian Hueske created FLINK-2945:
Summary: Shutting down a local Flink instance on Windows doesn't
clean up blob cache
Key: FLINK-2945
URL: https://issues.apache.org/jira/browse/FLINK-2945
Project:
Fabian Hueske created FLINK-2942:
Summary: Dangling operators in web UI's program visualization
Key: FLINK-2942
URL: https://issues.apache.org/jira/browse/FLINK-2942
Project: Flink
Issue
Fabian Hueske created FLINK-2943:
Summary: Confusing Bytes/Records "read" and "write" labels in
WebUI job view
Key: FLINK-2943
URL: https://issues.apache.org/jira/browse/FLINK-2943
Project: Flink
Fabian Hueske created FLINK-2936:
Summary: ClassCastException when using EventTimeSourceFunction in
non-EventTime program
Key: FLINK-2936
URL: https://issues.apache.org/jira/browse/FLINK-2936
Fabian Hueske created FLINK-2900:
Summary: Remove Record-API dependencies from Hadoop Compat module
Key: FLINK-2900
URL: https://issues.apache.org/jira/browse/FLINK-2900
Project: Flink
Issue
Fabian Hueske created FLINK-2901:
Summary: Several flink-test ITCases depend on Record API features
Key: FLINK-2901
URL: https://issues.apache.org/jira/browse/FLINK-2901
Project: Flink
Issue
Fabian Hueske created FLINK-2843:
Summary: Add documentation for DataSet outer joins
Key: FLINK-2843
URL: https://issues.apache.org/jira/browse/FLINK-2843
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-2842:
Summary: S3FileSystem is broken
Key: FLINK-2842
URL: https://issues.apache.org/jira/browse/FLINK-2842
Project: Flink
Issue Type: Bug
Affects Versions:
Fabian Hueske created FLINK-2773:
Summary: OutOfMemoryError on YARN Session
Key: FLINK-2773
URL: https://issues.apache.org/jira/browse/FLINK-2773
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-2757:
Summary: DataSinkTaskTest fails on Windows
Key: FLINK-2757
URL: https://issues.apache.org/jira/browse/FLINK-2757
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-2758:
Summary: TaskManagerRegistrationTest fails on Windows
Key: FLINK-2758
URL: https://issues.apache.org/jira/browse/FLINK-2758
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-2759:
Summary: TaskManagerProcessReapingTest fails on Windows
Key: FLINK-2759
URL: https://issues.apache.org/jira/browse/FLINK-2759
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-2749:
Summary: CliFrontendAddressConfigurationTest fails on GCE
Key: FLINK-2749
URL: https://issues.apache.org/jira/browse/FLINK-2749
Project: Flink
Issue Type:
Fabian Hueske created FLINK-2750:
Summary: FileStateHandleTest fails when building for Hadoop 2.6.0
Key: FLINK-2750
URL: https://issues.apache.org/jira/browse/FLINK-2750
Project: Flink
Issue
Fabian Hueske created FLINK-2689:
Summary: Reusing null object for joins with SolutionSet
Key: FLINK-2689
URL: https://issues.apache.org/jira/browse/FLINK-2689
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-2637:
Summary: Add abstract equals, hashCode and toString methods to
TypeInformation
Key: FLINK-2637
URL: https://issues.apache.org/jira/browse/FLINK-2637
Project: Flink
Fabian Hueske created FLINK-2442:
Summary: PojoType fields not supported by field position keys
Key: FLINK-2442
URL: https://issues.apache.org/jira/browse/FLINK-2442
Project: Flink
Issue
Fabian Hueske created FLINK-2445:
Summary: Add tests for HadoopOutputFormats
Key: FLINK-2445
URL: https://issues.apache.org/jira/browse/FLINK-2445
Project: Flink
Issue Type: Test
Fabian Hueske created FLINK-2435:
Summary: Add support for custom CSV field parsers
Key: FLINK-2435
URL: https://issues.apache.org/jira/browse/FLINK-2435
Project: Flink
Issue Type: New
Fabian Hueske created FLINK-2362:
Summary: distinct is missing in DataSet API documentation
Key: FLINK-2362
URL: https://issues.apache.org/jira/browse/FLINK-2362
Project: Flink
Issue Type:
Fabian Hueske created FLINK-2353:
Summary: Hadoop mapred IOFormat wrappers do not respect
JobConfigurable interface
Key: FLINK-2353
URL: https://issues.apache.org/jira/browse/FLINK-2353
Project:
Fabian Hueske created FLINK-2280:
Summary: GenericTypeComparator.compare() does not respect
ascending flag
Key: FLINK-2280
URL: https://issues.apache.org/jira/browse/FLINK-2280
Project: Flink
Fabian Hueske created FLINK-2206:
Summary: JobManager webinterface shows 5 finished jobs at most
Key: FLINK-2206
URL: https://issues.apache.org/jira/browse/FLINK-2206
Project: Flink
Issue
Fabian Hueske created FLINK-2205:
Summary: Confusing entries in JM Webfrontend Job Configuration
section
Key: FLINK-2205
URL: https://issues.apache.org/jira/browse/FLINK-2205
Project: Flink
Fabian Hueske created FLINK-2198:
Summary: Build fails on Windows
Key: FLINK-2198
URL: https://issues.apache.org/jira/browse/FLINK-2198
Project: Flink
Issue Type: Bug
Components:
Fabian Hueske created FLINK-2192:
Summary: ComplexIntegrationTest.complexIntegrationTest1 fails
Key: FLINK-2192
URL: https://issues.apache.org/jira/browse/FLINK-2192
Project: Flink
Issue
Fabian Hueske created FLINK-2165:
Summary: Rename Table conversion methods in TableEnvironment
Key: FLINK-2165
URL: https://issues.apache.org/jira/browse/FLINK-2165
Project: Flink
Issue
Fabian Hueske created FLINK-2167:
Summary: Add fromHCat() to TableEnvironment
Key: FLINK-2167
URL: https://issues.apache.org/jira/browse/FLINK-2167
Project: Flink
Issue Type: New Feature
Fabian Hueske created FLINK-2170:
Summary: Add fromOrcFile() to TableEnvironment
Key: FLINK-2170
URL: https://issues.apache.org/jira/browse/FLINK-2170
Project: Flink
Issue Type: New Feature
Fabian Hueske created FLINK-2169:
Summary: Add fromParquet() to TableEnvironment
Key: FLINK-2169
URL: https://issues.apache.org/jira/browse/FLINK-2169
Project: Flink
Issue Type: New Feature
Fabian Hueske created FLINK-2168:
Summary: Add fromHBase() to TableEnvironment
Key: FLINK-2168
URL: https://issues.apache.org/jira/browse/FLINK-2168
Project: Flink
Issue Type: New Feature
Fabian Hueske created FLINK-2171:
Summary: Add instruction to build Flink with Scala 2.11
Key: FLINK-2171
URL: https://issues.apache.org/jira/browse/FLINK-2171
Project: Flink
Issue Type:
Fabian Hueske created FLINK-2118:
Summary: Table API fails on composite filter conditions
Key: FLINK-2118
URL: https://issues.apache.org/jira/browse/FLINK-2118
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-2115:
Summary: TableAPI throws ExpressionException for Dangling GroupBy
operation
Key: FLINK-2115
URL: https://issues.apache.org/jira/browse/FLINK-2115
Project: Flink
Fabian Hueske created FLINK-2106:
Summary: Add outer joins to API, Optimizer, and Runtime
Key: FLINK-2106
URL: https://issues.apache.org/jira/browse/FLINK-2106
Project: Flink
Issue Type:
Fabian Hueske created FLINK-2107:
Summary: Implement Hash Outer Join algorithm
Key: FLINK-2107
URL: https://issues.apache.org/jira/browse/FLINK-2107
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-2095:
Summary: Screenshots missing in webcient documentation
Key: FLINK-2095
URL: https://issues.apache.org/jira/browse/FLINK-2095
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-2061:
Summary: CSVReader: quotedStringParsing and includeFields yields
ParseException
Key: FLINK-2061
URL: https://issues.apache.org/jira/browse/FLINK-2061
Project: Flink
Fabian Hueske created FLINK-2042:
Summary: Increase font size for stack figure on website home
Key: FLINK-2042
URL: https://issues.apache.org/jira/browse/FLINK-2042
Project: Flink
Issue
Fabian Hueske created FLINK-2031:
Summary: Missing images in blog posts
Key: FLINK-2031
URL: https://issues.apache.org/jira/browse/FLINK-2031
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-2020:
Summary: Table API JoinITCase fails non-deterministically
Key: FLINK-2020
URL: https://issues.apache.org/jira/browse/FLINK-2020
Project: Flink
Issue Type:
Fabian Hueske created FLINK-1998:
Summary: Equality filter predicate not correctly evaluated by
Table API
Key: FLINK-1998
URL: https://issues.apache.org/jira/browse/FLINK-1998
Project: Flink
Fabian Hueske created FLINK-1997:
Summary: Neither nor != supported for non-equals predicates
in .filter()
Key: FLINK-1997
URL: https://issues.apache.org/jira/browse/FLINK-1997
Project: Flink
Fabian Hueske created FLINK-1991:
Summary: Return Table as DataSetTuple
Key: FLINK-1991
URL: https://issues.apache.org/jira/browse/FLINK-1991
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-1990:
Summary: Uppercase AS keyword not allowed in select expression
Key: FLINK-1990
URL: https://issues.apache.org/jira/browse/FLINK-1990
Project: Flink
Issue
Fabian Hueske created FLINK-1989:
Summary: Sorting of POJO data set from TableEnv yields
NotSerializableException
Key: FLINK-1989
URL: https://issues.apache.org/jira/browse/FLINK-1989
Project: Flink
Fabian Hueske created FLINK-1963:
Summary: Improve distinct() transformation
Key: FLINK-1963
URL: https://issues.apache.org/jira/browse/FLINK-1963
Project: Flink
Issue Type: Improvement
Fabian Hueske created FLINK-1919:
Summary: Add HCatOutputFormat for Tuple data types
Key: FLINK-1919
URL: https://issues.apache.org/jira/browse/FLINK-1919
Project: Flink
Issue Type: New
Fabian Hueske created FLINK-1848:
Summary: Paths containing a Windows drive letter cannot be used in
FileOutputFormats
Key: FLINK-1848
URL: https://issues.apache.org/jira/browse/FLINK-1848
Project:
Fabian Hueske created FLINK-1841:
Summary: WindowJoinITCase fails
Key: FLINK-1841
URL: https://issues.apache.org/jira/browse/FLINK-1841
Project: Flink
Issue Type: Bug
Components:
Fabian Hueske created FLINK-1819:
Summary: Allow access to RuntimeContext from Input and
OutputFormats
Key: FLINK-1819
URL: https://issues.apache.org/jira/browse/FLINK-1819
Project: Flink
201 - 300 of 313 matches
Mail list logo
