To answer your questions:
1) yes, see https://issues.apache.org/jira/browse/FLINK-23221
2) Once an upstream image with the fix was released we will try to
release new images ASAP.
3) No, there's nothing to do on the Flink side.
4) No, we only have the debian-based images.
On 02/08/2021 16:40,
loyi created FLINK-23595:
Summary: Allow JSON format deserialize non-numeric numbers
Key: FLINK-23595
URL: https://issues.apache.org/jira/browse/FLINK-23595
Project: Flink
Issue Type: Improvement
zhouwenyang created FLINK-23596:
---
Summary: flink on k8s can create more than one instance
Key: FLINK-23596
URL: https://issues.apache.org/jira/browse/FLINK-23596
Project: Flink
Issue Type: New
zoucao created FLINK-23597:
--
Summary: support Add Jar in Table api
Key: FLINK-23597
URL: https://issues.apache.org/jira/browse/FLINK-23597
Project: Flink
Issue Type: Improvement
Reporter
+1 (binding)
Although I still think all the set* methods should accept a Supplier
instead of a Gauge.
On 02/08/2021 12:36, Becket Qin wrote:
+1 (binding).
Thanks for driving the efforts, Arvid.
Cheers,
Jiangjie (Becket) Qin
On Sat, Jul 31, 2021 at 12:08 PM Steven Wu wrote:
+1 (non-bind
nihileon created FLINK-23598:
Summary: DataOutputSerializer.writeBytes updates position twice
Key: FLINK-23598
URL: https://issues.apache.org/jira/browse/FLINK-23598
Project: Flink
Issue Type: Bu
Zhilong Hong created FLINK-23599:
Summary: Remove JobVertex#connectIdInput
Key: FLINK-23599
URL: https://issues.apache.org/jira/browse/FLINK-23599
Project: Flink
Issue Type: Technical Debt
Hi Devs,
In some discussions that popped up during reviewing the code, we decided to
rename this effort from clumsy "Dynamic buffer size adjustment" or
"Automatic in-flight data control", to "Buffer debloat". First of all,
bufferbloat is already an established name for this problem that we are
try
Tzu-Li (Gordon) Tai created FLINK-23600:
---
Summary: Rework StateFun's remote module parsing and binding
Key: FLINK-23600
URL: https://issues.apache.org/jira/browse/FLINK-23600
Project: Flink
Dawid Wysakowicz created FLINK-23601:
Summary: TPC-DS end-to-end test fail with "File upload failed."
Key: FLINK-23601
URL: https://issues.apache.org/jira/browse/FLINK-23601
Project: Flink
I am trying to build the Apache Flink project on my local machine and it seems
like failing due to spotless issues.
I am running the build on mac with java 8
xyz% java -version
java version "1.8.0_301"
Java(TM) SE Runtime Environment (build 1.8.0_301-b09)
Java HotSpot(TM) 64-Bit Server VM (bu
You are not using java 8, as shown by your maven output.
We have not made sure yet that Flink can be built on Java 16.
On 03/08/2021 12:00, Muhammad Haseeb Asif wrote:
I am trying to build the Apache Flink project on my local machine and it seems
like failing due to spotless issues.
I am runn
Hi Team,
Every email is hitting my email box bhagi.ramaha...@gmail.com.
I already unsubscribed from all Support Email id's.
Please check and resolve this issue.
xiaojin.wy created FLINK-23602:
--
Summary: org.codehaus.commons.compiler.CompileException: Line 84,
Column 78: No applicable constructor/method found for actual parameters
"org.apache.flink.table.data.DecimalData
Key: FLINK-23602
Follow the instructions at
https://www.apache.org/foundation/mailinglists.html#request-addresses-for-unsubscribing
to figure out which mail addresses was recorded for your subscription,
and then send mail to dev-unsubscribe-user=@flink.apache.org.
On 03/08/2021 12:16, R Bhaaagi wrote:
Hi Team
Thanks, Appreciate the quick turnaround.
I had to set up the $JAVA_HOME$ to 1.8 version so that maven can pick up that
version and it started building for me. Thanks
From: Chesnay Schepler
Sent: 03 August 2021 12:05:49
To: dev@flink.apache.org; Muhammad Haseeb
+1 (binding)
On Tue, Aug 3, 2021 at 12:58 AM Chesnay Schepler wrote:
> +1 (binding)
>
> Although I still think all the set* methods should accept a Supplier
> instead of a Gauge.
>
> On 02/08/2021 12:36, Becket Qin wrote:
> > +1 (binding).
> >
> > Thanks for driving the efforts, Arvid.
> >
> > C
@Becket Qin @Thomas Weise would you
also agree to @Chesnay Schepler 's proposal?
I think the main intention is to only use a Gauge when the exact metric is
exposed. For any partial value that may be used in an internal/predefined
metric, we would only use a supplier instead of a Gauge.
So a co
liuhong created FLINK-23603:
---
Summary:
动态查询sql后，使用toAppendStream将动态表转化为流时报错，org.apache.flink.table.api.TableException
Key: FLINK-23603
URL: https://issues.apache.org/jira/browse/FLINK-23603
Project: Flink
hehuiyuan created FLINK-23604:
-
Summary: 'csv.disable-quote-character' can not take effect during
deserialization for old csv format
Key: FLINK-23604
URL: https://issues.apache.org/jira/browse/FLINK-23604
JasonLee created FLINK-23605:
Summary: An exception was thrown when the metric was reported by
PrometheusPushGatewayReporter
Key: FLINK-23605
URL: https://issues.apache.org/jira/browse/FLINK-23605
Project
Dawid Wysakowicz created FLINK-23606:
Summary: Add safety guards in StreamTask(s) if a global failover
for a synchronous savepoint should've happen
Key: FLINK-23606
URL: https://issues.apache.org/jira/browse/F
Roman Khachatryan created FLINK-23607:
-
Summary: Cleanup unnecessary dependencies in dstl pom.xml
Key: FLINK-23607
URL: https://issues.apache.org/jira/browse/FLINK-23607
Project: Flink
Is
Hi David,
Thanks for the reply. I tried with Beam 2.29 and Flink 1.12 and
still getting NullPointerException like before. I changed the code a bit to
remove all the proprietary software used in our company and able to reproduce
the issue with local Kafka, Beam with Flink runner r
张祥兵 created FLINK-23608:
---
Summary:
org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a
suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory
Key: FLINK-23608
URL: https://
xiaojin.wy created FLINK-23609:
--
Summary: Codeine error of "Infinite or NaN at
java.math.BigDecimal.(BigDecimal.java:898)"
Key: FLINK-23609
URL: https://issues.apache.org/jira/browse/FLINK-23609
Project
Xintong Song created FLINK-23610:
Summary:
DefaultSchedulerTest.testProducedPartitionRegistrationTimeout fails on azure
Key: FLINK-23610
URL: https://issues.apache.org/jira/browse/FLINK-23610
Project:
Xintong Song created FLINK-23611:
Summary:
YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots
hangs on azure
Key: F
Caizhi Weng created FLINK-23612:
---
Summary: SELECT ROUND(CAST(1.2345 AS FLOAT), 1) cannot compile
Key: FLINK-23612
URL: https://issues.apache.org/jira/browse/FLINK-23612
Project: Flink
Issue Typ
Personally speaking, it is intuitive for me to set a gauge in MetricGroup.
So I am fine with set*Gauge pattern as long as the method is in
*MetricGroup class.
Thanks,
Jiangjie (Becket) Qin
On Tue, Aug 3, 2021 at 7:24 PM Arvid Heise wrote:
> @Becket Qin @Thomas Weise would
> you
> also agree
Ward Harris created FLINK-23613:
---
Summary: debezium and canal support read medata op and type
Key: FLINK-23613
URL: https://issues.apache.org/jira/browse/FLINK-23613
Project: Flink
Issue Type:
31 matches
Mail list logo
