xiaojin.wy created FLINK-15289:
--
Summary: Run sql appear error of "Zero-length character strings
have no serializable string representation".
Key: FLINK-15289
URL: https://issues.apache.org/jira/browse/FLINK-15289
Hi Becket,
I completely agree with Dawid's suggestion. The information about the
boundedness should come out of the source. Because most of the streaming
sources can be made bounded based on some connector specific criterion.
In Kafka, it would be an end offset or end timestamp but in any
Hi community,
After running tpc-ds test suite for several days on a session cluster, we
found a resource leak problem of OrcInputFormat which was reported in
FLINK-15239. The problem comes from the dependent third party library which
creates new internal thread (pool) and never release it. As a
Yang Wang created FLINK-15288:
-
Summary: Starting jobmanager pod should respect
containerized.heap-cutoff
Key: FLINK-15288
URL: https://issues.apache.org/jira/browse/FLINK-15288
Project: Flink
Rui Li created FLINK-15287:
--
Summary: Vectorized orc reader fails with Hive 2.0.1
Key: FLINK-15287
URL: https://issues.apache.org/jira/browse/FLINK-15287
Project: Flink
Issue Type: Bug
Hi jingjing,
Please leave comment under the JIRA issue[1] to keep the discussion in one
place.
Thanks,
Jark
[1]: https://issues.apache.org/jira/browse/FLINK-15283
On Mon, 16 Dec 2019 at 23:00, jingjing bai
wrote:
>-
>
>I think you might have misunderstood the sink schema. It is a
Hello,
I would like to understand options available to design an ingestion pipeline to
support the following requirements.
1) Events are coming from various sources and depending on the type of the
events it will be stored in specific Kafka topics (say we have 4 topics)
2) The events that are
Stephan Ewen created FLINK-15286:
Summary: Managed Memory Option for RocksDB not picked up from
config
Key: FLINK-15286
URL: https://issues.apache.org/jira/browse/FLINK-15286
Project: Flink
This discussion is a follow up to the previous thread on dropping
vendor-specific documentation[1].
The conversation ended unresolved on the question of what we should provide
on the Apache Flink docs. The consensus seemed to be moving towards
offering a table with links to 3rd parties. After an
-
I think you might have misunderstood the sink schema. It is a order
field but not json (or mapping) field in table sink ddl. At least that's
the case in Sql.
-
for exemple. DDL sink schema as and
the sql is insert into table select A, C ,B from t2。
-
A ,B
I found that the format of the mail was out of order. Please look at the
document:
https://docs.google.com/document/d/1jCKan5LGlkBZr2seUdwTsy-biu8Sz0xyQwqizCUZ2uk/edit?usp=sharing
Best,
Haibo
At 2019-12-16 21:29:15, "Haibo Sun" wrote:
>Hi, all
>
>
>I want to bring up a discussion about how
Hi, all
I want to bring up a discussion about how to deal with the pending(registered
but not scheduled for execution)
timers better before closing operator.
Introduction: From my understanding, there are two types of timers in Flink: 1)
One is one-shot or periodic
timers registered with
+1 for centralizing all the documentation issues so that the community can
take more effective to fix them.
Best,
Vino
Xintong Song 于2019年12月16日周一 下午6:02写道：
> Thank you Kostas.
> Big +1 for keeping all the documentation related issues at one place.
>
> I've added the documentation task for
Gary Yao created FLINK-15285:
Summary: Resuming Externalized Checkpoint (file, async, no
parallelism change) E2E test fails on Travis
Key: FLINK-15285
URL: https://issues.apache.org/jira/browse/FLINK-15285
xiaojin.wy created FLINK-15284:
--
Summary: Sql error (Failed to push project into table source!)
Key: FLINK-15284
URL: https://issues.apache.org/jira/browse/FLINK-15284
Project: Flink
Issue
Thank you Kostas.
Big +1 for keeping all the documentation related issues at one place.
I've added the documentation task for resource management.
Thank you~
Xintong Song
On Mon, Dec 16, 2019 at 5:29 PM Kostas Kloudas wrote:
> Hi all,
>
> With the feature-freeze for the release-1.10
roland wang created FLINK-15283:
---
Summary: Scala version of TableSinkUtils has a problem when
validating sinks.
Key: FLINK-15283
URL: https://issues.apache.org/jira/browse/FLINK-15283
Project: Flink
Jark Wu created FLINK-15282:
---
Summary: Remove ParameterScope in blink planner
Key: FLINK-15282
URL: https://issues.apache.org/jira/browse/FLINK-15282
Project: Flink
Issue Type: Sub-task
Hi all,
With the feature-freeze for the release-1.10 already past us, it is
time to focus a little bit on documenting the new features that the
community added to this release, and improving the already existing
documentation based on questions that we see in Flink's mailing lists.
To this end,
Timo Walther created FLINK-15281:
Summary: Map Flink's TypeInference to Calcite's interfaces
Key: FLINK-15281
URL: https://issues.apache.org/jira/browse/FLINK-15281
Project: Flink
Issue
wangxiyuan created FLINK-15280:
--
Summary: Checkpoint end-to-end test failed
Key: FLINK-15280
URL: https://issues.apache.org/jira/browse/FLINK-15280
Project: Flink
Issue Type: Bug
Kostas Kloudas created FLINK-15279:
--
Summary: Document new `executeAsync()` method and the newly
introduced `JobClient`
Key: FLINK-15279
URL: https://issues.apache.org/jira/browse/FLINK-15279
Kostas Kloudas created FLINK-15278:
--
Summary: Update StreamingFileSink documentation
Key: FLINK-15278
URL: https://issues.apache.org/jira/browse/FLINK-15278
Project: Flink
Issue Type:
Danny Chen created FLINK-15277:
--
Summary: Update SQL DDL document to add syntax and example of
computed column
Key: FLINK-15277
URL: https://issues.apache.org/jira/browse/FLINK-15277
Project: Flink
Kostas Kloudas created FLINK-15276:
--
Summary: Update CLI documentation to reflect the addition of the
ExecutorCLI
Key: FLINK-15276
URL: https://issues.apache.org/jira/browse/FLINK-15276
Project:
Kostas Kloudas created FLINK-15275:
--
Summary: Update CLI documentation to include only current valid
options
Key: FLINK-15275
URL: https://issues.apache.org/jira/browse/FLINK-15275
Project: Flink
Kostas Kloudas created FLINK-15274:
--
Summary: Update Filesystem documentation to reflect changes in
shading
Key: FLINK-15274
URL: https://issues.apache.org/jira/browse/FLINK-15274
Project: Flink
Kostas Kloudas created FLINK-15273:
--
Summary: Complete and Update Documentation
Key: FLINK-15273
URL: https://issues.apache.org/jira/browse/FLINK-15273
Project: Flink
Issue Type: Bug
Congrats Zhu Zhu!
On Mon, Dec 16, 2019 at 8:10 AM Xintong Song wrote:
> Congratulations Zhu Zhu~
>
> Thank you~
>
> Xintong Song
>
>
>
> On Mon, Dec 16, 2019 at 12:34 PM Danny Chan wrote:
>
> > Congrats Zhu Zhu!
> >
> > Best,
> > Danny Chan
> > 在 2019年12月14日 +0800
Jingsong Lee created FLINK-15272:
Summary: Better error message when insert partition with values
Key: FLINK-15272
URL: https://issues.apache.org/jira/browse/FLINK-15272
Project: Flink
Issue
30 matches
Mail list logo
