luoyuxia created FLINK-29386:
Summary: Fix fail to compile flink-connector-hive when profile is
hive3
Key: FLINK-29386
URL: https://issues.apache.org/jira/browse/FLINK-29386
Project: Flink
Issue
+1 (binding)
czw., 22 wrz 2022 o 08:21 Lincoln Lee napisał(a):
> Hi everyone,
>
> Thanks for all your feedback for FLIP-260[1] in the discussion thread[2],
> I'd
> like to start a vote for it.
>
> The vote will be open for at least 72 hours.
>
> [1]
>
> https://cwiki.apache.org/confluence/displa
Huang Xingbo created FLINK-29387:
Summary:
IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with
AssertionError
Key: FLINK-29387
URL: https://issues.apache.org/jira/browse/FLINK-29387
Usamah Jassat created FLINK-29388:
-
Summary: Fix args in JobSpec not being passed through to Flink in
Standalone mode
Key: FLINK-29388
URL: https://issues.apache.org/jira/browse/FLINK-29388
Project: F
Qingsheng Ren created FLINK-29389:
-
Summary: Update documentation of JDBC and HBase lookup table for
new caching options
Key: FLINK-29389
URL: https://issues.apache.org/jira/browse/FLINK-29389
Project
Yufei Zhang created FLINK-29390:
---
Summary: Pulsar SQL Connector: SQLClient E2E testing
Key: FLINK-29390
URL: https://issues.apache.org/jira/browse/FLINK-29390
Project: Flink
Issue Type: Sub-tas
Barisa created FLINK-29391:
--
Summary: Add option to set labels and annotations in kubernetes
deployment
Key: FLINK-29391
URL: https://issues.apache.org/jira/browse/FLINK-29391
Project: Flink
Issue
+1 That sounds like a good idea. Does it make sense to add a validation
step to prevent new configuration parameters from running into the same
issue (with whitelisting the existing ones)?
Matthias
On Thu, Sep 22, 2022 at 6:35 AM Yun Tang wrote:
> +1
>
> This is the prerequisite to help us to i
Gyula Fora created FLINK-29392:
--
Summary: SessionJobs are lost when Session FlinkDeployment is
upgraded without HA
Key: FLINK-29392
URL: https://issues.apache.org/jira/browse/FLINK-29392
Project: Flink
Gyula Fora created FLINK-29393:
--
Summary: Upgrade Kubernetes operator examples to use the latest
Flink base image
Key: FLINK-29393
URL: https://issues.apache.org/jira/browse/FLINK-29393
Project: Flink
+1 (non-binding)
* Check the checksums of released tar packages.
* Started the session cluster, and verified the commit tag in the web UI.
* Submitted a wordcount example in streaming and batch modes.
* Reviewed the flink web PR.
* Build the source code from the tag.
Best,
Yu
Gabor Somogyi created FLINK-29394:
-
Summary: Flink k8s operator observe Flink job restart count
Key: FLINK-29394
URL: https://issues.apache.org/jira/browse/FLINK-29394
Project: Flink
Issue Ty
Hong Liang Teoh created FLINK-29395:
---
Summary: [Kinesis][EFO] Issue using EFO consumer at timestamp with
empty shard
Key: FLINK-29395
URL: https://issues.apache.org/jira/browse/FLINK-29395
Project:
+1 (binding)
Please make also sure to update ExpressionReducer during implementation.
This is not mentioned in the FLIP yet.
Thanks,
Timo
On 22.09.22 10:41, Piotr Nowojski wrote:
+1 (binding)
czw., 22 wrz 2022 o 08:21 Lincoln Lee napisał(a):
Hi everyone,
Thanks for all your feedback for
Chesnay Schepler created FLINK-29396:
Summary: Race condition in JobMaster shutdown can leak resource
requirements
Key: FLINK-29396
URL: https://issues.apache.org/jira/browse/FLINK-29396
Project:
Chesnay Schepler created FLINK-29397:
Summary: Race condition in StreamTask can lead to NPE if changelog
is disabled
Key: FLINK-29397
URL: https://issues.apache.org/jira/browse/FLINK-29397
Project
Hi everyone,
I would like to start a discussion thread on FLIP-262 for a MongoDB Connector
that will support both
DataStream, Table API and SQL implementations with Lookup ability.
This would be a new connector in its own external repository being
https://www.github.com/apache/flink-connector-mo
Hi Jiabao,
Thanks for creating the FLIP. It looks like there's is enthusiasm for a
MongoDB connector so that's good.
What is also good to mention is that you have already prepared a PR at
https://github.com/apache/flink/pull/20848 - That would need to move to the
dedicated repository.
Overall +1
Jeremy DeGroot created FLINK-29398:
--
Summary: Utilize Rack Awareness in Flink Consumer
Key: FLINK-29398
URL: https://issues.apache.org/jira/browse/FLINK-29398
Project: Flink
Issue Type: Impr
Chesnay Schepler created FLINK-29399:
Summary: TableITCase is unstable
Key: FLINK-29399
URL: https://issues.apache.org/jira/browse/FLINK-29399
Project: Flink
Issue Type: Bug
Com
Dhruv Patel created FLINK-29400:
---
Summary: Default Value of env.log.max in documentation is incorrect
Key: FLINK-29400
URL: https://issues.apache.org/jira/browse/FLINK-29400
Project: Flink
Issu
+1 (binding)
Best,
Jingsong
On Thu, Sep 22, 2022 at 9:45 PM Timo Walther wrote:
>
> +1 (binding)
>
> Please make also sure to update ExpressionReducer during implementation.
> This is not mentioned in the FLIP yet.
>
> Thanks,
> Timo
>
> On 22.09.22 10:41, Piotr Nowojski wrote:
> > +1 (binding)
+1 (binding)
- Reviewed the flink-web PR
- Installed the PyFlink package and run a simple example successfully
- Verified the checksum and signature
Regards,
Dian
On Thu, Sep 22, 2022 at 8:36 PM Yun Tang wrote:
> +1 (non-binding)
>
>
> * Check the checksums of released tar packages.
> *
23 matches
Mail list logo
