Huang Xingbo created FLINK-20483:
Summary: Support Pandas UDF for Map Operation in Python Table API
Key: FLINK-20483
URL: https://issues.apache.org/jira/browse/FLINK-20483
Project: Flink
Issu
Hi，I have some questions about state TTL to consult with everybody，the
statebackend is rocksdb Below is my code：
-code begin-
private static final String EV_STATE_FLAG = "EV_EID_FLAG";
StateTtlConfig ttlConfig = StateTtlConfig
.newBuilder(Time.minutes(60))
Leonard Xu created FLINK-20484:
--
Summary: Improve hive temporal table exception
Key: FLINK-20484
URL: https://issues.apache.org/jira/browse/FLINK-20484
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-20485:
Summary: Map views are deserialized multiple times
Key: FLINK-20485
URL: https://issues.apache.org/jira/browse/FLINK-20485
Project: Flink
Issue Type: Sub-tas
Rui Li created FLINK-20486:
--
Summary: Hive temporal join shouldn't require a minimal 1h monitor
interval
Key: FLINK-20486
URL: https://issues.apache.org/jira/browse/FLINK-20486
Project: Flink
Issue
jiayue.yu created FLINK-20487:
-
Summary: FLINK SQL GROUP BY TUMBLE AND OVER FUNCTION
Key: FLINK-20487
URL: https://issues.apache.org/jira/browse/FLINK-20487
Project: Flink
Issue Type: Bug
+1 (non-binding)
* Build from source
* Deploy Flink cluster in following deployments with HA enabled(ZooKeeper
and K8s), including kill JobManager and check failover
* Native K8s Session
* Native K8s Application
* Yarn Session
* Yarn Per-Job
* Yarn Application
* Check webUI and logs in d
Roman Khachatryan created FLINK-20488:
-
Summary: Supporting changes (UI, conf) for timing out aligned
checkpoints
Key: FLINK-20488
URL: https://issues.apache.org/jira/browse/FLINK-20488
Project: F
Partha Pradeep Mishra created FLINK-20489:
-
Summary: Error in restoring checkpoint/savepoint when Flink is
upgraded from 1.9 to 1.10.2
Key: FLINK-20489
URL: https://issues.apache.org/jira/browse/FLINK-2048
godfrey he created FLINK-20490:
--
Summary: Don't share inputs between FlinkPhysicalRel and ExecNode
Key: FLINK-20490
URL: https://issues.apache.org/jira/browse/FLINK-20490
Project: Flink
Issue Ty
+1 (non-binding)
- verified checksums and signatures
- build Flink with Scala 2.11
- pip install pyflink on Windows python 3.7
- run a python job with udfs on Windows
- pyflink shell works well on local mode and remote mode
Best,
Wei
> 在 2020年12月4日，17:21，Yang Wang 写道：
>
> +1 (non-binding)
>
>
+1 (binding)
* Verified the checksums
* Ran RC on Minikube cluster
** Session mode
** Application mode
* Built Flink from sources
Cheers,
Till
On Fri, Dec 4, 2020 at 2:15 PM Wei Zhong wrote:
> +1 (non-binding)
>
> - verified checksums and signatures
> - build Flink with Scala 2.11
> - pip inst
Aljoscha Krettek created FLINK-20491:
Summary: Support Broadcast State in BATCH execution mode
Key: FLINK-20491
URL: https://issues.apache.org/jira/browse/FLINK-20491
Project: Flink
Issue
Jiangjie Qin created FLINK-20492:
Summary: The SourceOperatorStreamTask should implement
cancelTask() and finishTask()
Key: FLINK-20492
URL: https://issues.apache.org/jira/browse/FLINK-20492
Project:
Huang Xingbo created FLINK-20493:
Summary: SQLClientSchemaRegistryITCase test failed
Key: FLINK-20493
URL: https://issues.apache.org/jira/browse/FLINK-20493
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20494:
Summary: SQLClientHBaseITCase Task Timeout
Key: FLINK-20494
URL: https://issues.apache.org/jira/browse/FLINK-20494
Project: Flink
Issue Type: Bug
C
Huang Xingbo created FLINK-20495:
Summary: Elasticsearch6DynamicSinkITCase Hang
Key: FLINK-20495
URL: https://issues.apache.org/jira/browse/FLINK-20495
Project: Flink
Issue Type: Bug
+1 (binding)
- verified signature and checksum
- built from source
- run testing jobs on yarn with manually triggered failures. checked logs
and WebUI of those jobs
* DataStream job (paralelism=1000) with multiple disjoint pipelined
regions
* DataSet job (paralelism=1000) with all edges blocki
18 matches
Mail list logo
