Huang Xingbo created FLINK-22149:
Summary: Test Python UDAF in Group Window
Key: FLINK-22149
URL: https://issues.apache.org/jira/browse/FLINK-22149
Project: Flink
Issue Type: Test
C
Huang Xingbo created FLINK-22150:
Summary: Test user-defined window in Python DataStream API
Key: FLINK-22150
URL: https://issues.apache.org/jira/browse/FLINK-22150
Project: Flink
Issue Type:
Hi,
I don't think there is a Flink specific answer to this question. Just do
what you would normally do with a normal Java application running inside a
JVM. If there is an OOM on heap space, you can either try to bump the heap
space, or reduce usage of it. The only Flink specific part is probably
Timo Walther created FLINK-22151:
Summary: Implement type inference for agg functions
Key: FLINK-22151
URL: https://issues.apache.org/jira/browse/FLINK-22151
Project: Flink
Issue Type: Sub-ta
Hi Arvid,
There are interface changes to the Kafka source, and there is a backwards
compatible change in the base source implementation. Therefore technically
speaking, users might be able to run the Kafka source in 1.13 with a 1.12
Flink job. However, it could be tricky because there might be som
Huang Xingbo created FLINK-22152:
Summary: Fix the bug of same timers are registered multiple times
Key: FLINK-22152
URL: https://issues.apache.org/jira/browse/FLINK-22152
Project: Flink
Issu
Yingjie Cao created FLINK-22153:
---
Summary: Manually test the sort-merge blocking shuffle
Key: FLINK-22153
URL: https://issues.apache.org/jira/browse/FLINK-22153
Project: Flink
Issue Type: Task
Caizhi Weng created FLINK-22154:
---
Summary: PushFilterIntoTableSourceScanRule fails to deal with IN
expressions
Key: FLINK-22154
URL: https://issues.apache.org/jira/browse/FLINK-22154
Project: Flink
Shengkai Fang created FLINK-22155:
-
Summary: Fix EXPLAIN implementation
Key: FLINK-22155
URL: https://issues.apache.org/jira/browse/FLINK-22155
Project: Flink
Issue Type: Bug
Compon
Yingjie Cao created FLINK-22156:
---
Summary: HiveDialectQueryITCase fails on Azure because of no
output for 900 seconds
Key: FLINK-22156
URL: https://issues.apache.org/jira/browse/FLINK-22156
Project: Fli
Caizhi Weng created FLINK-22157:
---
Summary: Join & Select a part of composite primary key will cause
ArrayIndexOutOfBoundsException
Key: FLINK-22157
URL: https://issues.apache.org/jira/browse/FLINK-22157
Yang Wang created FLINK-22158:
-
Summary: Test native Kubernetes pod template
Key: FLINK-22158
URL: https://issues.apache.org/jira/browse/FLINK-22158
Project: Flink
Issue Type: Test
Comp
Jark Wu created FLINK-22159:
---
Summary: Add documentation for the new window TVF based operations
Key: FLINK-22159
URL: https://issues.apache.org/jira/browse/FLINK-22159
Project: Flink
Issue Type: S
Hey everyone, I'm looking to get the full set of unit tests working using
AdoptOpenJDK 11 with the OpenJ9 VM and I'm basically seeing problems with
the runtime tests (always going OoM creating new threads) and I'd also like
to have a go at https://issues.apache.org/jira/browse/FLINK-21672.
That be
Jark Wu created FLINK-22160:
---
Summary: Test Window TVF based aggregation and TopN
Key: FLINK-22160
URL: https://issues.apache.org/jira/browse/FLINK-22160
Project: Flink
Issue Type: Test
C
Jark Wu created FLINK-22161:
---
Summary: 'Run Mesos WordCount test' failed on Azure
Key: FLINK-22161
URL: https://issues.apache.org/jira/browse/FLINK-22161
Project: Flink
Issue Type: Bug
Co
Lu Niu created FLINK-22162:
--
Summary: Make Max Operator name Length Configurable
Key: FLINK-22162
URL: https://issues.apache.org/jira/browse/FLINK-22162
Project: Flink
Issue Type: Improvement
François Lacombe created FLINK-22163:
Summary: DataTypes implementation for flink-csv with ZonedDateTime
support
Key: FLINK-22163
URL: https://issues.apache.org/jira/browse/FLINK-22163
Project: Fl
I have deployed my own flink setup in AWS ECS. One Service for JobManager
and one Service for task Managers. I am running one ECS task for a job
manager and 3 ecs tasks for TASK managers.
I have a kind of batch job which I upload using flink rest every-day with
changing new arguments, when I submi
Lu Niu created FLINK-22164:
--
Summary: Add jobId and JobName variable to JobManager metrics in
per-job deployment mode
Key: FLINK-22164
URL: https://issues.apache.org/jira/browse/FLINK-22164
Project: Flink
Spongebob created FLINK-22165:
-
Summary: How to set rabbitmq correlationId when using rabbitmq
sink in dataStreamEnv
Key: FLINK-22165
URL: https://issues.apache.org/jira/browse/FLINK-22165
Project: Flink
Jingsong Lee created FLINK-22167:
Summary: Partial insert not works when complex fields reorder
Key: FLINK-22167
URL: https://issues.apache.org/jira/browse/FLINK-22167
Project: Flink
Issue Ty
Jingsong Lee created FLINK-22166:
Summary: Empty values with sort willl fail
Key: FLINK-22166
URL: https://issues.apache.org/jira/browse/FLINK-22166
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-22168:
Summary: Partition insert with union all will fail
Key: FLINK-22168
URL: https://issues.apache.org/jira/browse/FLINK-22168
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-22169:
-
Summary: Beautify the CliTableauResultView when print
Key: FLINK-22169
URL: https://issues.apache.org/jira/browse/FLINK-22169
Project: Flink
Issue Type: Bu
Rui Li created FLINK-22170:
--
Summary: Manual test for hive dialect
Key: FLINK-22170
URL: https://issues.apache.org/jira/browse/FLINK-22170
Project: Flink
Issue Type: Sub-task
Components: C
Shengkai Fang created FLINK-22171:
-
Summary: Update the doc about SQL Client
Key: FLINK-22171
URL: https://issues.apache.org/jira/browse/FLINK-22171
Project: Flink
Issue Type: Sub-task
Huang Xingbo created FLINK-22172:
Summary: Fix the bug of shared resource among Python Operators of
the same slot is not released
Key: FLINK-22172
URL: https://issues.apache.org/jira/browse/FLINK-22172
Dawid Wysakowicz created FLINK-22173:
Summary: UnalignedCheckpointRescaleITCase fails on azure
Key: FLINK-22173
URL: https://issues.apache.org/jira/browse/FLINK-22173
Project: Flink
Issue
29 matches
Mail list logo
