Jing Zhang created FLINK-12017:
--
Summary: Support to run a sql query : 'SELECT * FROM source'
Key: FLINK-12017
URL: https://issues.apache.org/jira/browse/FLINK-12017
Project: Flink
Issue Type: T
Hi Stephan
I prefer to remove 'enableForceKryo' since Kryo serializer does not work
out-of-the-box well for schema evolution stories due to its mutable properties,
and our built-in POJO serializer has already supported schema evolution.
On the other hand, what's the backward compatibility plan
godfrey he created FLINK-12018:
--
Summary: Add support for generating optimized logical plan for
Sort and Rank
Key: FLINK-12018
URL: https://issues.apache.org/jira/browse/FLINK-12018
Project: Flink
Compatibility is really important for checkpointed state.
For that, you can always directly specify GenericTypeInfo or AvroTypeInfo
if you want to continue to treat a type via Kryo or Avro.
Alternatively, once https://issues.apache.org/jira/browse/FLINK-11917 is
implemented, this should happen aut
Hi,
I really like the idea of introducing Java Expression DSL. I think this
will solve many problems e.g. right now it's quite tricky how string
literals work in scala (sometimes it might go through the
ExpressionParser and it will end up as an UnresolvedFieldReference),
another important problem
Thanks for bringing up this DISCUSS Timo!
Java Expression DSL is pretty useful for java user. When we have the Java
Expression DSL, Java API will become very rich and easy to use!
+1 from my side.
Best,
Jincheng
Dawid Wysakowicz 于2019年3月26日周二 下午5:08写道：
> Hi,
>
> I really like the idea of int
Hi Stephan,
I am in favor of renaming forceKryo() instead of removing it, because users
might plugin their Protobuf/Thrift serializers via Kryo as advertised in
our documentation [1]. For this, Kryo needs to be used for POJO types as
well, if I am not mistaken.
Cheers,
Konstantin
[1]
https://ci
Aljoscha Krettek created FLINK-12019:
Summary:
ZooKeeperHaServicesTest.testCloseAndCleanupAllDataWithUncle is unstable
Key: FLINK-12019
URL: https://issues.apache.org/jira/browse/FLINK-12019
Proje
Hi all,
I'm investigating using Table-API as an abstraction for Batch-API in our
GRADOOP project [1]. As a user of Flink I like to give you some feedback
from the user perspective.
I really like Timo's ideas - since we built another framework which is
based on Apache Flink we are just provid
Good point, Konstantin, that makes sense.
On Tue, Mar 26, 2019 at 10:37 AM Konstantin Knauf
wrote:
> Hi Stephan,
>
> I am in favor of renaming forceKryo() instead of removing it, because users
> might plugin their Protobuf/Thrift serializers via Kryo as advertised in
> our documentation [1]. For
Till Rohrmann created FLINK-12020:
-
Summary: Add documentation for mesos-appmaster-job.sh
Key: FLINK-12020
URL: https://issues.apache.org/jira/browse/FLINK-12020
Project: Flink
Issue Type: Im
Till Rohrmann created FLINK-12021:
-
Summary: Let ResultConjunctFuture return future results in same
order as futures
Key: FLINK-12021
URL: https://issues.apache.org/jira/browse/FLINK-12021
Project: Fl
Hi Konstantin
I think there is no direct relationship between registering
chill-protobuf/chill-thrift for Protobuf/Thrift type with Kryo and enforcing
POJO to use Kryo.
For both Protobuf and Thrift types, they will be extracted as GenericTypeInfo
within TypeExtractor which would use Kryoseriali
Thanks for the fix and information boss!
Best Regards,
Yu
On Tue, 26 Mar 2019 at 02:24, Stephan Ewen wrote:
> Thanks for reporting this.
>
> Here is the issue and the fix for it:
> https://issues.apache.org/jira/browse/FLINK-12012
>
>
> On Fri, Mar 15, 2019 at 1:36 PM Yu Li wrote:
>
> > Hi Al
+1 (non-binding)
- Checked release notes: OK
- Checked sums and signatures: OK
- Source release
- contains no binaries: OK
- contains no 1.8-SNAPSHOT references: OK
- build from source: OK (8u101)
- mvn clean verify: OK (8u101)
- Binary release
- no examples appear to be m
+1 (non-binding)
- checked checksums and GPG files
- build from source successfully- run end-to-end precommit tests successfully-
run end-to-end nightly tests successfully
Xiaowei
On Tuesday, March 26, 2019, 8:09:19 PM GMT+8, Yu Li
wrote:
+1 (non-binding)
- Checked release notes: OK
Paul Lin created FLINK-12022:
Summary: Enable StreamWriter to update file length on sync flush
Key: FLINK-12022
URL: https://issues.apache.org/jira/browse/FLINK-12022
Project: Flink
Issue Type: I
Michel Davit created FLINK-12023:
Summary: Override TaskManager memory when submitting a Flink job
Key: FLINK-12023
URL: https://issues.apache.org/jira/browse/FLINK-12023
Project: Flink
Issue
Elias Levy created FLINK-12024:
--
Summary: Bump universal Kafka connector to Kafka dependency to
2.2.0
Key: FLINK-12024
URL: https://issues.apache.org/jira/browse/FLINK-12024
Project: Flink
Issu
vinoyang created FLINK-12025:
Summary: Support FOR SYSTEM_TIME AS OF in temporal table
Key: FLINK-12025
URL: https://issues.apache.org/jira/browse/FLINK-12025
Project: Flink
Issue Type: Sub-task
+1 (non-binding)
- checked JIRA release note
- ran "mvn package -DskipTests"
- checked signature and checksum
- started a cluster locally and ran some examples in binary
- checked web site announcement's PR
Best,
Vino
Xiaowei Jiang 于2019年3月26日周二 下午8:20写道：
> +1 (non-binding)
>
> - checked che
sunjincheng created FLINK-12026:
---
Summary: Remove the `xxxInternal` method from TableImpl
Key: FLINK-12026
URL: https://issues.apache.org/jira/browse/FLINK-12026
Project: Flink
Issue Type: Impr
Jeff Zhang created FLINK-12027:
--
Summary: Flink Web UI is not accessible in local mode
Key: FLINK-12027
URL: https://issues.apache.org/jira/browse/FLINK-12027
Project: Flink
Issue Type: Improvem
sunjincheng created FLINK-12028:
---
Summary: Add Column Operators(add/rename/drop)
Key: FLINK-12028
URL: https://issues.apache.org/jira/browse/FLINK-12028
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-12029:
---
Summary: Add Column selections
Key: FLINK-12029
URL: https://issues.apache.org/jira/browse/FLINK-12029
Project: Flink
Issue Type: Sub-task
Components
+1 （non-binding)
• checked signature and checksum ok
• mvn clean package -DskipTests ok
• Run job on yarn ok
• Test state migration with POJO type (both heap and rocksdb) ok
• - 1.6 -> 1.8
• - 1.7 -> 1.8
• - 1.8 -> 1.8
Best, Congxian
On Mar 27, 2019, 10:26 +0800, vino yang , wrote:
> +1 (non-bi
26 matches
Mail list logo
