[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761442#comment-17761442
]
Arseniy Tashoyan commented on FLINK-30530:
--
I would say that default config is a different
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677432#comment-17677432
]
Arseniy Tashoyan edited comment on FLINK-30530 at 1/19/23 9:16 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677432#comment-17677432
]
Arseniy Tashoyan commented on FLINK-30530:
--
Helm chart is a complementary tool, but not a
[
https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655112#comment-17655112
]
Arseniy Tashoyan edited comment on FLINK-21383 at 1/5/23 8:04 PM:
--
One
[
https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655112#comment-17655112
]
Arseniy Tashoyan edited comment on FLINK-21383 at 1/5/23 7:39 PM:
--
One
[
https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655112#comment-17655112
]
Arseniy Tashoyan edited comment on FLINK-21383 at 1/5/23 7:38 PM:
--
One
[
https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655112#comment-17655112
]
Arseniy Tashoyan commented on FLINK-21383:
--
One more problem caused by this issue: it is
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653159#comment-17653159
]
Arseniy Tashoyan edited comment on FLINK-30530 at 12/30/22 4:43 PM:
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653159#comment-17653159
]
Arseniy Tashoyan commented on FLINK-30530:
--
Hi [~gyfora]
The YAML descriptor contains
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-30530:
-
Description:
Currently the Flink configuration can be specified in the YAML descriptor
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-30530:
-
Description:
Currently the Flink configuration can be specified in the YAML descriptor
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-30530:
-
Description:
Currently the Flink configuration can be specified in the YAML descriptor
Arseniy Tashoyan created FLINK-30530:
Summary: Flink configuration from user-provided ConfigMap
Key: FLINK-30530
URL: https://issues.apache.org/jira/browse/FLINK-30530
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17600693#comment-17600693
]
Arseniy Tashoyan commented on FLINK-29144:
--
[~gyfora] now I'm a bit overloaded, but maybe a
Arseniy Tashoyan created FLINK-29206:
Summary: Default Flink configuration contains irrelevant settings
Key: FLINK-29206
URL: https://issues.apache.org/jira/browse/FLINK-29206
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598037#comment-17598037
]
Arseniy Tashoyan edited comment on FLINK-29144 at 8/30/22 7:56 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598037#comment-17598037
]
Arseniy Tashoyan commented on FLINK-29144:
--
Although _flinkConfiguration.pipeline.jars_
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598035#comment-17598035
]
Arseniy Tashoyan edited comment on FLINK-29144 at 8/30/22 7:48 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598035#comment-17598035
]
Arseniy Tashoyan commented on FLINK-29144:
--
Then, how do you suggest merging values from
[
https://issues.apache.org/jira/browse/FLINK-29145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-29145:
-
Description:
When running a FlinkDeployment, we can see error messages:
{code:none}
[
https://issues.apache.org/jira/browse/FLINK-29145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-29145:
-
Description:
When running a FlinkDeployment, we can see error messages:
{code:none}
[
https://issues.apache.org/jira/browse/FLINK-29145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598030#comment-17598030
]
Arseniy Tashoyan commented on FLINK-29145:
--
This script is in another repository:
Arseniy Tashoyan created FLINK-29145:
Summary: docker-entrypoint.sh - Read-only file system
Key: FLINK-29145
URL: https://issues.apache.org/jira/browse/FLINK-29145
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17597873#comment-17597873
]
Arseniy Tashoyan commented on FLINK-29144:
--
For API compatibility, we can preserve the old
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-29144:
-
Description:
The setting _job.jarURI_ accepts a string with the path to the jar-file:
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-29144:
-
Description:
The setting _job.jarURI_ accepts a string with the path to the jar-file:
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-29144:
-
Affects Version/s: 1.15.2
1.16.0
(was:
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-29144:
-
Description:
The setting _job.jarURI_ accepts a string with the path to the jar-file:
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-29144:
-
Description:
The setting _job.jarURI_ accepts a string with the path to the jar-file:
[
https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-29144:
-
Description:
The setting _job.jarURI_ accepts a string with the path to the jar-file:
Arseniy Tashoyan created FLINK-29144:
Summary: Enable multiple jar entries for jarURI
Key: FLINK-29144
URL: https://issues.apache.org/jira/browse/FLINK-29144
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-28383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-28383:
-
Description:
This problem occurs when reading Avro files from HDFS. Flink is not able
[
https://issues.apache.org/jira/browse/FLINK-28383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-28383:
-
Description:
This problem occurs when reading Avro files from HDFS. Flink is not able
Arseniy Tashoyan created FLINK-28383:
Summary: HDFS source: Trying to access closed classloader
Key: FLINK-28383
URL: https://issues.apache.org/jira/browse/FLINK-28383
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560852#comment-17560852
]
Arseniy Tashoyan commented on FLINK-27487:
--
Hi [~fpaul]
Should we apply the same fix to
Title: Message Title
Arseniy Tashoyan
Title: Message Title
Arseniy Tashoyan
Title: Message Title
Arseniy Tashoyan
[
https://issues.apache.org/jira/browse/FLINK-28266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-28266:
-
Description:
The failure occurs when reading from a Kafka topic using new KafkaSource
Arseniy Tashoyan created FLINK-28266:
Summary: Kafka connector fails: Invalid negative offset
Key: FLINK-28266
URL: https://issues.apache.org/jira/browse/FLINK-28266
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24851:
-
Affects Version/s: 1.15.0
> KafkaSourceBuilder: auto.offset.reset is ignored
>
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24850:
-
Affects Version/s: 1.15.0
> KafkaSinkBuilder: NullPointerException if bootstrap.servers
[
https://issues.apache.org/jira/browse/FLINK-28188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan closed FLINK-28188.
Release Note:
This is applicable for plugin.classloader.parent-first-patterns.default,
[
https://issues.apache.org/jira/browse/FLINK-28188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-28188:
-
Description:
The documentation provides a wrong value:
Arseniy Tashoyan created FLINK-28188:
Summary: Documentation: Wrong default value for
classloader.parent-first-patterns.default
Key: FLINK-28188
URL: https://issues.apache.org/jira/browse/FLINK-28188
[
https://issues.apache.org/jira/browse/FLINK-26826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-26826:
-
Affects Version/s: 1.13.6
> env.readFile() fails if auto-generated UIDs disabled
>
Arseniy Tashoyan created FLINK-26826:
Summary: env.readFile() fails if auto-generated UIDs disabled
Key: FLINK-26826
URL: https://issues.apache.org/jira/browse/FLINK-26826
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446571#comment-17446571
]
Arseniy Tashoyan commented on FLINK-24850:
--
It is linked to this issue:
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445000#comment-17445000
]
Arseniy Tashoyan commented on FLINK-24851:
--
[~renqs] thank you for your proposal - looks good
[
https://issues.apache.org/jira/browse/FLINK-24727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444996#comment-17444996
]
Arseniy Tashoyan commented on FLINK-24727:
--
[~guoyangze] thank you for this pointer.
I have
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444769#comment-17444769
]
Arseniy Tashoyan commented on FLINK-24851:
--
I proposed the same behavior for KafkaSinkBuilder:
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444753#comment-17444753
]
Arseniy Tashoyan commented on FLINK-23972:
--
[~trohrmann] yes, the option '-C / --classpath'
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443960#comment-17443960
]
Arseniy Tashoyan commented on FLINK-24851:
--
I propose the following precedence rule: settings
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443949#comment-17443949
]
Arseniy Tashoyan commented on FLINK-24897:
--
[~bgeng777] there is a similar ticket for the Job
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443941#comment-17443941
]
Arseniy Tashoyan commented on FLINK-24851:
--
I mean the situation, when we specify all Kafka
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24850:
-
Description:
Let's create KafkaSink:
{code:scala}
val props = new Properties()
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24850:
-
Description:
Let's create KafkaSink:
{code:scala}
val props = new Properties()
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24850:
-
Description:
Let's create KafkaSink:
{code:scala}
val props = new Properties()
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24850:
-
Description:
Let's create KafkaSink:
{code:scala}
val props = new Properties()
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24850:
-
Description:
Let's create KafkaSink:
{code:scala}
val props = new Properties()
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24851:
-
Description:
Creating KafkaSource like this:
{code:scala}
val props = new
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24851:
-
Description:
Creating KafkaSource like this:
{code:scala}
val props = new
Arseniy Tashoyan created FLINK-24851:
Summary: KafkaSourceBuilder: auto.offset.reset is ignored
Key: FLINK-24851
URL: https://issues.apache.org/jira/browse/FLINK-24851
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24850:
-
Description:
Let's create KafkaSink:
{code:scala}
val props = new Properties()
[
https://issues.apache.org/jira/browse/FLINK-24850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-24850:
-
Description:
Let's create KafkaSink:
{code:scala}
val props = new Properties()
Arseniy Tashoyan created FLINK-24850:
Summary: KafkaSinkBuilder: NullPointerException if
bootstrap.servers are defined via properties
Key: FLINK-24850
URL: https://issues.apache.org/jira/browse/FLINK-24850
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439885#comment-17439885
]
Arseniy Tashoyan commented on FLINK-23972:
--
A non-working automated test for this feature:
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-19930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408346#comment-17408346
]
Arseniy Tashoyan edited comment on FLINK-19930 at 9/1/21, 7:31 PM:
---
It
[
https://issues.apache.org/jira/browse/FLINK-19930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408346#comment-17408346
]
Arseniy Tashoyan edited comment on FLINK-19930 at 9/1/21, 7:30 PM:
---
It
[
https://issues.apache.org/jira/browse/FLINK-19930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408346#comment-17408346
]
Arseniy Tashoyan commented on FLINK-19930:
--
It would be convenient to configure the settings of
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Environment: Flink 1.12.4 or 1.13.2 on YARN (was: Flink 1.12.4 or 1.13.2
YARN
Running
[
https://issues.apache.org/jira/browse/FLINK-23972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arseniy Tashoyan updated FLINK-23972:
-
Description:
Flink provides a way to inject additional jars into the classpath of the
Arseniy Tashoyan created FLINK-23972:
Summary: NoClassDefFoundError: Jars from yarn.ship-files are
missing in the classpath of the client
Key: FLINK-23972
URL:
[
https://issues.apache.org/jira/browse/FLINK-19930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400287#comment-17400287
]
Arseniy Tashoyan edited comment on FLINK-19930 at 8/17/21, 12:18 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-19930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400287#comment-17400287
]
Arseniy Tashoyan commented on FLINK-19930:
--
The current flink-connector-cassandra is packaged
Arseniy Tashoyan created FLINK-12044:
Summary: Flink CEP discards events as late if they have timestamps
<= 0
Key: FLINK-12044
URL: https://issues.apache.org/jira/browse/FLINK-12044
Project:
86 matches
Mail list logo
