[
https://issues.apache.org/jira/browse/FLINK-27554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536970#comment-17536970
]
Xintong Song edited comment on FLINK-27554 at 5/14/22 5:42 AM:
---
I've made
[
https://issues.apache.org/jira/browse/FLINK-27554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536970#comment-17536970
]
Xintong Song commented on FLINK-27554:
--
I've made a little progress on this.
I ran into the same
[
https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Kania updated FLINK-27611:
Component/s: Connectors / Pulsar
> ConcurrentModificationException during Flink-Pulsar checkpoint
Dengyu123 closed pull request #19718: [tests] Add annotation for override method
URL: https://github.com/apache/flink/pull/19718
--
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-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Kania updated FLINK-27611:
Issue Type: Bug (was: Improvement)
> ConcurrentModificationException during Flink-Pulsar
Jason Kania created FLINK-27611:
---
Summary: ConcurrentModificationException during Flink-Pulsar
checkpoint notification
Key: FLINK-27611
URL: https://issues.apache.org/jira/browse/FLINK-27611
Project:
tweise merged PR #19719:
URL: https://github.com/apache/flink/pull/19719
--
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:
tweise merged PR #19720:
URL: https://github.com/apache/flink/pull/19720
--
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-27465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-27465:
-
Fix Version/s: 1.15.1
> AvroRowDeserializationSchema.convertToTimestamp fails with negative
[
https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-27255:
-
Fix Version/s: 1.15.1
> Flink-avro does not support serialization and deserialization of avro
tweise commented on PR #19704:
URL: https://github.com/apache/flink/pull/19704#issuecomment-1126633844
@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
flinkbot commented on PR #19722:
URL: https://github.com/apache/flink/pull/19722#issuecomment-1126630673
## CI report:
* 8face87316f4af09594d64bfd14023f4da627414 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Dengyu123 opened a new pull request, #19722:
URL: https://github.com/apache/flink/pull/19722
This pr tries to replace the "keySet" with "entrySet" for iterate over .
that case which both key and value are needed ,
it's more efficient to iterate the entrySet
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-27600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27600:
---
Labels: pull-request-available (was: )
> Add basic logs for coping and deleting jars
>
Aitozi commented on code in PR #211:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/211#discussion_r872917451
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/FileSystemBasedArtifactFetcher.java:
##
@@ -39,6 +39,7 @@
Aitozi commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872916175
##
docs/content/docs/operations/configuration.md:
##
@@ -53,3 +53,12 @@ To learn more about metrics and logging configuration please
refer to the
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872873594
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java:
##
@@ -133,6 +135,19 @@ public
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872873594
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java:
##
@@ -133,6 +135,19 @@ public
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872863534
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/FileSystemBasedArtifactFetcher.java:
##
@@ -33,7 +34,8 @@
flinkbot commented on PR #19721:
URL: https://github.com/apache/flink/pull/19721#issuecomment-1126523035
## CI report:
* 267285cd4cc39ebdc2846f8dfe3fe2a064a75b4c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
rudikershaw commented on code in PR #19721:
URL: https://github.com/apache/flink/pull/19721#discussion_r872850362
##
README.md:
##
@@ -75,7 +75,7 @@ Prerequisites for building Flink:
```
git clone https://github.com/apache/flink.git
cd flink
-mvn clean package -DskipTests #
rudikershaw opened a new pull request, #19721:
URL: https://github.com/apache/flink/pull/19721
## What is the purpose of the change
When adding jars to the `/lib` directory any extra jar files that match the
pattern `flink-dist*.jar` provoke an error when trying to use
gaborgsomogyi commented on PR #19372:
URL: https://github.com/apache/flink/pull/19372#issuecomment-1126477747
@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
gyfora merged PR #209:
URL: https://github.com/apache/flink-kubernetes-operator/pull/209
--
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-27003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-27003.
--
Resolution: Fixed
> Operator Helm chart improvements
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-27270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-27270.
--
Resolution: Fixed
merged to main 85fc32a8aa2293daf90d53c228d62552979f2710
> Add document of session
gyfora commented on PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#issuecomment-1126414287
@FuyaoLi2017 no worries, I have went through the code and added comments.
Mostly minor stuff :)
No need to worry about force pushing, this is your branch, it's
gyfora commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872744006
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java:
##
@@ -141,4 +142,15 @@
FuyaoLi2017 commented on PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#issuecomment-1126402997
Hi @Aitozi @gyfora , thanks for reviewing this. I have updated the code
based on your suggestions.
1. Update typos for `spec.job.flinkConfiguration`.
2.
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872722982
##
docs/content/docs/operations/configuration.md:
##
@@ -53,3 +53,11 @@ To learn more about metrics and logging configuration please
refer to the
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872721505
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/FlinkSessionJobReconciler.java:
##
@@ -83,6
Qihong Jiang created FLINK-27610:
Summary: PrometheusPushGatewayReporter doesn't support basic
authentication
Key: FLINK-27610
URL: https://issues.apache.org/jira/browse/FLINK-27610
Project: Flink
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872701915
##
docs/content/docs/operations/configuration.md:
##
@@ -53,3 +53,11 @@ To learn more about metrics and logging configuration please
refer to the
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872700622
##
docs/layouts/shortcodes/generated/kubernetes_operator_config_configuration.html:
##
@@ -110,5 +110,11 @@
String
The
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536840#comment-17536840
]
Zhilong Hong edited comment on FLINK-27608 at 5/13/22 6:55 PM:
---
When a
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536840#comment-17536840
]
Zhilong Hong edited comment on FLINK-27608 at 5/13/22 6:52 PM:
---
As a
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536840#comment-17536840
]
Zhilong Hong commented on FLINK-27608:
--
As a {{PartitionNotFoundException}} is thrown, it will be
flinkbot commented on PR #19720:
URL: https://github.com/apache/flink/pull/19720#issuecomment-1126310355
## CI report:
* 85c9612daae5c56f16de41fbd0ce2e5958d1762c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #19719:
URL: https://github.com/apache/flink/pull/19719#issuecomment-1126308081
## CI report:
* b9e4b181102292f7b4a164066cee125801853e3b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
haizhou-zhao opened a new pull request, #19720:
URL: https://github.com/apache/flink/pull/19720
…RowDeserializationSchema
Backport of fix to release-1.15.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536802#comment-17536802
]
Haizhou Zhao commented on FLINK-27255:
--
Here it is: https://github.com/apache/flink/pull/19719
>
haizhou-zhao opened a new pull request, #19719:
URL: https://github.com/apache/flink/pull/19719
…e avro schema (#19645)
Backport of fix to release 1.15
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872636486
##
docs/content/docs/operations/configuration.md:
##
@@ -53,3 +53,11 @@ To learn more about metrics and logging configuration please
refer to the
snuyanzin commented on PR #19716:
URL: https://github.com/apache/flink/pull/19716#issuecomment-1126274461
@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
flinkbot commented on PR #19718:
URL: https://github.com/apache/flink/pull/19718#issuecomment-1126265524
## CI report:
* 69a52bf6181733b12ea315c21704c0e50cb4d472 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Dengyu123 opened a new pull request, #19718:
URL: https://github.com/apache/flink/pull/19718
Using the @Override annotation could be more standardized and friendly to
read
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
gyfora commented on PR #212:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/212#issuecomment-1126254738
cc @Aitozi @tweise @wangyang0918 @morhidi
This is a larger change that fixes a couple outstanding critical issues and
also aims to make the whole flow a bit
[
https://issues.apache.org/jira/browse/FLINK-27572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27572:
---
Labels: pull-request-available (was: )
> Verify HA Metadata present before performing
gyfora opened a new pull request, #212:
URL: https://github.com/apache/flink-kubernetes-operator/pull/212
**This PR contains the following improvements/fixes for a number of loosely
connected blocker issues:**
1. Eliminate bug that causes 0 delay infinite reconcile loop with the
[
https://issues.apache.org/jira/browse/FLINK-27074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536756#comment-17536756
]
Thomas Thornton commented on FLINK-27074:
-
[~chesnay] pull request is available for review
flinkbot commented on PR #19717:
URL: https://github.com/apache/flink/pull/19717#issuecomment-1126234095
## CI report:
* 9df66fdad3309e0e5ad33ffe656a07760e1eaa68 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27074:
---
Labels: pull-request-available (was: )
> python_job.py should write to TEST_DATA_DIR
>
twthorn opened a new pull request, #19717:
URL: https://github.com/apache/flink/pull/19717
## What is the purpose of the change
Change python_job.py to use the shared TEST_DATA_DIR environment variable &
directory for writing test output data (rather than its current custom
gaborgsomogyi commented on PR #19372:
URL: https://github.com/apache/flink/pull/19372#issuecomment-1126192259
@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
zhuzhurk commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r872369788
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultSchedulingPipelinedRegion.java:
##
@@ -42,6 +43,8 @@ public class
ajian2002 commented on PR #121:
URL:
https://github.com/apache/flink-table-store/pull/121#issuecomment-1126169687
If I want to test the same MergeFunction on tables with different
structures, what should I do? (Is it possible to create a new Test file again?)
--
This is an automated
ajian2002 commented on code in PR #121:
URL: https://github.com/apache/flink-table-store/pull/121#discussion_r872505878
##
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/AggregationITCase.java:
##
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache
gyfora commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872488147
##
docs/content/docs/operations/configuration.md:
##
@@ -53,3 +53,11 @@ To learn more about metrics and logging configuration please
refer to the
Aitozi commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872450640
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/HttpArtifactFetcher.java:
##
@@ -32,12 +37,24 @@ public class
gaborgsomogyi commented on PR #19372:
URL: https://github.com/apache/flink/pull/19372#issuecomment-1126125435
@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
gyfora merged PR #203:
URL: https://github.com/apache/flink-kubernetes-operator/pull/203
--
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:
gyfora commented on PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#issuecomment-1126082667
Thank you @FuyaoLi2017 I will try to review this latest on monday as I will
be travelling during the weekend.
@Aitozi if you have some spare capacity I would
[
https://issues.apache.org/jira/browse/FLINK-27609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-27609:
--
Assignee: Matyas Orhidi
> Tracking flink-version and flink-revision in FlinkDeploymentStatus
Matyas Orhidi created FLINK-27609:
-
Summary: Tracking flink-version and flink-revision in
FlinkDeploymentStatus
Key: FLINK-27609
URL: https://issues.apache.org/jira/browse/FLINK-27609
Project: Flink
TanYuxin-tyx commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r872423445
##
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java:
##
@@ -84,6 +86,33 @@ CompletableFuture registerPartitionWithProducer(
[
https://issues.apache.org/jira/browse/FLINK-27337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-27337.
--
Resolution: Fixed
merged to main 5239cd6a7ae0812e1c399949f0facde972dcfa78
> Prevent session cluster
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zlzhang0122 updated FLINK-27608:
Component/s: Runtime / Network
> Flink may throw PartitionNotFound Exception if the downstream
zlzhang0122 created FLINK-27608:
---
Summary: Flink may throw PartitionNotFound Exception if the
downstream task reached Running state earlier than it's upstream task
Key: FLINK-27608
URL:
flinkbot commented on PR #19716:
URL: https://github.com/apache/flink/pull/19716#issuecomment-1126061144
## CI report:
* f8c3129f7ed0028a2a4002cab0ef26877b5f3653 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27607:
---
Labels: pull-request-available (was: )
> [JUnit5 Migration] Module: flink-connector-files
gaborgsomogyi commented on PR #19372:
URL: https://github.com/apache/flink/pull/19372#issuecomment-1126051696
@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
snuyanzin opened a new pull request, #19716:
URL: https://github.com/apache/flink/pull/19716
## What is the purpose of the change
Update the flink-connector-files module to AssertJ and JUnit 5 following the
[JUnit 5 Migration
Sergey Nuyanzin created FLINK-27607:
---
Summary: [JUnit5 Migration] Module: flink-connector-files
Key: FLINK-27607
URL: https://issues.apache.org/jira/browse/FLINK-27607
Project: Flink
Issue
alpreu commented on code in PR #19660:
URL: https://github.com/apache/flink/pull/19660#discussion_r872383249
##
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java:
##
@@ -723,11 +721,11 @@
flinkbot commented on PR #19715:
URL: https://github.com/apache/flink/pull/19715#issuecomment-1126036539
## CI report:
* 7803b17f358cda070931874947ae9ed18030dcc1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27606:
---
Labels: pull-request-available (was: )
> Fix code generator exception when using
lsyldliu opened a new pull request, #19715:
URL: https://github.com/apache/flink/pull/19715
## Brief change log
- *Fix code generator exception when using imperative udaf that is
introduced for planner scala-free*
--
This is an automated message from the Apache Git Service.
beyond1920 commented on code in PR #19709:
URL: https://github.com/apache/flink/pull/19709#discussion_r872348182
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/HashCodeGenerator.scala:
##
@@ -75,6 +75,146 @@ object HashCodeGenerator {
dalongliu created FLINK-27606:
-
Summary: Fix code generator exception when using imperative udaf
that is introduced for planner scala-free
Key: FLINK-27606
URL: https://issues.apache.org/jira/browse/FLINK-27606
gaoyunhaii commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r872318377
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java:
##
@@ -142,6 +142,12 @@ public class JobVertex implements java.io.Serializable {
MartijnVisser merged PR #18:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/18
--
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-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27603:
-
Description:
In Hive, by "reload function", the user can use the function defined in other
session.
[
https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27603:
-
Description:
In Hive, by "reload function", the user can use the function defined in other
session.
gaoyunhaii commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r872337757
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java:
##
@@ -299,6 +302,21 @@ private void handleTaskFailure(
final
[
https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27603:
-
Description: In Hive, by
> Hive dialect supports "reload function"
>
Aitozi commented on PR #203:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/203#issuecomment-1125982252
force pushed to solve conflicts
--
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
RyanSkraba commented on PR #18635:
URL: https://github.com/apache/flink/pull/18635#issuecomment-1125974968
I've fixed the merge conflicts in this PR: for older PRs like this, does
the Flink project prefer merging or rebasing?
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-27605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-27605:
--
Labels: pull-request-available (was: )
> Upgrade mockito to a version where static function
Aitozi commented on PR #209:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/209#issuecomment-1125972445
@morhidi Thanks for your suggestion, I have addressed your comments, PTAL
again.
--
This is an automated message from the Apache Git Service.
To respond to the message,
gaborgsomogyi commented on PR #19372:
URL: https://github.com/apache/flink/pull/19372#issuecomment-1125967453
I've done the following steps and I think every suggestion is added:
* Squashed all the commits
* Added the last missing `@Nullable`s
* Changed the PR description to reflect
gaborgsomogyi commented on code in PR #19372:
URL: https://github.com/apache/flink/pull/19372#discussion_r872305484
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManager.java:
##
@@ -45,10 +56,25 @@ public class
[
https://issues.apache.org/jira/browse/FLINK-27605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-27605:
-
Assignee: Gabor Somogyi
> Upgrade mockito to a version where static function mocking
deadwind4 commented on code in PR #19682:
URL: https://github.com/apache/flink/pull/19682#discussion_r872299864
##
flink-python/pyflink/datastream/connectors.py:
##
@@ -1449,6 +1455,314 @@ def build(self) -> 'PulsarSource':
return
MartijnVisser merged PR #19710:
URL: https://github.com/apache/flink/pull/19710
--
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:
gaborgsomogyi commented on PR #19372:
URL: https://github.com/apache/flink/pull/19372#issuecomment-1125930126
As suggested I've created FLINK-27605.
--
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
Gabor Somogyi created FLINK-27605:
-
Summary: Upgrade mockito to a version where static function
mocking is possible
Key: FLINK-27605
URL: https://issues.apache.org/jira/browse/FLINK-27605
Project:
[
https://issues.apache.org/jira/browse/FLINK-27578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27578.
--
Resolution: Invalid
This issue is resolved via FLINK-24433
>
[
https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536562#comment-17536562
]
Martijn Visser edited comment on FLINK-24433 at 5/13/22 10:55 AM:
--
In
[
https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-24433:
--
Assignee: Martijn Visser
> "No space left on device" in Azure e2e tests
>
[
https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-24433.
--
Fix Version/s: 1.16.0
1.14.5
1.15.1
Resolution:
1 - 100 of 160 matches
Mail list logo
