Gao Fei created FLINK-29647:
---
Summary: report stackoverflow when using kryo
Key: FLINK-29647
URL: https://issues.apache.org/jira/browse/FLINK-29647
Project: Flink
Issue Type: Bug
sap1ens commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996211925
##
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecoratorTest.java:
##
sap1ens commented on PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#issuecomment-1279584573
> I agree, it would be nice to have comprehensive tests that actually test
the allowNonRestoredState logic. On the other hand if we simply enable that
flag on existing
gyfora commented on code in PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#discussion_r996141173
##
flink-kubernetes-standalone/src/test/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecoratorTest.java:
##
@@
gyfora commented on PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#issuecomment-127956
> > We should think of a way to test these in a reliable way. Testing the
parameters is not enough as might not be understood by the JM as you pointed
out.
> > Maybe
sap1ens commented on PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#issuecomment-1279307886
> We should think of a way to test these in a reliable way. Testing the
parameters is not enough as might not be understood by the JM as you pointed
out.
>
>
[
https://issues.apache.org/jira/browse/FLINK-20350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617883#comment-17617883
]
Danny Cranmer commented on FLINK-20350:
---
[~samrat007] yes please do, I will assign to you. Thanks!
[
https://issues.apache.org/jira/browse/FLINK-20350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-20350:
-
Assignee: Samrat Deb
> Incompatible Connectors due to Guava conflict
>
[
https://issues.apache.org/jira/browse/FLINK-20350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617877#comment-17617877
]
Samrat Deb commented on FLINK-20350:
[~danny.cranmer]
can i pick this task and try to fix it ?
Samrat002 commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1279234327
@dannycranmer
I removed `org.apache.hadoop:hadoop-mapreduce-client-core:3.1.0` from
`NOTICE`.
> Regarding "The bundled Apache Hive org.apache.hive:hive-exec dependency"
[
https://issues.apache.org/jira/browse/FLINK-12010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617844#comment-17617844
]
Danny Cranmer commented on FLINK-12010:
---
We introduced a new Sink in Flink 1.15 that does not use
[
https://issues.apache.org/jira/browse/FLINK-12010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-12010.
---
Resolution: Won't Do
> Kinesis Producer problems on Alpine Linux image
>
[
https://issues.apache.org/jira/browse/FLINK-20350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-20350:
--
Summary: Incompatible Connectors due to Guava conflict (was: [Kinesis][GCP
PubSub]
[
https://issues.apache.org/jira/browse/FLINK-21830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-21830.
---
Resolution: Won't Do
This does not make sense, since session tokens will expire. Resolving
[
https://issues.apache.org/jira/browse/FLINK-21228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-21228:
--
Summary: Deadlock in KinesisProducer (was: [Kinesis][Producer] Deadlock in
KinesisProducer)
[
https://issues.apache.org/jira/browse/FLINK-21830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-21830:
--
Summary: Add support for Session Token with Basic Auth (was:
[kinesis][auth] Add support for
[
https://issues.apache.org/jira/browse/FLINK-24549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-24549.
---
Resolution: Duplicate
Resolving as duplicate of FLINK-24943
> FlinkKinesisConsumer does
[
https://issues.apache.org/jira/browse/FLINK-23167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-23167.
---
Resolution: Won't Fix
> Port Kinesis Table API e2e tests to release-1.12 branch
>
[
https://issues.apache.org/jira/browse/FLINK-23167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617841#comment-17617841
]
Danny Cranmer commented on FLINK-23167:
---
1.12 is now out of support, resolving as won't do
> Port
[
https://issues.apache.org/jira/browse/FLINK-24549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-24549:
--
Fix Version/s: (was: 1.17.0)
> FlinkKinesisConsumer does not work with generic types
[
https://issues.apache.org/jira/browse/FLINK-24913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617839#comment-17617839
]
Danny Cranmer commented on FLINK-24913:
---
Given that we added a new Kinesis Sink in Flink 1.15 that
[
https://issues.apache.org/jira/browse/FLINK-24913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-24913.
---
Resolution: Won't Do
> Upgrade KPL version in flink-connector-kinesis to support ARM
>
dannycranmer commented on PR #20257:
URL: https://github.com/apache/flink/pull/20257#issuecomment-1279205494
@Cyberness please also squash commits and update commit message as per the
[contribution
[
https://issues.apache.org/jira/browse/FLINK-25729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-25729.
---
Resolution: Duplicate
> Replace the deprecated FlinkKinesisConsumer with a Kinesis Consumer
[
https://issues.apache.org/jira/browse/FLINK-25729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617831#comment-17617831
]
Danny Cranmer commented on FLINK-25729:
---
Yes I believe so, resolving this as duplicate
> Replace
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r995921557
##
flink-core/src/main/java/org/apache/flink/api/connector/source/SourceReaderFactory.java:
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/FLINK-26657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617828#comment-17617828
]
Danny Cranmer commented on FLINK-26657:
---
Resolving as "won't do" due to inactivity
> Resilient
[
https://issues.apache.org/jira/browse/FLINK-26657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-26657.
---
Resolution: Won't Do
> Resilient Kinesis consumption
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617811#comment-17617811
]
Kevin Li commented on FLINK-29572:
--
No, it wouldn't. This problem happens for K8s deployment. For K8s,
flinkbot commented on PR #21075:
URL: https://github.com/apache/flink/pull/21075#issuecomment-1279137259
## CI report:
* cdc2a58e9c51cd7c6e9293b4cd1418f9ccd5c374 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-26027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-26027:
Fix Version/s: 1.17.0
> Add FLIP-33 metrics to new PulsarSink
>
[
https://issues.apache.org/jira/browse/FLINK-29633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29633:
---
Priority: Critical (was: Major)
> Operator doesn't pass initialSavepointPath as fromSavepoint
syhily opened a new pull request, #21075:
URL: https://github.com/apache/flink/pull/21075
## What is the purpose of the change
PulsarUnorderedSourceReader should close all the pending transaction before
shutdown.
## Brief change log
1. Close the finished splits related
XComp merged PR #18760:
URL: https://github.com/apache/flink/pull/18760
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
XComp commented on PR #18760:
URL: https://github.com/apache/flink/pull/18760#issuecomment-1279106087
Only documentation was affected. I'm gonna merge right away without waiting
for CI.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Description:
sql gateway Should return simpler exception information
for example:
If i execute a
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Description:
sql gateway should return simpler exception information
for example:
If i execute a
RyanSkraba commented on PR #18760:
URL: https://github.com/apache/flink/pull/18760#issuecomment-1279095126
Rebased, squashed into one commit and fixed merge conflicts. Can you take a
look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
yuanfenghu created FLINK-29646:
--
Summary: SQL Gateway should return a simpler error message
Key: FLINK-29646
URL: https://issues.apache.org/jira/browse/FLINK-29646
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Description:
sql gateway Should return simpler exception information
for example:
If i execute a
flinkbot commented on PR #21074:
URL: https://github.com/apache/flink/pull/21074#issuecomment-1279082363
## CI report:
* 6004175f2aa10d2d805a3a575e5efa0954482d1d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-26822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617758#comment-17617758
]
Etienne Chauchot commented on FLINK-26822:
--
As promised, I have developed the Cassandra source
[
https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-28959:
Affects Version/s: (was: 1.14.5)
> 504 gateway timeout when consume large number of topics
[
https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-28959:
Fix Version/s: (was: 1.14.7)
> 504 gateway timeout when consume large number of topics using
flinkbot commented on PR #21073:
URL: https://github.com/apache/flink/pull/21073#issuecomment-1279069831
## CI report:
* 39b9a1b91a23296082e30e64ffeba6a838805952 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
syhily opened a new pull request, #21074:
URL: https://github.com/apache/flink/pull/21074
## What is the purpose of the change
PulsarSink is slow when we use the `At-Least-Once` or `Exactly-Once`. This
is because PulsarSink uses `MallboxExecutor` to write messages. A lot of
useless
[
https://issues.apache.org/jira/browse/FLINK-26822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26822:
---
Labels: pull-request-available (was: )
> Add Source implementation for Cassandra connector
echauchot opened a new pull request, #21073:
URL: https://github.com/apache/flink/pull/21073
## What is the purpose of the change
Add a flink source for Cassandra database compliant with
[FLIP-27](https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface)
flinkbot commented on PR #21072:
URL: https://github.com/apache/flink/pull/21072#issuecomment-1279052707
## CI report:
* 647e279d5e4295d56ecc58184870317a6a67b1db UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21071:
URL: https://github.com/apache/flink/pull/21071#issuecomment-1279044483
## CI report:
* df6929923a7dbc1d868e7dc5e4533213050378f6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r995787574
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
[
https://issues.apache.org/jira/browse/FLINK-28960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28960:
---
Labels: pull-request-available (was: )
> Pulsar throws java.lang.NoClassDefFoundError:
>
syhily opened a new pull request, #21072:
URL: https://github.com/apache/flink/pull/21072
## What is the purpose of the change
`pulsar-client-all` requires jaxb-api to serialize some Admin API. We
shouldn't exclude it in current dependency list. So we just add it back to
gyfora commented on PR #403:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/403#issuecomment-1279035826
We should think of a way to test these in a reliable way. Testing the
parameters is not enough as might not be understood by the JM as you pointed
out.
Maybe we
[
https://issues.apache.org/jira/browse/FLINK-29401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29401.
--
Resolution: Fixed
merged to main bca630c3a003149683b74a54ccd376f9a9691028
> Improve observer
flinkbot commented on PR #21070:
URL: https://github.com/apache/flink/pull/21070#issuecomment-1279033294
## CI report:
* 757289c8fafe5f687f5772b7ce45d4f1cf7e5f55 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora merged PR #400:
URL: https://github.com/apache/flink-kubernetes-operator/pull/400
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-29433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29433:
---
Labels: pull-request-available (was: )
> Support Auth through the builder pattern in
syhily opened a new pull request, #21071:
URL: https://github.com/apache/flink/pull/21071
## What is the purpose of the change
Authentication is a common used function in consuming/producing message
between Pulsar and Flink. We didn't expose it to Builder method, and use the
common
[
https://issues.apache.org/jira/browse/FLINK-29512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul resolved FLINK-29512.
-
Fix Version/s: 1.17.0
1.15.3
1.16.1
Resolution:
[
https://issues.apache.org/jira/browse/FLINK-29512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617734#comment-17617734
]
Fabian Paul commented on FLINK-29512:
-
Merged into:
master:
fapaul merged PR #21063:
URL: https://github.com/apache/flink/pull/21063
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
fapaul merged PR #21062:
URL: https://github.com/apache/flink/pull/21062
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
fapaul merged PR #21022:
URL: https://github.com/apache/flink/pull/21022
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-29433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-29433:
Affects Version/s: 1.17.0
(was: 1.16.0)
> Support Auth through the
[
https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29580:
---
Labels: pull-request-available (was: )
>
syhily opened a new pull request, #21070:
URL: https://github.com/apache/flink/pull/21070
## What is the purpose of the change
The config option `pulsar.consumer.autoUpdatePartitionsIntervalSeconds` in
Pulsar connector is conflict with Flink's split discovery logic and useless. We
[
https://issues.apache.org/jira/browse/FLINK-29536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29536:
---
Fix Version/s: (was: kubernetes-operator-1.2.0)
> Add WATCH_NAMESPACES env var to kubernetes
[
https://issues.apache.org/jira/browse/FLINK-29550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29550.
--
Resolution: Cannot Reproduce
The examples are mainly designed for minikube, other kubernetes envs may
[
https://issues.apache.org/jira/browse/FLINK-29566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617730#comment-17617730
]
Gyula Fora commented on FLINK-29566:
I think this improvement makes sense :)
> Reschedule the
[
https://issues.apache.org/jira/browse/FLINK-29550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29550:
---
Affects Version/s: (was: 1.15.0)
> example "basic-checkpoint-ha.yaml" not working
>
Piotr Nowojski created FLINK-29645:
--
Summary: BatchExecutionKeyedStateBackend is using incorrect
ExecutionConfig when creating serializer
Key: FLINK-29645
URL: https://issues.apache.org/jira/browse/FLINK-29645
[
https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617729#comment-17617729
]
Gyula Fora commented on FLINK-29634:
I think savepoint history is mostly important so that the
flinkbot commented on PR #21069:
URL: https://github.com/apache/flink/pull/21069#issuecomment-1278989774
## CI report:
* 7d89bb64116b99d895edf1df5cba443715b1f710 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Gyula Fora created FLINK-29644:
--
Summary: Reference Kubernetes operator from Flink Kubernetes
deploy docs
Key: FLINK-29644
URL: https://issues.apache.org/jira/browse/FLINK-29644
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29613:
---
Labels: pull-request-available (was: )
> Wrong message size assertion in Pulsar's batch
syhily opened a new pull request, #21069:
URL: https://github.com/apache/flink/pull/21069
## What is the purpose of the change
Pulsar did a wrong batch message size assertion in code. We require every
batch message should have size 1. But sometimes the message size could be 0 due
to
[
https://issues.apache.org/jira/browse/FLINK-29632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29632.
--
Fix Version/s: kubernetes-operator-1.3.0
Resolution: Fixed
merged to main
gyfora merged PR #402:
URL: https://github.com/apache/flink-kubernetes-operator/pull/402
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r995726266
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
Nico Kruber created FLINK-29643:
---
Summary: Possible NPE in ApplicationDispatcherBootstrap with
failedJob submission and no HA
Key: FLINK-29643
URL: https://issues.apache.org/jira/browse/FLINK-29643
fapaul commented on PR #21022:
URL: https://github.com/apache/flink/pull/21022#issuecomment-1278933763
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617676#comment-17617676
]
Thomas Weise commented on FLINK-29634:
--
[~Jiale] that PR it the right place to look at wrt how
[
https://issues.apache.org/jira/browse/FLINK-13876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617675#comment-17617675
]
Piotr Nowojski commented on FLINK-13876:
I'm not sure, but if this is a really issue, that's not
zentol merged PR #21057:
URL: https://github.com/apache/flink/pull/21057
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
zentol closed pull request #20997: fix(sec): upgrade org.apache.hive:hive-exec
to 3.1.3
URL: https://github.com/apache/flink/pull/20997
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
snuyanzin commented on PR #21064:
URL: https://github.com/apache/flink/pull/21064#issuecomment-1278910720
@flinkbot run azure
failure seems related to https://issues.apache.org/jira/browse/FLINK-29387
--
This is an automated message from the Apache Git Service.
To respond to the
zentol commented on code in PR #21056:
URL: https://github.com/apache/flink/pull/21056#discussion_r995678770
##
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##
@@ -148,6 +148,19 @@ public class ExecutionConfig implements Serializable,
Archiveable
afedulov commented on PR #20757:
URL: https://github.com/apache/flink/pull/20757#issuecomment-1278903252
@zentol I modified the docs according to your proposals, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
zentol commented on code in PR #21056:
URL: https://github.com/apache/flink/pull/21056#discussion_r995676246
##
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##
@@ -756,7 +811,27 @@ public GlobalJobParameters getGlobalJobParameters() {
*/
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r995674703
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r995674573
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r995674275
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r995671986
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
[
https://issues.apache.org/jira/browse/FLINK-29619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29619.
--
Resolution: Fixed
merged to main f1387f723da3f274bcb3268d401d91042064255d
> Remove redundant
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r995657759
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
gyfora merged PR #401:
URL: https://github.com/apache/flink-kubernetes-operator/pull/401
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-29641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617651#comment-17617651
]
Weijie Guo commented on FLINK-29641:
[~mapohl] Thank you for your report and investigation,I will
klion26 commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r995430467
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r995629891
##
docs/content/docs/connectors/datastream/datagen.md:
##
@@ -0,0 +1,115 @@
+---
+title: DataGen
+weight: 3
+type: docs
+---
+
+
+# DataGen Connector
+
+The DataGen
1 - 100 of 209 matches
Mail list logo
