Feifan Wang created FLINK-27105:
---
Summary: wrong metric type
Key: FLINK-27105
URL: https://issues.apache.org/jira/browse/FLINK-27105
Project: Flink
Issue Type: Bug
Reporter: Feifan
Sitan Pang created FLINK-27104:
--
Summary: ClassNotFound when submit jobs to session cluster with
external jars
Key: FLINK-27104
URL: https://issues.apache.org/jira/browse/FLINK-27104
Project: Flink
Hi Luan,
Your error is because the version of the Python interpreter used by your
client and the cluster side is inconsistent. The default protocol version
used by pickle before python 3.8 is 4, and after python 3.8 it is 5. If the
two version do not match, an error will be reported as shown in
Jingsong Lee created FLINK-27103:
Summary: Don't store redundant primary key fields
Key: FLINK-27103
URL: https://issues.apache.org/jira/browse/FLINK-27103
Project: Flink
Issue Type:
Dong Lin created FLINK-27102:
Summary: Add BinaryClassificationEvaluator
Key: FLINK-27102
URL: https://issues.apache.org/jira/browse/FLINK-27102
Project: Flink
Issue Type: New Feature
Steven Zhen Wu created FLINK-27101:
--
Summary: Periodically break the chain of incremental checkpoint
Key: FLINK-27101
URL: https://issues.apache.org/jira/browse/FLINK-27101
Project: Flink
Yubin Li created FLINK-27100:
Summary: Support parquet format in FileStore
Key: FLINK-27100
URL: https://issues.apache.org/jira/browse/FLINK-27100
Project: Flink
Issue Type: New Feature
Mexicapita created FLINK-27099:
--
Summary: RestClient fills /tmp directory
Key: FLINK-27099
URL: https://issues.apache.org/jira/browse/FLINK-27099
Project: Flink
Issue Type: Bug
Xin Hao created FLINK-27098:
---
Summary: The session job controller should create FlinkDeployment
informer event source with namespace definition
Key: FLINK-27098
URL: https://issues.apache.org/jira/browse/FLINK-27098
Nicholas Jiang created FLINK-27097:
--
Summary: Document custom validator implementations
Key: FLINK-27097
URL: https://issues.apache.org/jira/browse/FLINK-27097
Project: Flink
Issue Type:
HI, Kevin
I have not reproduced this problem.
What is the impact of this problem? Can't get this parameter correctly in user
main method?
Could you provide a screenshot of the JobManager configuration on the UI
> 2022年4月2日 上午10:23，Kevin Lee 写道：
>
> It's a typo
>
> I run this demo on yarn
Dong Lin created FLINK-27096:
Summary: Benchmark all algorithms included in Flink ML 2.1 release
and achieve performance parity with Spark
Key: FLINK-27096
URL: https://issues.apache.org/jira/browse/FLINK-27096
Usamah Jassat created FLINK-27095:
-
Summary: Allow FlinkDeployment Mode Switching
Key: FLINK-27095
URL: https://issues.apache.org/jira/browse/FLINK-27095
Project: Flink
Issue Type:
Martijn Visser created FLINK-27094:
--
Summary: Use Boring Cyborg to link issues back to Jira
Key: FLINK-27094
URL: https://issues.apache.org/jira/browse/FLINK-27094
Project: Flink
Issue
I think creating an official image is not necessary.
Per the docker hub statement [1], "Docker Official Images are an
intellectual property of Docker". So technically it's not part of the
Apache Flink release, and anyone who wants can open a PR to create such an
image.
Thank you~
Xintong Song
Dong Lin created FLINK-27093:
Summary: Add Estimator and Transformer for LinearReg
Key: FLINK-27093
URL: https://issues.apache.org/jira/browse/FLINK-27093
Project: Flink
Issue Type: New Feature
Dong Lin created FLINK-27092:
Summary: Add Estimator and Transformer for Bucketizer
Key: FLINK-27092
URL: https://issues.apache.org/jira/browse/FLINK-27092
Project: Flink
Issue Type: New Feature
Dong Lin created FLINK-27091:
Summary: Add Estimator and Transformer for SVM
Key: FLINK-27091
URL: https://issues.apache.org/jira/browse/FLINK-27091
Project: Flink
Issue Type: Bug
Dong Lin created FLINK-27090:
Summary: Add Estimator and Transformer for FTRL
Key: FLINK-27090
URL: https://issues.apache.org/jira/browse/FLINK-27090
Project: Flink
Issue Type: Bug
Caizhi Weng created FLINK-27089:
---
Summary: Calling TRY_CAST with an invalid value throws
IndexOutOfBounds Exception.
Key: FLINK-27089
URL: https://issues.apache.org/jira/browse/FLINK-27089
Project:
Penguin created FLINK-27088:
---
Summary: The example of using StringDeserializer for deserializing
Kafka message value as string has an error
Key: FLINK-27088
URL: https://issues.apache.org/jira/browse/FLINK-27088
Smile created FLINK-27087:
-
Summary: Configuration "taskmanager.network.detailed-metrics" in
metrics document was mistaken as "taskmanager.net.detailed-metrics"
Key: FLINK-27087
URL:
Jing Zhang created FLINK-27086:
--
Summary: Add a QA about how to handle exception when use hive
parser in hive dialect document
Key: FLINK-27086
URL: https://issues.apache.org/jira/browse/FLINK-27086
Caizhi Weng created FLINK-27085:
---
Summary: Introduce snapshot.num-retained.min option
Key: FLINK-27085
URL: https://issues.apache.org/jira/browse/FLINK-27085
Project: Flink
Issue Type:
Yunfeng Zhou created FLINK-27084:
Summary: Perround mode recreating operator fails
Key: FLINK-27084
URL: https://issues.apache.org/jira/browse/FLINK-27084
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27083:
---
Summary:
SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed on
azure
Key: FLINK-27083
URL: https://issues.apache.org/jira/browse/FLINK-27083
Project:
Chesnay Schepler created FLINK-27082:
Summary: Disable tests relying on non-writable directories
Key: FLINK-27082
URL: https://issues.apache.org/jira/browse/FLINK-27082
Project: Flink
Chesnay Schepler created FLINK-27081:
Summary: Remove Azure integration
Key: FLINK-27081
URL: https://issues.apache.org/jira/browse/FLINK-27081
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-27080:
Summary: Enable builds for pull requests
Key: FLINK-27080
URL: https://issues.apache.org/jira/browse/FLINK-27080
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-27079:
Summary: Setup cron jobs
Key: FLINK-27079
URL: https://issues.apache.org/jira/browse/FLINK-27079
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-27077:
Summary: Setup per-commit builds for master
Key: FLINK-27077
URL: https://issues.apache.org/jira/browse/FLINK-27077
Project: Flink
Issue Type:
Lijie Wang created FLINK-27078:
--
Summary: There is a performance gap between the new csv
source(file system source + CSV format) and legacy CsvTableSource.
Key: FLINK-27078
URL:
Chesnay Schepler created FLINK-27076:
Summary: Setup runners
Key: FLINK-27076
URL: https://issues.apache.org/jira/browse/FLINK-27076
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-27075:
Summary: Migrate CI from Azure to Github Actions
Key: FLINK-27075
URL: https://issues.apache.org/jira/browse/FLINK-27075
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-27074:
Summary: python_job.py should write to TEST_DATA_DIR
Key: FLINK-27074
URL: https://issues.apache.org/jira/browse/FLINK-27074
Project: Flink
Issue
Yun Gao created FLINK-27073:
---
Summary: HAQueryableStateFsBackendITCase hangs on azure
Key: FLINK-27073
URL: https://issues.apache.org/jira/browse/FLINK-27073
Project: Flink
Issue Type: Bug
Zhipeng Zhang created FLINK-27072:
-
Summary: Add Bucketizer in FlinkML
Key: FLINK-27072
URL: https://issues.apache.org/jira/browse/FLINK-27072
Project: Flink
Issue Type: New Feature
haixiaCao created FLINK-27071:
-
Summary: For jdbcsink function to support config table name in
SQL parameter
Key: FLINK-27071
URL: https://issues.apache.org/jira/browse/FLINK-27071
Project: Flink
Caizhi Weng created FLINK-27070:
---
Summary: Reuse FileFormat instead of DecodingFormat/EncodingFormat
to ensure thread safety.
Key: FLINK-27070
URL: https://issues.apache.org/jira/browse/FLINK-27070
actually I had build/compile
- pyarrow==2.0.0 (test skipped)
- apache-beam==2.27.0 (test skipped)
on python 3.9, and test with example python jobs( bin/flink run
-pyclientexec python3.7 -pyexec python3.9 -py
examples/python/table/word_count.py )
but got exceptions following
Caused by:
Huang Xingbo created FLINK-27069:
Summary: Fix the potential memory corruption in Thread Mode
Key: FLINK-27069
URL: https://issues.apache.org/jira/browse/FLINK-27069
Project: Flink
Issue
41 matches
Mail list logo
