Matthias created FLINK-20744:
Summary:
org.apache.flink.test.checkpointing.UnalignedCheckpointITCase fails due to
java.lang.ArrayIndexOutOfBoundsException
Key: FLINK-20744
URL:
Thanks for driving the release Gordon!
here is a +1 (non binding) from my side:
- verified checksums, signatures etc’.
- verified that there are no binary files in the source distribution.
- built successfully with jdk11
- built successfully with jdk8
- e2e passes with jdk11
- e2e passes
yang gang created FLINK-20743:
-
Summary: Print ContainerId For RemoteTransportException
Key: FLINK-20743
URL: https://issues.apache.org/jira/browse/FLINK-20743
Project: Flink
Issue Type:
Tzu-Li (Gordon) Tai created FLINK-20742:
---
Summary: Skip deployment of StateFun example artifacts
Key: FLINK-20742
URL: https://issues.apache.org/jira/browse/FLINK-20742
Project: Flink
+1 (binding)
- Verified hashes and signatures
- Verified NOTICE files in statefun-flink-datastream and
statefun-flink-distribution
- Built locally: mvn clean install -Prun-e2e-tests
- Successfully restored from a 2.2.0 savepoint that contains feedback events
- Verified that the proposed new
Hi everyone,
Please review and vote on the release candidate #2 for the version 2.2.2 of
Apache Flink Stateful Functions, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
***Testing Guideline***
You can find here [1] a page in the
Tzu-Li (Gordon) Tai created FLINK-20741:
---
Summary: StateFun's DataStream interop SDK module is missing a
valid NOTICE file
Key: FLINK-20741
URL: https://issues.apache.org/jira/browse/FLINK-20741
Yingjie Cao created FLINK-20740:
---
Summary: Use managed memory to avoid direct memory OOM error
Key: FLINK-20740
URL: https://issues.apache.org/jira/browse/FLINK-20740
Project: Flink
Issue
jinfeng created FLINK-20739:
---
Summary: Ban `if` from HiveModule
Key: FLINK-20739
URL: https://issues.apache.org/jira/browse/FLINK-20739
Project: Flink
Issue Type: Improvement
godfrey he created FLINK-20738:
--
Summary: Separate the implementation of batch aggregate nodes
Key: FLINK-20738
URL: https://issues.apache.org/jira/browse/FLINK-20738
Project: Flink
Issue Type:
godfrey he created FLINK-20737:
--
Summary: Separate the implementation of stream aggregate nodes
Key: FLINK-20737
URL: https://issues.apache.org/jira/browse/FLINK-20737
Project: Flink
Issue
Thanks Shuo Cheng for driving this discussion ~
Generally i have the same feeling that our temporal table syntax is a
little verbose compared to KSQL or other RDBMS. (they just use the normal
join syntax for the temporal join).
>I think maybe we can add a pseudo-column `PROCTIME` (or `_PROCTIME`
Wenlong Lyu created FLINK-20736:
---
Summary: Separate the implementation of BatchExecLimit and
StreamExecLimit
Key: FLINK-20736
URL: https://issues.apache.org/jira/browse/FLINK-20736
Project: Flink
zlzhang0122 created FLINK-20735:
---
Summary: Support configurable log level
Key: FLINK-20735
URL: https://issues.apache.org/jira/browse/FLINK-20735
Project: Flink
Issue Type: Improvement
owr created FLINK-20734:
---
Summary: SQL client error when running joining query
Key: FLINK-20734
URL: https://issues.apache.org/jira/browse/FLINK-20734
Project: Flink
Issue Type: Bug
Jianyun Zhao created FLINK-20733:
Summary: Introduce the upsert-pulsar Connector
Key: FLINK-20733
URL: https://issues.apache.org/jira/browse/FLINK-20733
Project: Flink
Issue Type: Sub-task
Jianyun Zhao created FLINK-20732:
Summary: Pulsar Sink
Key: FLINK-20732
URL: https://issues.apache.org/jira/browse/FLINK-20732
Project: Flink
Issue Type: Sub-task
Reporter:
Jianyun Zhao created FLINK-20731:
Summary: Pulsar Source
Key: FLINK-20731
URL: https://issues.apache.org/jira/browse/FLINK-20731
Project: Flink
Issue Type: Sub-task
Reporter:
Jianyun Zhao created FLINK-20730:
Summary: Pulsar Catalog
Key: FLINK-20730
URL: https://issues.apache.org/jira/browse/FLINK-20730
Project: Flink
Issue Type: Sub-task
Reporter:
Jianyun Zhao created FLINK-20729:
Summary: Pulsar DynamicTable
Key: FLINK-20729
URL: https://issues.apache.org/jira/browse/FLINK-20729
Project: Flink
Issue Type: Sub-task
Jianyun Zhao created FLINK-20728:
Summary: Pulsar SinkFunction
Key: FLINK-20728
URL: https://issues.apache.org/jira/browse/FLINK-20728
Project: Flink
Issue Type: Sub-task
Jianyun Zhao created FLINK-20727:
Summary: Pulsar SourceFunction
Key: FLINK-20727
URL: https://issues.apache.org/jira/browse/FLINK-20727
Project: Flink
Issue Type: Sub-task
Jianyun Zhao created FLINK-20726:
Summary: Support Pulsar connector
Key: FLINK-20726
URL: https://issues.apache.org/jira/browse/FLINK-20726
Project: Flink
Issue Type: New Feature
Lijie Wang created FLINK-20725:
--
Summary: TableFunction#getTypeInference is not work well for
JdbcRowDataLookupFunction, it's always throws Exception
Key: FLINK-20725
URL:
Piotr Nowojski created FLINK-20724:
--
Summary: Create a http handler for aggregating metrics from whole
job
Key: FLINK-20724
URL: https://issues.apache.org/jira/browse/FLINK-20724
Project: Flink
Matthias created FLINK-20723:
Summary: testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink
failed due to NoHostAvailableException
Key: FLINK-20723
URL: https://issues.apache.org/jira/browse/FLINK-20723
Rui Li created FLINK-20722:
--
Summary: Fail to insert into hive table due to ClassCastException
Key: FLINK-20722
URL: https://issues.apache.org/jira/browse/FLINK-20722
Project: Flink
Issue Type: Bug
Zhu Zhu created FLINK-20721:
---
Summary: Remove unknown input channels and process to update
partitions
Key: FLINK-20721
URL: https://issues.apache.org/jira/browse/FLINK-20721
Project: Flink
Issue
Shuiqiang Chen created FLINK-20720:
--
Summary: Add documentation for ProcessFunction in Python
DataStream API
Key: FLINK-20720
URL: https://issues.apache.org/jira/browse/FLINK-20720
Project: Flink
godfrey he created FLINK-20719:
--
Summary: Change BatchExecNode & StreamExecNode to interface and
make each node extended from ExecNodeBase directly
Key: FLINK-20719
URL:
Piotr Nowojski created FLINK-20718:
--
Summary: Create isCausingBackPressureRatio and
isCausingBackPressure metrics
Key: FLINK-20718
URL: https://issues.apache.org/jira/browse/FLINK-20718
Project:
Piotr Nowojski created FLINK-20717:
--
Summary: Create isBackPressuredRatio metric
Key: FLINK-20717
URL: https://issues.apache.org/jira/browse/FLINK-20717
Project: Flink
Issue Type: Sub-task
Jin Xing created FLINK-20716:
Summary: Pluggable shuffle service public interface
IndexedInputGate mixed with Netty shuffle service implementation.
Key: FLINK-20716
URL:
It seems like the statefun-flink-datastream artifact is missing a valid
NOTICE file, since it bundles dependencies and builds a fat jar.
Any bundled dependencies in released artifacts need to be acknowledged in
the NOTICE file of the artifact.
-1
I'm hereby cancelling this RC due to this, and
Enter created FLINK-20715:
-
Summary: pyflink DataStream filter error.
Key: FLINK-20715
URL: https://issues.apache.org/jira/browse/FLINK-20715
Project: Flink
Issue Type: Bug
Components: API
Hi all,
I found that currently the managed memory can only be used in 3 workloads
[1]:
- state backends for streaming jobs
- sorting, hash tables for batch jobs
- python UDFs
And the configuration option `taskmanager.memory.managed.consumer-weights`
only allows values: PYTHON and DATAPROC (state
36 matches
Mail list logo
