[
https://issues.apache.org/jira/browse/FLINK-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16278165#comment-16278165
]
ASF GitHub Bot commented on FLINK-8201:
---
GitHub user wenlong88 opened a pull request
GitHub user wenlong88 opened a pull request:
https://github.com/apache/flink/pull/5123
[FLINK-8201] YarnResourceManagerTest causes license checking failure
YarnResourceManagerTest generates a temporary taskmanager config file in
flink-yarn module
root folder and never clear it,
Wenlong Lyu created FLINK-8201:
--
Summary: YarnResourceManagerTest causes license checking failure
Key: FLINK-8201
URL: https://issues.apache.org/jira/browse/FLINK-8201
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16278159#comment-16278159
]
Tzu-Li (Gordon) Tai commented on FLINK-8192:
Sure thing [~mingleizhang]. It wo
[
https://issues.apache.org/jira/browse/FLINK-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu reassigned FLINK-8200:
--
Assignee: Wenlong Lyu
> RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixe
[
https://issues.apache.org/jira/browse/FLINK-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16278134#comment-16278134
]
ASF GitHub Bot commented on FLINK-8200:
---
GitHub user wenlong88 opened a pull request
GitHub user wenlong88 opened a pull request:
https://github.com/apache/flink/pull/5122
[FLINK-8200] RocksDBAsyncSnapshotTest should use temp fold instead of fold
with fixed name
Using fixed folder in test makes test fail when different users run the
test in the same machine. We sho
Wenlong Lyu created FLINK-8200:
--
Summary: RocksDBAsyncSnapshotTest should use temp fold instead of
fold with fixed name
Key: FLINK-8200
URL: https://issues.apache.org/jira/browse/FLINK-8200
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-8017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16278092#comment-16278092
]
ASF GitHub Bot commented on FLINK-8017:
---
Github user tony810430 commented on the iss
Github user tony810430 commented on the issue:
https://github.com/apache/flink/pull/4976
Hi, @aljoscha
Could you please merge this PR to `release-1.3` branch as well? Thank you.
---
mingleizhang created FLINK-8199:
---
Summary: Annotation for Elasticsearch connector
Key: FLINK-8199
URL: https://issues.apache.org/jira/browse/FLINK-8199
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16278040#comment-16278040
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/3359
@shixiaogang Sounds nice! Can you please open a PR if possible? Thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16278030#comment-16278030
]
mingleizhang commented on FLINK-8192:
-
[~tzulitai] I would create a subtask of Elastic
[
https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277998#comment-16277998
]
ASF GitHub Bot commented on FLINK-7574:
---
Github user yew1eb commented on the issue:
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5076
@zentol thanks for your review. I have updated the PR.
`mvn clean verify -Dverbose -pl flink-clients`ï¼No dependency problems
found:
```
[INFO] --- maven-dependency-plugin:3
[
https://issues.apache.org/jira/browse/FLINK-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wind closed FLINK-8195.
---
Resolution: Fixed
> Add Redis Sink
> --
>
> Key: FLINK-8195
> URL: https:/
Ted Yu created FLINK-8198:
-
Summary: Useless check against -1 in
LimitedConnectionsFileSystem#fromConfig
Key: FLINK-8198
URL: https://issues.apache.org/jira/browse/FLINK-8198
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277802#comment-16277802
]
Che Lui Shum commented on FLINK-7129:
-
Hi [~dawidwys], is there any plan to include th
[
https://issues.apache.org/jira/browse/FLINK-8197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277767#comment-16277767
]
Eron Wright commented on FLINK-8197:
-
Just an (obvious) suggestion: consider the incl
[
https://issues.apache.org/jira/browse/FLINK-8196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8196.
---
> Fix Hadoop Servlet Dependency Exclusion
> ---
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-8196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8196.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in
- 1.4.0 via b53e3d65c980696d548d251a37eec
Hao Sun created FLINK-8197:
--
Summary: Support include conf directories in flink config
Key: FLINK-8197
URL: https://issues.apache.org/jira/browse/FLINK-8197
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277305#comment-16277305
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r154748301
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -244,7 +302,32 @@ protected JobManagerRunner createJobManag
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277300#comment-16277300
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r154747386
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -534,6 +536,40 @@ public void handleError(final Exception excep
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277296#comment-16277296
]
ASF GitHub Bot commented on FLINK-8176:
---
GitHub user GJL reopened a pull request:
GitHub user GJL reopened a pull request:
https://github.com/apache/flink/pull/5107
[FLINK-8176][flip6] Start SubmittedJobGraphStore in Dispatcher
## What is the purpose of the change
The FLIP-6 dispatcher never calls `start()` on its SubmittedJobGraphStore
instance. Hence,
[
https://issues.apache.org/jira/browse/FLINK-6590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277285#comment-16277285
]
ASF GitHub Bot commented on FLINK-6590:
---
Github user zentol closed the pull request
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/3916
---
[
https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277280#comment-16277280
]
Ankit Parashar commented on FLINK-8116:
---
Hi [~ggevay] , I have made the required cha
[
https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277274#comment-16277274
]
ASF GitHub Bot commented on FLINK-8116:
---
GitHub user ankitiitb1069 opened a pull req
GitHub user ankitiitb1069 opened a pull request:
https://github.com/apache/flink/pull/5121
[FLINK-8116] Stale comments referring to Checkpointed interface
## What is the purpose of the change
This pull request replaces the stale comments referring to Checkpointed
interface
[
https://issues.apache.org/jira/browse/FLINK-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277258#comment-16277258
]
ASF GitHub Bot commented on FLINK-8193:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5118
I'll add flink-clients again with a comment.
---
[
https://issues.apache.org/jira/browse/FLINK-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277250#comment-16277250
]
ASF GitHub Bot commented on FLINK-8193:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5118
`flink-core` is a direct dependency due to the usage of the
[Collector](https://github.com/apache/flink/blob/master/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/src/mai
[
https://issues.apache.org/jira/browse/FLINK-8196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8196:
--
Summary: Fix Hadoop Servlet Dependency Exclusion (was: Fix Hadoop Servled
Dependency Exclusion)
> Fix Hadoop S
[
https://issues.apache.org/jira/browse/FLINK-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277150#comment-16277150
]
ASF GitHub Bot commented on FLINK-8174:
---
Github user tillrohrmann commented on the i
Stephan Ewen created FLINK-8196:
---
Summary: Fix Hadoop Servled Dependency Exclusion
Key: FLINK-8196
URL: https://issues.apache.org/jira/browse/FLINK-8196
Project: Flink
Issue Type: Bug
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5114
Thanks for your fast contribution @EronWright. I will take a closer look at
the fix but from a first glance it seems that the `LaunchCoordinatorTest`
fails. Could you fix this test case while I
[
https://issues.apache.org/jira/browse/FLINK-5297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277149#comment-16277149
]
Stephan Ewen commented on FLINK-5297:
-
[~till.rohrmann] Is this still valid, or can we
[
https://issues.apache.org/jira/browse/FLINK-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277144#comment-16277144
]
ASF GitHub Bot commented on FLINK-8193:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5118
Is there a way to fail the build if users do not use the `-Pbuild-jar`
profile? I would assume that right now, at least half of the users build a
mother-of-all-jars that includes all of Flink.
[
https://issues.apache.org/jira/browse/FLINK-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277142#comment-16277142
]
ASF GitHub Bot commented on FLINK-8193:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5118
I think that the change of `1.` is actually not necessary. The dependencies
were good in my opinion:
- `flink-core` is not directly needed, because it is a transitive
dependency of `flink-
[
https://issues.apache.org/jira/browse/FLINK-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277130#comment-16277130
]
Ted Yu commented on FLINK-8100:
---
I did a brief search and found:
https://stackoverflow.com/q
[
https://issues.apache.org/jira/browse/FLINK-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8146:
--
Component/s: Python API
> Potential resource leak in PythonPlanBinder#unzipPythonLibrary
> -
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277095#comment-16277095
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW commented on a diff i
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154710910
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -378,6 +381,11 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277089#comment-16277089
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW commented on a diff i
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154710187
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -378,6 +381,11 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277076#comment-16277076
]
ASF GitHub Bot commented on FLINK-7574:
---
Github user yew1eb commented on a diff in t
Github user yew1eb commented on a diff in the pull request:
https://github.com/apache/flink/pull/5076#discussion_r154708511
--- Diff: pom.xml ---
@@ -581,6 +581,20 @@ under the License.
0.9.10
test
[
https://issues.apache.org/jira/browse/FLINK-8190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-8190.
--
> Add extra FlinkKafkaConsumer constructors to expose pattern-based topic
> subscription fu
[
https://issues.apache.org/jira/browse/FLINK-8190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277058#comment-16277058
]
Tzu-Li (Gordon) Tai commented on FLINK-8190:
Merged.
release-1.4: {{810be6dca
[
https://issues.apache.org/jira/browse/FLINK-8190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8190.
Resolution: Fixed
> Add extra FlinkKafkaConsumer constructors to expose pattern-base
[
https://issues.apache.org/jira/browse/FLINK-8190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277055#comment-16277055
]
ASF GitHub Bot commented on FLINK-8190:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5117
---
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277052#comment-16277052
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154702193
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public vo
[
https://issues.apache.org/jira/browse/FLINK-8190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277045#comment-16277045
]
ASF GitHub Bot commented on FLINK-8190:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5117
Thanks a lot for the review @aljoscha.
I'm merging this to `master` and `release-1.4` (fixing the doc issue while
merging).
---
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8173:
Summary: Fix input unboxing and support Avro Utf8 in Table API (was:
InvalidProgramExceptio
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277035#comment-16277035
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154697358
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -378,6 +381,11 @@ public void noti
[
https://issues.apache.org/jira/browse/FLINK-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277030#comment-16277030
]
ASF GitHub Bot commented on FLINK-8193:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5118
The comment about "adding to the exclusions" under `a)` is outdated now.
Should we maybe add the shade plugin in the profile, so that users don't
accidentally build a super-fat jar?
Overall
[
https://issues.apache.org/jira/browse/FLINK-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277020#comment-16277020
]
Fabian Hueske commented on FLINK-8195:
--
A Redis connector is available in the Apache
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/commit/aa1f8f31c01d8fd4ae5bdaaf48c44aadc221#commitcomment-26036557
In flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.java:
In flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.j
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276992#comment-16276992
]
ASF GitHub Bot commented on FLINK-8186:
---
Github user aljoscha commented on the issue
Wind created FLINK-8195:
---
Summary: Add Redis Sink
Key: FLINK-8195
URL: https://issues.apache.org/jira/browse/FLINK-8195
Project: Flink
Issue Type: New Feature
Reporter: Wind
I think we sh
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5120
@zentol I think so, yes. First, I only excluded, which led me to discover
the problem with `AvroUtils` and them not using the right classloader to
dynamically load the them.
---
[
https://issues.apache.org/jira/browse/FLINK-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8194.
Resolution: Fixed
1.5.0: 2d1d4dd763ddcc8166bf26492e4950089c10f64e
1.4.0: d9551ae1dcfae76064786d37dd1
Till Rohrmann created FLINK-8194:
Summary: Disable akka.actor.warn-about-java-serializer-usage to
suppress akka warnings when using the Java serializer
Key: FLINK-8194
URL: https://issues.apache.org/jira/browse/FL
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276968#comment-16276968
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154685383
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void t
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276952#comment-16276952
]
ASF GitHub Bot commented on FLINK-8186:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5120
Looks good to me. This is actually two fixes in one:
1. Avro should not be in `flink-dist`, because starting with
`org.apache.flink`, it would always be loaded *"parent first"*. That ca
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154680022
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -378,6 +381,11 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276939#comment-16276939
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276932#comment-16276932
]
ASF GitHub Bot commented on FLINK-8186:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5120
is the exclusion from flink-dist still necessary?
---
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276928#comment-16276928
]
ASF GitHub Bot commented on FLINK-8186:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276927#comment-16276927
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW commented on a diff i
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/5120
[FLINK-8186] Exclude flink-avro from flink-dist; fix AvroUtils loading
Before, AvroUtils were loaded when the class was loaded which didn't
take into account the user-code ClassLoader. Now, we t
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276924#comment-16276924
]
Aljoscha Krettek commented on FLINK-8186:
-
I have a fix for this, PR coming up in
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154676972
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public vo
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-8186:
---
Assignee: Aljoscha Krettek
> AvroInputFormat regression: fails to deserialize Generic
[
https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276922#comment-16276922
]
ASF GitHub Bot commented on FLINK-7395:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4504
or, we may add these fields as a metric, actually - but let's discuss this
elsewhere
---
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276916#comment-16276916
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154675125
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -280,94 +280,120 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276918#comment-16276918
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154674880
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -108,17 +117,75 @@ public void t
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276910#comment-16276910
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154673167
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClient.java
---
@@ -167,6 +167,13 @@ public void operationComp
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276905#comment-16276905
]
ASF GitHub Bot commented on FLINK-7692:
---
Github user tony810430 commented on a diff
Github user tony810430 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5115#discussion_r154672680
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java
---
@@ -409,6 +404,22 @@ public MetricGroup addGro
1 - 100 of 214 matches
Mail list logo
