Timo Walther created FLINK-11066:
Summary: Migrate main Table API classes to flink-table-api-base
Key: FLINK-11066
URL: https://issues.apache.org/jira/browse/FLINK-11066
Project: Flink
Issue
Timo Walther created FLINK-11065:
Summary: Migrate flink-table runtime classes
Key: FLINK-11065
URL: https://issues.apache.org/jira/browse/FLINK-11065
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-11064:
Summary: Setup a new flink-table module structure
Key: FLINK-11064
URL: https://issues.apache.org/jira/browse/FLINK-11064
Project: Flink
Issue Type: Sub
Timo Walther created FLINK-11063:
Summary: Make flink-table Scala-free
Key: FLINK-11063
URL: https://issues.apache.org/jira/browse/FLINK-11063
Project: Flink
Issue Type: New Feature
Thanks for being the release manager Till and thanks for the great work
Flink community!
Regards,
Timo
Am 30.11.18 um 10:39 schrieb Till Rohrmann:
The Apache Flink community is very happy to announce the release of Apache
Flink 1.7.0, which is the next major release.
Apache Flink® is an
Timo Walther created FLINK-11036:
Summary: Streaming classloader end-to-end test does not work on
source releases
Key: FLINK-11036
URL: https://issues.apache.org/jira/browse/FLINK-11036
Project
n one file each time,
let other people have more time to resolve the conflicts.
Best,
Kurt
On Tue, Nov 27, 2018 at 8:37 PM Timo Walther wrote:
Hi Kurt,
I understand your concerns. However, there is no concrete roadmap for
Flink 2.0 and (as Vino said) the flink-table is developed very actively
Timo Walther created FLINK-11020:
Summary: Reorder joins only to eliminate cross joins
Key: FLINK-11020
URL: https://issues.apache.org/jira/browse/FLINK-11020
Project: Flink
Issue Type
nt to change program language.
Best,
Kurt
On Tue, Nov 27, 2018 at 5:57 PM Timo Walther wrote:
Hi Hequn,
thanks for your feedback. Yes, migrating the test cases is another issue
that is not represented in the document but should naturally go along
with the migration.
I agree that we should
://issues.apache.org/jira/browse/FLINK-11001
On Fri, Nov 23, 2018 at 5:36 PM Timo Walther wrote:
Hi everyone,
thanks for the great feedback so far. I updated the document with the
input I got so far
@Fabian: I moved the porting of flink-table-runtime classes up in the
list.
@Xiaowei: Could you
Timo Walther created FLINK-11011:
Summary: Elasticsearch 6 sink end-to-end test unstable
Key: FLINK-11011
URL: https://issues.apache.org/jira/browse/FLINK-11011
Project: Flink
Issue Type
Thanks for offering your help here, Xuefu. It would be great to move
these efforts forward. I agree that the DDL is somehow releated to the
unified connector API design but we can also start with the basic
functionality now and evolve the DDL during this release and next releases.
For
e) independent of the API and
planner modules, we could start porting these classes once the code is
split into the new module structure.
The benefits of a Scala-free flink-table-runtime would be a Scala-free
execution Jar.
Best, Fabian
Am Do., 22. Nov. 2018 um 10:54 Uhr schrieb Timo Walther <
twal...
res written in Java and so that they can coexist with old
Scala code until we gradually switch from Scala to Java.
Piotrek
On 13 Jun 2018, at 11:32, Timo Walther wrote:
Hi everyone,
as you all know, currently the Table & SQL API is implemented in
Scala.
This decision was made a long-t
Timo Walther created FLINK-10927:
Summary: Resuming Externalized Checkpoint (r, inc, up) test
instable
Key: FLINK-10927
URL: https://issues.apache.org/jira/browse/FLINK-10927
Project: Flink
Welcome to the Flink community!
I gave you contributor permissions.
Regards,
Timo
Am 13.11.18 um 14:09 schrieb Shuiqiang Chen:
Hi guys:
Could somebody give me contributor permissions? my jira username is :
csq.
Thanks.
Timo Walther created FLINK-10859:
Summary: Queryable state (rocksdb) end-to-end test fails on Travis
Key: FLINK-10859
URL: https://issues.apache.org/jira/browse/FLINK-10859
Project: Flink
Timo Walther created FLINK-10847:
Summary: Add support for IS NOT DISTINCT FROM in code generator
Key: FLINK-10847
URL: https://issues.apache.org/jira/browse/FLINK-10847
Project: Flink
Issue
Timo Walther created FLINK-10846:
Summary: Add support for IS DISTINCT FROM in code generator
Key: FLINK-10846
URL: https://issues.apache.org/jira/browse/FLINK-10846
Project: Flink
Issue
Timo Walther created FLINK-10845:
Summary: Support DISTINCT aggregates for batch
Key: FLINK-10845
URL: https://issues.apache.org/jira/browse/FLINK-10845
Project: Flink
Issue Type: New
Timo Walther created FLINK-10843:
Summary: Make Kafka version definition more flexible for new Kafka
table factory
Key: FLINK-10843
URL: https://issues.apache.org/jira/browse/FLINK-10843
Project
Timo Walther created FLINK-10825:
Summary: ConnectedComponents test instable on Travis
Key: FLINK-10825
URL: https://issues.apache.org/jira/browse/FLINK-10825
Project: Flink
Issue Type: Bug
Hi Jincheng,
I was also thinking about introducing a process function for the Table
API several times. This would allow to define more complex logic (custom
windows, timers, etc.) embedded into a relational API with schema
awareness and optimization around the black box. Of course this would
Timo Walther created FLINK-10726:
Summary: Streaming SQL end-to-end test fails due to recent
flink-table-common changes
Key: FLINK-10726
URL: https://issues.apache.org/jira/browse/FLINK-10726
Project
Timo Walther created FLINK-10689:
Summary: Port Table API extension points to flink-table-common
Key: FLINK-10689
URL: https://issues.apache.org/jira/browse/FLINK-10689
Project: Flink
Issue
Timo Walther created FLINK-10688:
Summary: Remove flink-table dependencies from flink-connectors
Key: FLINK-10688
URL: https://issues.apache.org/jira/browse/FLINK-10688
Project: Flink
Issue
Timo Walther created FLINK-10687:
Summary: Make flink-formats Scala-free
Key: FLINK-10687
URL: https://issues.apache.org/jira/browse/FLINK-10687
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-10686:
Summary: Introduce a flink-table-common module
Key: FLINK-10686
URL: https://issues.apache.org/jira/browse/FLINK-10686
Project: Flink
Issue Type
Timo Walther created FLINK-10638:
Summary: Invalid table scan resolution for temporal join queries
Key: FLINK-10638
URL: https://issues.apache.org/jira/browse/FLINK-10638
Project: Flink
Timo Walther created FLINK-10568:
Summary: Show correct time attributes when calling
Table.getSchema()
Key: FLINK-10568
URL: https://issues.apache.org/jira/browse/FLINK-10568
Project: Flink
+1
- I built locally and checked the JAR files for suspicious things.
- I went throught the change diff between 4 and 5 as well.
Could not find anything blocking this release.
Thanks,
Timo
Am 10.10.18 um 17:22 schrieb Aljoscha Krettek:
+1
I did
- verify all changes between 4.0 and 5.0
Hi Xuefu,
thanks for your proposal, it is a nice summary. Here are my thoughts to
your list:
1. I think this is also on our current mid-term roadmap. Flink lacks a
poper catalog support for a very long time. Before we can connect
catalogs we need to define how to map all the information
properties is still useful as it can restrict a certain connector to be
only source/sink, for example, we usually want a Kafka topic to be either
read-only or write-only, but not both.
Shuyi
On Mon, Oct 1, 2018 at 1:53 AM Timo Walther wrote:
Hi everyone,
as some of you might have noticed, in the last
age of mapping format fields to fields with a
different name in the schema.
Besides that, all existing functionality is preserved although the syntax
changes a bit.
Best,
Fabian
Am Mo., 1. Okt. 2018 um 10:53 Uhr schrieb Timo Walther :
Hi everyone,
as some of you might have noticed, in the last two relea
Hi everyone,
as some of you might have noticed, in the last two releases we aimed to
unify SQL connectors and make them more modular. The first connectors
and formats have been implemented and are usable via the SQL Client and
Java/Scala/SQL APIs.
However, after writing more
Timo Walther created FLINK-10448:
Summary: VALUES clause is translated into a separate operator per
value
Key: FLINK-10448
URL: https://issues.apache.org/jira/browse/FLINK-10448
Project: Flink
+1 (binding)
- Checked all issues that went into the release (I found two JIRA issue
that have been incorrectly marked)
- Built the source and verify locally successfully
- Run a couple of end-to-end tests successfully
Regards,
Timo
Am 20.09.18 um 11:13 schrieb Tzu-Li (Gordon) Tai:
+1
+1 (binding)
- Checked all issues that went into the release (I found one JIRA issue
that has been incorrectly marked)
- Built from source (On my machine SelfJoinDeadlockITCase is failing due
to a timeout, in the IDE it works correctly. I guess my machine was just
too busy.)
- Run some
Congratulations, Gary!
Timo
Am 07.09.18 um 16:46 schrieb Ufuk Celebi:
Great addition to the committers. Congrats, Gary!
– Ufuk
On Fri, Sep 7, 2018 at 4:45 PM, Kostas Kloudas
wrote:
Congratulations Gary! Well deserved!
Cheers,
Kostas
On Sep 7, 2018, at 4:43 PM, Fabian Hueske wrote:
Timo Walther created FLINK-10273:
Summary: Access composite type fields after a function
Key: FLINK-10273
URL: https://issues.apache.org/jira/browse/FLINK-10273
Project: Flink
Issue Type
Timo Walther created FLINK-10269:
Summary: Elasticsearch UpdateRequest fail because of binary
incompatibility
Key: FLINK-10269
URL: https://issues.apache.org/jira/browse/FLINK-10269
Project: Flink
Timo Walther created FLINK-10265:
Summary: Configure checkpointing behavior for SQL Client
Key: FLINK-10265
URL: https://issues.apache.org/jira/browse/FLINK-10265
Project: Flink
Issue Type
Timo Walther created FLINK-10261:
Summary: INSERT INTO does not work with ORDER BY clause
Key: FLINK-10261
URL: https://issues.apache.org/jira/browse/FLINK-10261
Project: Flink
Issue Type
Timo Walther created FLINK-10258:
Summary: Allow streaming sources to be present for batch
executions
Key: FLINK-10258
URL: https://issues.apache.org/jira/browse/FLINK-10258
Project: Flink
Timo Walther created FLINK-10232:
Summary: Add a SQL DDL
Key: FLINK-10232
URL: https://issues.apache.org/jira/browse/FLINK-10232
Project: Flink
Issue Type: New Feature
Components
Timo Walther created FLINK-10231:
Summary: Support views in Table API
Key: FLINK-10231
URL: https://issues.apache.org/jira/browse/FLINK-10231
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-10230:
Summary: Support printing the query of a view
Key: FLINK-10230
URL: https://issues.apache.org/jira/browse/FLINK-10230
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-10229:
Summary: Support listing of views
Key: FLINK-10229
URL: https://issues.apache.org/jira/browse/FLINK-10229
Project: Flink
Issue Type: New Feature
Hi Eron,
yes, FLINK-9172 covers how the SQL Client will discover ExternalCatalog
similar to how it discovers connectors and formats today. The exact
design has to be fleshed out but the SQL Client's environment file will
declare catalogs and their properties. The SQL Client's gateway will
a problem.
Best,
wangsan
On Aug 21, 2018, at 10:16 PM, Timo Walther wrote:
Hi,
this sounds like a bug to me. Maybe the explain() method is not implemented
correctly. Can you open an issue for it in Jira?
Thanks,
Timo
Am 21.08.18 um 15:04 schrieb wangsan:
Hi all,
I noticed
Hi,
this sounds like a bug to me. Maybe the explain() method is not
implemented correctly. Can you open an issue for it in Jira?
Thanks,
Timo
Am 21.08.18 um 15:04 schrieb wangsan:
Hi all,
I noticed that the DataStreamRel#translateToPlan is non-idempotent, and that
may cause the execution
Timo Walther created FLINK-10173:
Summary: Elasticsearch 6 connector does not package Elasticsearch
Key: FLINK-10173
URL: https://issues.apache.org/jira/browse/FLINK-10173
Project: Flink
Timo Walther created FLINK-10169:
Summary: RowtimeValidator fails with custom TimestampExtractor
Key: FLINK-10169
URL: https://issues.apache.org/jira/browse/FLINK-10169
Project: Flink
Issue
Timo Walther created FLINK-10163:
Summary: Support CREATE VIEW in SQL Client
Key: FLINK-10163
URL: https://issues.apache.org/jira/browse/FLINK-10163
Project: Flink
Issue Type: New Feature
Thank you for starting this discussion.
+1 for this
Regards,
Timo
Am 16.08.18 um 09:27 schrieb vino yang:
Agree! This sounds very good.
Till Rohrmann 于2018年8月16日周四 下午3:14写道：
+1 for starting the release process 1.5.3 immediately. We can always
create another bug fix release afterwards. I
Hi,
I gave you contributor permissions.
Regards,
Timo
Am 10.08.18 um 13:05 schrieb 邓林:
Hi Flink community,
I want to contribute code to Flink, can anyone give me
contribution permission? My JIRA account name is lyndldeng.
Thanks.
Timo Walther created FLINK-10107:
Summary: SQL Client end-to-end test fails for releases
Key: FLINK-10107
URL: https://issues.apache.org/jira/browse/FLINK-10107
Project: Flink
Issue Type
+1
- successfully run `mvn clean verify` locally
- successfully run end-to-end tests locally (except for SQL Client
end-to-end test)
Found a bug in the class loading of SQL JAR files. This is not a blocker
but a bug that we should fix soon. As an easy workaround user should not
use
Timo Walther created FLINK-10073:
Summary: Allow setting a restart strategy in SQL Client
Key: FLINK-10073
URL: https://issues.apache.org/jira/browse/FLINK-10073
Project: Flink
Issue Type
Timo Walther created FLINK-10071:
Summary: Document usage of INSERT INTO in SQL Client
Key: FLINK-10071
URL: https://issues.apache.org/jira/browse/FLINK-10071
Project: Flink
Issue Type
Timo Walther created FLINK-10062:
Summary: Docs are not built due to git-commit-id-plugin
Key: FLINK-10062
URL: https://issues.apache.org/jira/browse/FLINK-10062
Project: Flink
Issue Type
Hi Sampath,
I added you as a contributor. You can now assign issues to yourself.
Regards,
Timo
Am 03.08.18 um 11:42 schrieb Sampath Bhat:
Hello Till
Could you please add sampathBhat to the list of contributors in JIRA.
Thank you
Sampath
On Fri, Aug 3, 2018 at 1:18 PM, Till Rohrmann wrote:
Timo Walther created FLINK-10031:
Summary: Support handling late events in Table API & SQL
Key: FLINK-10031
URL: https://issues.apache.org/jira/browse/FLINK-10031
Project: Flink
Issue
Timo Walther created FLINK-10017:
Summary: Support keyed formats for Kafka table source sink factory
Key: FLINK-10017
URL: https://issues.apache.org/jira/browse/FLINK-10017
Project: Flink
Hi,
the Maven enforcer plugin produced invalid errors under certain
conditions. See also the discussion here [1]. If you start the build
again, it should succeed. This issue is fixed in 1.5.2.
Regards,
Timo
[1] https://issues.apache.org/jira/browse/FLINK-9091
Am 01.08.18 um 11:26 schrieb
Thanks for managing the release process Chesnay!
Timo
Am 31.07.18 um 10:05 schrieb Chesnay Schepler:
I'm happy to announce that we have approved this release.
There are 5 approving votes, 3 of which are binding:
* Yaz (non-binding)
* Thomas (non-binding)
* Till (binding)
* Timo (binding)
*
+1
- run a couple of programs from the Web UI
- run SQL Client table programs (failing and non-failing)
- run a couple end-to-end tests on my local machine
Caveat: The test_streaming_classloader.sh does not work on releases. But
this is a bug in the test, not in the release (see FLINK-9987).
Timo Walther created FLINK-9984:
---
Summary: Add a byte array table format factory
Key: FLINK-9984
URL: https://issues.apache.org/jira/browse/FLINK-9984
Project: Flink
Issue Type: Sub-task
I tried to reproduce your error but everything worked fine. Which Flink
version are you using?
Inner joins are a Flink 1.5 feature.
Am 27.07.18 um 13:28 schrieb Amol S - iProgrammer:
Table master = table1.filter("ns === 'Master'").select("o as master,
'accessBasicDBObject(applicationId,o)'
.**Phone: +91 9689077510 | Skype: amols_iprogrammer*
www.iprogrammer.com
On Fri, Jul 27, 2018 at 1:08 PM, Timo Walther wrote:
Hi Amol,
the dot operation is reserved for calling functions on fields. If you want
to get a nested field in the Table API
Timo Walther created FLINK-9979:
---
Summary: Support a custom FlinkKafkaPartitioner for a Kafka table
sink factory
Key: FLINK-9979
URL: https://issues.apache.org/jira/browse/FLINK-9979
Project: Flink
Hi Amol,
the dot operation is reserved for calling functions on fields. If you
want to get a nested field in the Table API, use the
`.get("applicationId")` operation. See also [1] under "Value access
functions".
Regards,
Timo
[1]
I agree with Chesnay. Only regressions in the release candidate should
cancel minor releases.
Timo
Am 26.07.18 um 15:02 schrieb Chesnay Schepler:
Since the regression already existed in 1.5.0 I will not cancel the vote,
as there's no benefit to canceling the bugfix release.
If a fix is
Timo Walther created FLINK-9966:
---
Summary: Add a ORC table factory
Key: FLINK-9966
URL: https://issues.apache.org/jira/browse/FLINK-9966
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-9965:
---
Summary: Support schema derivation in Avro table format factory
Key: FLINK-9965
URL: https://issues.apache.org/jira/browse/FLINK-9965
Project: Flink
Issue
Timo Walther created FLINK-9964:
---
Summary: Add a CSV table format factory
Key: FLINK-9964
URL: https://issues.apache.org/jira/browse/FLINK-9964
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-9963:
---
Summary: Create a string table format factory
Key: FLINK-9963
URL: https://issues.apache.org/jira/browse/FLINK-9963
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-9947:
---
Summary: Document unified table sources/sinks/formats
Key: FLINK-9947
URL: https://issues.apache.org/jira/browse/FLINK-9947
Project: Flink
Issue Type
Timo Walther created FLINK-9948:
---
Summary: JSON format does not convert timestamps correctly
Key: FLINK-9948
URL: https://issues.apache.org/jira/browse/FLINK-9948
Project: Flink
Issue Type
Timo Walther created FLINK-9934:
---
Summary: Kafka table source factory produces invalid field mapping
Key: FLINK-9934
URL: https://issues.apache.org/jira/browse/FLINK-9934
Project: Flink
Issue
Timo Walther created FLINK-9886:
---
Summary: Build SQL jars with every build
Key: FLINK-9886
URL: https://issues.apache.org/jira/browse/FLINK-9886
Project: Flink
Issue Type: Improvement
Hi Titus,
have you looked into ProcessFunction? ProcessFunction[1] gives you
access to the two important streaming primitives "time" and "state".
So in your case you can decide flexibly what you want to put into state
and when you want to set and fire a timer (for clean-up) per key.
Timo Walther created FLINK-9870:
---
Summary: Support field mapping and time attributes for table sinks
Key: FLINK-9870
URL: https://issues.apache.org/jira/browse/FLINK-9870
Project: Flink
Issue
Timo Walther created FLINK-9864:
---
Summary: Make timestamp extraction more flexible in SQL Client
Key: FLINK-9864
URL: https://issues.apache.org/jira/browse/FLINK-9864
Project: Flink
Issue Type
Timo Walther created FLINK-9863:
---
Summary: Add a built-in ingestion time TS extractor
Key: FLINK-9863
URL: https://issues.apache.org/jira/browse/FLINK-9863
Project: Flink
Issue Type: New
Timo Walther created FLINK-9855:
---
Summary: KeyedStream.IntervalJoined#process does not work for
lambdas
Key: FLINK-9855
URL: https://issues.apache.org/jira/browse/FLINK-9855
Project: Flink
Timo Walther created FLINK-9854:
---
Summary: Allow passing multi-line input to SQL Client CLI
Key: FLINK-9854
URL: https://issues.apache.org/jira/browse/FLINK-9854
Project: Flink
Issue Type: Sub
Timo Walther created FLINK-9852:
---
Summary: Expose descriptor-based sink creation in table
environments
Key: FLINK-9852
URL: https://issues.apache.org/jira/browse/FLINK-9852
Project: Flink
Timo Walther created FLINK-9851:
---
Summary: Add documentation for unified table sources/sinks
Key: FLINK-9851
URL: https://issues.apache.org/jira/browse/FLINK-9851
Project: Flink
Issue Type
Timo Walther created FLINK-9846:
---
Summary: Add a Kafka table sink factory
Key: FLINK-9846
URL: https://issues.apache.org/jira/browse/FLINK-9846
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-9833:
---
Summary: Add a SQL Client end-to-end test
Key: FLINK-9833
URL: https://issues.apache.org/jira/browse/FLINK-9833
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-9790:
---
Summary: Add documentation for UDF in SQL Client
Key: FLINK-9790
URL: https://issues.apache.org/jira/browse/FLINK-9790
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-9775:
---
Summary: BucketingSink E2E test fails in certain environments
Key: FLINK-9775
URL: https://issues.apache.org/jira/browse/FLINK-9775
Project: Flink
Issue Type
Timo Walther created FLINK-9774:
---
Summary: Allow to pass a string-based cluster identifier to
command line
Key: FLINK-9774
URL: https://issues.apache.org/jira/browse/FLINK-9774
Project: Flink
Timo Walther created FLINK-9765:
---
Summary: Improve CLI responsiveness when cluster is not reachable
Key: FLINK-9765
URL: https://issues.apache.org/jira/browse/FLINK-9765
Project: Flink
Issue
Timo Walther created FLINK-9740:
---
Summary: Support group windows over intervals of months
Key: FLINK-9740
URL: https://issues.apache.org/jira/browse/FLINK-9740
Project: Flink
Issue Type: New
Timo Walther created FLINK-9578:
---
Summary: Allow to define an auto watermark interval in SQL Client
Key: FLINK-9578
URL: https://issues.apache.org/jira/browse/FLINK-9578
Project: Flink
Issue
Hi everyone,
as you all know, currently the Table & SQL API is implemented in Scala.
This decision was made a long-time ago when the initital code base was
created as part of a master's thesis. The community kept Scala because
of the nice language features that enable a fluent Table API like
Timo Walther created FLINK-9568:
---
Summary: Wrong error handling for batch input formats with invalid
paths
Key: FLINK-9568
URL: https://issues.apache.org/jira/browse/FLINK-9568
Project: Flink
Timo Walther created FLINK-9556:
---
Summary: Scala TypeAnalyzer does not consider ResultTypeQueryable
Key: FLINK-9556
URL: https://issues.apache.org/jira/browse/FLINK-9556
Project: Flink
Issue
901 - 1000 of 1349 matches
Mail list logo
