Bo Cui created FLINK-32159:
--
Summary: Hudi Source throws NPE
Key: FLINK-32159
URL: https://issues.apache.org/jira/browse/FLINK-32159
Project: Flink
Issue Type: Bug
Affects Versions: 1.17.0, 1.16
+1 (non-binding)
- Checked signature/checksum [OK]
- Unpacked the src tar file, diffed with github tag [OK]
- Compiled from source with jdk 1.8.0_301 [OK]
- Started a local cluster, played with JDBC 3.1.0-1.17, mysql 8.0.28, for
some simple batch queries [OK]
- Gone through the release note [OK]
+1 (binding)
- Verified checksums and signatures
- Verified that no binary exist in the source archive
- Build the source with Maven
- Verified that README doesn't have unexpected contents
- Verified that the commit ID on Flink UI matches with the tag
- Run a job with SQL client that reads from a
qingbo jiao created FLINK-32158:
---
Summary: Unify the getMultiInputOperatorDefaultMeta and
getOneInputOperatorDefaultMeta methods into the same
getInputOperatorDefaultMeta method
Key: FLINK-32158
URL: https://issues
Hello Ran Tao,
Thanks for this FLIP.
I have a comment about the handover of switching context between sources.
You have proposed to define interfaces named around timestamps,
SupportsGetEndTimestamp
and SupportsSwitchedStartTimestamp.
These work well with KafkaSource as the downstream child sour
Matthias Pohl created FLINK-32157:
-
Summary: Replaces LeaderConnectionInfo with LeaderInformation
Key: FLINK-32157
URL: https://issues.apache.org/jira/browse/FLINK-32157
Project: Flink
Issue
cc user ML to get more attention, since the plugin will be used by Flink
application developers.
Best regards,
Jing
On Mon, May 22, 2023 at 3:32 PM Jing Ge wrote:
> Hi Emre,
>
> Thanks for clarifying it. Afaiac, it is a quite interesting proposal,
> especially for Flink job developers who are h
Hi all,
> For example, a user might want to read in logs, perform some aggregations
and publish it into a metrics store for visualisation. This might be a
great use-case for reducing the cardinality of metrics!
I can see that. What I would like to see in the FLIP is a proposal on the
boundaries o
Hi Emre,
Thanks for clarifying it. Afaiac, it is a quite interesting proposal,
especially for Flink job developers who are heavily using the Datastream
API. Publishing the plugin in your Github would be a feasible way for the
first move. As I mentioned previously, in order to help the community
un
+1(non-binding)
- Verified signatures
- Verified hashes
- Verified tag
- repos contain all necessary files
- built from source
- reviewed the PR
Best regards,
Jing
On Mon, May 22, 2023 at 1:32 PM Yun Tang wrote:
> +1 (non-binding)
>
>
> * Verified signatures.
> * Start a local standalo
+1 (binding)
- verify signatures and checksums
- verify python wheel package contents
- pip install apache-flink-libraries and apache-flink wheel packages
- run example flink/flink-python/pyflink/examples/table/basic_operations.py
with Python 3.7
- reviewed release blog post
Best,
Xingbo
Xintong
+1 (non-binding)
* Verified signatures.
* Start a local standalone cluster and checked the git revision number.
* Submit stateful examples both in BATCH and STREAMING mode successfully.
* Run a local sql-gateway.
* Reviewed the release flink-web PR.
Best
Yun Tang
Sergey Nuyanzin created FLINK-32156:
---
Summary: Int2AdaptiveHashJoinOperatorTest produced no output for
900s on AZP
Key: FLINK-32156
URL: https://issues.apache.org/jira/browse/FLINK-32156
Project: Fl
+1 (binding)
- verify signatures and checksums
- verify python wheel package contents
- pip install apache-flink-libraries and apache-flink wheel packages
- run example flink/flink-python/pyflink/examples/table/basic_operations.py
with Python 3.10
- reviewed release blog post
Best,
Xingbo
Yuxin
Sergey Nuyanzin created FLINK-32155:
---
Summary: Multiple CIs jobs failed due to "Could not connect to
azure.archive.ubuntu.com"
Key: FLINK-32155
URL: https://issues.apache.org/jira/browse/FLINK-32155
+1 (non-binding)
- verified the signatures
- verified the checksums
- built from source
- start a standalone cluster, run a simple batch and a streaming job
successfully
- review release announcement PR
Best,
Yuxin
Xintong Song 于2023年5月22日周一 18:24写道：
> +1 (binding)
>
> - verified signatures a
Chesnay Schepler created FLINK-32154:
Summary: Setup checkstyle rule to forbid mockito/powermock
Key: FLINK-32154
URL: https://issues.apache.org/jira/browse/FLINK-32154
Project: Flink
Iss
Chesnay Schepler created FLINK-32153:
Summary: Limit powermock to flink-core/-runtime
Key: FLINK-32153
URL: https://issues.apache.org/jira/browse/FLINK-32153
Project: Flink
Issue Type: Su
Chesnay Schepler created FLINK-32152:
Summary: Consolidate mocking library usage
Key: FLINK-32152
URL: https://issues.apache.org/jira/browse/FLINK-32152
Project: Flink
Issue Type: Sub-tas
+1 (binding)
- verified signatures and checksums
- built from source
- tried example jobs with a standalone cluster, everything seems fine
- review release announcement PR
Best,
Xintong
On Mon, May 22, 2023 at 2:18 PM weijie guo
wrote:
> Hi everyone,
>
>
> Please review and vote on the rele
Sergey Nuyanzin created FLINK-32151:
---
Summary: 'Run kubernetes pyflink application test' fails while
pulling image
Key: FLINK-32151
URL: https://issues.apache.org/jira/browse/FLINK-32151
Project: Fl
Sergey Nuyanzin created FLINK-32150:
---
Summary: ThreadDumpInfoTest crashed with exit code 239 on AZP
Key: FLINK-32150
URL: https://issues.apache.org/jira/browse/FLINK-32150
Project: Flink
Is
Chesnay Schepler created FLINK-32149:
Summary: Remove some unnecessary mocking usages
Key: FLINK-32149
URL: https://issues.apache.org/jira/browse/FLINK-32149
Project: Flink
Issue Type: Su
Gyula Fora created FLINK-32148:
--
Summary: Reduce info logging noise in the operator
Key: FLINK-32148
URL: https://issues.apache.org/jira/browse/FLINK-32148
Project: Flink
Issue Type: Improvement
Hi Jing,
The proposed plugin would be used by Flink application developers, when they
are writing their Flink job. It would trigger during compilation/packaging and
would look for known incompatibilities, bad practices, or bugs.
For instance one cause of frustration for our customers is connecto
Gyula Fora created FLINK-32147:
--
Summary: Deduplicate scaling report messages
Key: FLINK-32147
URL: https://issues.apache.org/jira/browse/FLINK-32147
Project: Flink
Issue Type: Improvement
Sergey Nuyanzin created FLINK-32146:
---
Summary: HiveTableSinkITCase crashed with exit code 239 on AZP
Key: FLINK-32146
URL: https://issues.apache.org/jira/browse/FLINK-32146
Project: Flink
I
Yun Tang created FLINK-32145:
Summary: Fix incorrect docker image links of specific versions in
flink-web site
Key: FLINK-32145
URL: https://issues.apache.org/jira/browse/FLINK-32145
Project: Flink
Sergey Nuyanzin created FLINK-32144:
---
Summary: FileSourceTextLinesITCase times out on AZP
Key: FLINK-32144
URL: https://issues.apache.org/jira/browse/FLINK-32144
Project: Flink
Issue Type:
+1 these things already popped up during the initial review by Chesnay, but
I wasn't able to visualize them in a way that didn't look completely awful
:)
I hope that someone will be able to pick this up.
Best,
D.
On Fri, May 19, 2023 at 1:30 PM Jing Ge wrote:
> Hi David,
>
> Thanks for driving
30 matches
Mail list logo
