Ben Longo created FLINK-27300:
-
Summary: Support scala case class for PulsarSchema
Key: FLINK-27300
URL: https://issues.apache.org/jira/browse/FLINK-27300
Project: Flink
Issue Type: Improvement
Huajie Wang created FLINK-27299:
---
Summary: [BUG] Flink parsing parameter bug
Key: FLINK-27299
URL: https://issues.apache.org/jira/browse/FLINK-27299
Project: Flink
Issue Type: Bug
陈磊 created FLINK-27298:
--
Summary: in sqlClient.md, table name inconsistency problem.
Key: FLINK-27298
URL: https://issues.apache.org/jira/browse/FLINK-27298
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-27297:
Summary: Add the
StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method in
PyFlink
Key: FLINK-27297
URL: https://issues.apache.org/jira/browse/FLINK-27297
tartarus created FLINK-27296:
Summary: CalcOperator CodeGenException: Boolean expression type
expected
Key: FLINK-27296
URL: https://issues.apache.org/jira/browse/FLINK-27296
Project: Flink
Yun Tang created FLINK-27295:
Summary: UnalignedCheckpointITCase failed due to
OperatorCoordinatorHolder cannot mark checkpoint
Key: FLINK-27295
URL: https://issues.apache.org/jira/browse/FLINK-27295
Hi devs,
Yuan and I would like to start a discussion about FLIP-221[1], which introduces
an abstraction of lookup table cache and its standard metrics.
Currently each lookup table source should implement their own cache to store
lookup results, and there isn’t a standard of metrics for users
weibo zhao created FLINK-27294:
--
Summary: Add Transformer for EvalBinaryClass
Key: FLINK-27294
URL: https://issues.apache.org/jira/browse/FLINK-27294
Project: Flink
Issue Type: New Feature
Spencer Deehring created FLINK-27293:
Summary: CVE-2020-36518 in flink-shaded jackson
Key: FLINK-27293
URL: https://issues.apache.org/jira/browse/FLINK-27293
Project: Flink
Issue Type:
Chengkai Yang created FLINK-27292:
-
Summary: Translate the "Data Type Extraction" section of "Data
Types" in to Chinese
Key: FLINK-27292
URL: https://issues.apache.org/jira/browse/FLINK-27292
Chengkai Yang created FLINK-27291:
-
Summary: Translate the "List of Data Types" section of "Data
Types" in to Chinese
Key: FLINK-27291
URL: https://issues.apache.org/jira/browse/FLINK-27291
Project:
Chengkai Yang created FLINK-27290:
-
Summary: Translate the "Data Type" section of "Data Types" in to
Chinese
Key: FLINK-27290
URL: https://issues.apache.org/jira/browse/FLINK-27290
Project: Flink
+1(non-binding)
- Verified signature and checksum
- Build image with flink-docker repo
- Run statemachine last-state upgrade via flink-kubernetes-operator which
could verify the following aspects
- Native K8s integration
- Multiple Component Kubernetes HA services
- Run Flink application
liuzhuo created FLINK-27289:
---
Summary: Do some optimizations for
"FlinkService#stopSessionCluster"
Key: FLINK-27289
URL: https://issues.apache.org/jira/browse/FLINK-27289
Project: Flink
Issue
kent created FLINK-27288:
Summary: flink operator crd is too long
Key: FLINK-27288
URL: https://issues.apache.org/jira/browse/FLINK-27288
Project: Flink
Issue Type: Bug
Components:
Hi team,
I’d like to start a discussion about FLIP-222 [1], which adds query lifecycle
statements to SQL client.
Currently, SQL client supports submitting queries (queries in a broad sense,
including DQLs and DMLs) but no further lifecycle statements, like canceling
a query or triggering a
Zhilong Hong created FLINK-27287:
Summary: FileExecutionGraphInfoStoreTest unstable with "Could not
start rest endpoint on any port in port range 8081"
Key: FLINK-27287
URL:
Caizhi Weng created FLINK-27286:
---
Summary: Fix table store connector throws ClassNotFoundException:
org.apache.flink.table.store.shaded.org.apache.flink.connector.file.table.RowDataPartitionComputer
Key: FLINK-27286
+1(binding)
- Verified the signature and checksum of the release binary
- Run the SqlClient example
- Run the WordCount example
- Compile from the source and success
Best,
Guowei
On Mon, Apr 18, 2022 at 11:13 AM Xintong Song wrote:
> +1 (binding)
>
> - verified signature and checksum
> -
Yun Gao created FLINK-27285:
---
Summary: CassandraConnectorITCase failed on azure due to
NoHostAvailableException
Key: FLINK-27285
URL: https://issues.apache.org/jira/browse/FLINK-27285
Project: Flink
Yun Gao created FLINK-27284:
---
Summary: KafkaSinkITCase$IntegrationTests.testScaleUp failed on
azures due to failed to create topic
Key: FLINK-27284
URL: https://issues.apache.org/jira/browse/FLINK-27284
Caizhi Weng created FLINK-27283:
---
Summary: Add end to end tests for table store
Key: FLINK-27283
URL: https://issues.apache.org/jira/browse/FLINK-27283
Project: Flink
Issue Type: Sub-task
Huang Xingbo created FLINK-27282:
Summary: Fix the bug of wrong positions mapping in RowCoder
Key: FLINK-27282
URL: https://issues.apache.org/jira/browse/FLINK-27282
Project: Flink
Issue
Gyula Fora created FLINK-27281:
--
Summary: Improve stability conditions for rollback logic
Key: FLINK-27281
URL: https://issues.apache.org/jira/browse/FLINK-27281
Project: Flink
Issue Type:
Gyula Fora created FLINK-27280:
--
Summary: Support rollback for session jobs.
Key: FLINK-27280
URL: https://issues.apache.org/jira/browse/FLINK-27280
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27279:
--
Summary: Extract common status interfaces
Key: FLINK-27279
URL: https://issues.apache.org/jira/browse/FLINK-27279
Project: Flink
Issue Type: Improvement
Sorry for misspelling your name, Shengkai. The autocomple plugin is not very
wise.
Best,
Paul Lam
> 2022年4月18日 11:39，Paul Lam 写道：
>
> Hi Shanghai,
>
> You’re right. We can only retrieve the job names from the cluster, and
> display
> them as query names.
>
> I agree that the meaning word
27 matches
Mail list logo
