Hey Xingbo, thanks for driving this release.
+1 (non-binding)
* Signatures look good
* Nexus contains expected files
* All required files on dist.apache.org
* Tag is present in Github
* Verified source archive does not contain any binary files
* Source archive builds using maven
* Added a couple
Timo Walther created FLINK-29309:
Summary: Relax allow-client-job-configurations for Table API and
parameters
Key: FLINK-29309
URL: https://issues.apache.org/jira/browse/FLINK-29309
Project: Flink
Chesnay Schepler created FLINK-29310:
Summary: Setup license checks
Key: FLINK-29310
URL: https://issues.apache.org/jira/browse/FLINK-29310
Project: Flink
Issue Type: Sub-task
C
Nicolas Pocock created FLINK-29311:
--
Summary: Unable to use http for Kinesis consumer when testing
locally
Key: FLINK-29311
URL: https://issues.apache.org/jira/browse/FLINK-29311
Project: Flink
shouzuo meng created FLINK-29312:
Summary: Performance problems encountered when using
StatementSetImpl#addInsertSql in Flink SQL
Key: FLINK-29312
URL: https://issues.apache.org/jira/browse/FLINK-29312
Hey Lincoln,
Thanks for opening the discussion.
To be honest I am not convinced if emitting from close there is a
contract that was envisioned and thus should be maintained. As far as I
can see it does affect only the TableFunction, because it has the
collect method. None of the other UDFs (S
Matyas Orhidi created FLINK-29313:
-
Summary: Some config overrides are ignored when set under
spec.flinkConfiguration
Key: FLINK-29313
URL: https://issues.apache.org/jira/browse/FLINK-29313
Project: F
Hi Ryan and Yu,
> There's quite a bit of existing code and it looks like there's
> interest and community willing to contribute to this connector with 2
> implementations already in the flink-connector-redis repo[1].
Yes, this FLIP is to formalize that the Flink community wants to add this
connec
Hi Dawid, Lincoln,
I would tend to agree with Dawid. It seems to me like `TableFunction` is
the one that needs to be taken care of. Other types of
`UserDefinedFunction` wouldn't be able to emit anything from the `finish()`
even if we added it. And if we added `finish(Collector out)` to them, it
wo
Yes, thanks for pushing this Xingbo.
+1 (non-binding)
* Signatures look good
* Checked out source code from git repository using the tag and diffed it
with the provided sources
* Build source code
* Reviewed flink-web PR
* Started session cluster and submitted WordCount example in batch and
strea
Hello,
over the past week I worked on putting the final things into place to
enable the first release of an externalized elasticsearch connector.
Then it dawned on me that there are a few things we _haven't really
decided yet_, which are rather important though.
Let's fix that.
Note that w
Satyasheel Satyasheel created FLINK-29314:
-
Summary: AskTimeoutException for more than two partition with
FileSource API on S3
Key: FLINK-29314
URL: https://issues.apache.org/jira/browse/FLINK-29314
Chesnay Schepler created FLINK-29315:
Summary: HDFSTest#testBlobServerRecovery fails on CI
Key: FLINK-29315
URL: https://issues.apache.org/jira/browse/FLINK-29315
Project: Flink
Issue Typ
Chesnay Schepler created FLINK-29316:
Summary: Replicate packaging tests
Key: FLINK-29316
URL: https://issues.apache.org/jira/browse/FLINK-29316
Project: Flink
Issue Type: Sub-task
Thanks for starting this discussion. I am working on the early stages of
the new DynamoDB connector and have been pondering the same thing.
a) Makes sense. On the flip side, how many Flink versions will we
support? Right now we support 2 versions for Flink, so it makes sense to
follow this rule.
Hi folks,
I use the following to interact with databases and elasticsearch.
org.apache.flink.connector.jdbc.table.JdbcTableSource
org.apache.flink.streaming.connectors.elasticsearch7.ElasticsearchSink
Do these connectors provide any metrics out of the box? Metrics such as
- QPS to database, Elast
Everyone, we have 2 bounding votes and 2 unbounding votes in our voting
(url: https://lists.apache.org/thread/89f7kwnqgs8mfwos0h6b27lt3xn7383t).
According to the rules, we need at least 3 bound votes to start this FLIP.
If you forget to vote, it doesn't matter, we still have time to vote it,
let's
Shammon created FLINK-29317:
---
Summary: Add WebSocket in Dispatcher to support olap query
submission and push results in session cluster
Key: FLINK-29317
URL: https://issues.apache.org/jira/browse/FLINK-29317
weibo zhao created FLINK-29318:
--
Summary: Add Transformer for PolynomialExpansion
Key: FLINK-29318
URL: https://issues.apache.org/jira/browse/FLINK-29318
Project: Flink
Issue Type: New Feature
19 matches
Mail list logo
