Re: [VOTE] Release 1.17.1, release candidate #1

2023-05-22 Thread Qingsheng Ren
+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

[jira] [Created] (FLINK-32158) Unify the getMultiInputOperatorDefaultMeta and getOneInputOperatorDefaultMeta methods into the same getInputOperatorDefaultMeta method

2023-05-22 Thread qingbo jiao (Jira)
qingbo jiao created FLINK-32158: --- Summary: Unify the getMultiInputOperatorDefaultMeta and getOneInputOperatorDefaultMeta methods into the same getInputOperatorDefaultMeta method Key: FLINK-32158 URL:

Re: [DISCUSS] FLIP-278: Hybrid Source Connector

2023-05-22 Thread Raman Verma
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

[jira] [Created] (FLINK-32157) Replaces LeaderConnectionInfo with LeaderInformation

2023-05-22 Thread Matthias Pohl (Jira)
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

Re: Maven plugin to detect issues early on

2023-05-22 Thread Jing Ge
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

Re: [DISCUSS] FLIP-229: Prometheus Sink Connector

2023-05-22 Thread Martijn Visser
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

Re: Maven plugin to detect issues early on

2023-05-22 Thread Jing Ge
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

Re: [VOTE] Release 1.17.1, release candidate #1

2023-05-22 Thread Jing Ge
+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

Re: [VOTE] Release 1.16.2, release candidate #1

2023-05-22 Thread Xingbo Huang
+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

Re: [VOTE] Release 1.17.1, release candidate #1

2023-05-22 Thread Yun Tang
+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

[jira] [Created] (FLINK-32156) Int2AdaptiveHashJoinOperatorTest produced no output for 900s on AZP

2023-05-22 Thread Sergey Nuyanzin (Jira)
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:

Re: [VOTE] Release 1.17.1, release candidate #1

2023-05-22 Thread Xingbo Huang
+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

[jira] [Created] (FLINK-32155) Multiple CIs jobs failed due to "Could not connect to azure.archive.ubuntu.com"

2023-05-22 Thread Sergey Nuyanzin (Jira)
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

Re: [VOTE] Release 1.17.1, release candidate #1

2023-05-22 Thread Yuxin Tan
+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

[jira] [Created] (FLINK-32154) Setup checkstyle rule to forbid mockito/powermock

2023-05-22 Thread Chesnay Schepler (Jira)
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

[jira] [Created] (FLINK-32153) Limit powermock to flink-core/-runtime

2023-05-22 Thread Chesnay Schepler (Jira)
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:

[jira] [Created] (FLINK-32152) Consolidate mocking library usage

2023-05-22 Thread Chesnay Schepler (Jira)
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:

Re: [VOTE] Release 1.17.1, release candidate #1

2023-05-22 Thread Xintong Song
+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

[jira] [Created] (FLINK-32151) 'Run kubernetes pyflink application test' fails while pulling image

2023-05-22 Thread Sergey Nuyanzin (Jira)
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:

[jira] [Created] (FLINK-32150) ThreadDumpInfoTest crashed with exit code 239 on AZP

2023-05-22 Thread Sergey Nuyanzin (Jira)
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

[jira] [Created] (FLINK-32149) Remove some unnecessary mocking usages

2023-05-22 Thread Chesnay Schepler (Jira)
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:

[jira] [Created] (FLINK-32148) Reduce info logging noise in the operator

2023-05-22 Thread Gyula Fora (Jira)
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:

Re: Maven plugin to detect issues early on

2023-05-22 Thread Kartoglu, Emre
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

[jira] [Created] (FLINK-32147) Deduplicate scaling report messages

2023-05-22 Thread Gyula Fora (Jira)
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

[jira] [Created] (FLINK-32146) HiveTableSinkITCase crashed with exit code 239 on AZP

2023-05-22 Thread Sergey Nuyanzin (Jira)
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

[jira] [Created] (FLINK-32145) Fix incorrect docker image links of specific versions in flink-web site

2023-05-22 Thread Yun Tang (Jira)
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

[jira] [Created] (FLINK-32144) FileSourceTextLinesITCase times out on AZP

2023-05-22 Thread Sergey Nuyanzin (Jira)
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:

Re: Call for help on the Web UI (In-Place Rescaling)

2023-05-22 Thread David Morávek
+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

[VOTE] Release 1.17.1, release candidate #1

2023-05-22 Thread weijie guo
Hi everyone, Please review and vote on the release candidate #1 for the version 1.17.1, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release

Troubleshooting pyflink import error regarding Json, Kafka, Substring, DataTypes and FileSystem libraries

2023-05-22 Thread Alireza Omidvar
Gentlemen, I don't if dev is the right place to ask questions about pyflink mismatch problems. If this is not the case kindly guide me where can i register to ask these matters. I have problem with some apache-flink modules. I am running a 1.17.0 apache- flink and I write codes in Colab I faced