Yazdan Shirvany created FLINK-9343:
--
Summary: Add Async Example with External Rest API call
Key: FLINK-9343
URL: https://issues.apache.org/jira/browse/FLINK-9343
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472849#comment-16472849
]
vinoyang commented on FLINK-9339:
-
the reason because of , SubtaskCurrentAttemptDetailsHeaders used url
GitHub user medcv opened a pull request:
https://github.com/apache/flink/pull/5996
[FLINK-9343] [Example] Add Async Example with External Rest API call
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server,
[
https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472921#comment-16472921
]
ASF GitHub Bot commented on FLINK-9343:
---
GitHub user medcv opened a pull request:
vinoyang created FLINK-9342:
---
Summary: conflicted url path pattern about
SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders
Key: FLINK-9342
URL: https://issues.apache.org/jira/browse/FLINK-9342
[
https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472855#comment-16472855
]
vinoyang commented on FLINK-9339:
-
another similar issue is FLINK-9342
> Accumulators are not UI
[
https://issues.apache.org/jira/browse/FLINK-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472856#comment-16472856
]
vinoyang commented on FLINK-9342:
-
like FLINK-9339
> conflicted url path pattern about
[
https://issues.apache.org/jira/browse/FLINK-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9342:
Summary: Conflicted url path pattern about
SubtaskCurrentAttemptDetailsHeaders and
[
https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9339:
---
Assignee: vinoyang
> Accumulators are not UI accessible running in FLIP-6 mode
>
[
https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471618#comment-16471618
]
ASF GitHub Bot commented on FLINK-7775:
---
Github user yanghua commented on the issue:
Juho Autio created FLINK-9335:
-
Summary: Expose client logs via Flink UI
Key: FLINK-9335
URL: https://issues.apache.org/jira/browse/FLINK-9335
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471526#comment-16471526
]
ASF GitHub Bot commented on FLINK-9234:
---
Github user nezhazheng commented on the issue:
Github user nezhazheng commented on the issue:
https://github.com/apache/flink/pull/5897
encountered same issue.
---
[
https://issues.apache.org/jira/browse/FLINK-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471564#comment-16471564
]
ASF GitHub Bot commented on FLINK-9322:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5990
[FLINK-9322][FLINK-9320] [e2e] Improvements to e2e standalone chaos monkey
test
## What is the purpose of the change
This PR is based on #5941. Only the last 2 commits are relevant.
[
https://issues.apache.org/jira/browse/FLINK-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juho Autio updated FLINK-9334:
--
Description:
Tzu-Li (Gordon) said:
{quote}Yes, it might be helpful to have a code snippet to
[
https://issues.apache.org/jira/browse/FLINK-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juho Autio updated FLINK-9335:
--
Description:
The logs logged by my Flink job jar _before_ *env.execute* can't be found in
jobmanager
[
https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471648#comment-16471648
]
Fabian Hueske commented on FLINK-9289:
--
Hi [~xccui], the fix should go into
[
https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471660#comment-16471660
]
Xingcan Cui commented on FLINK-9289:
I see. Thanks for the explanation, [~fhueske]. Will fix this as
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5929
@alexpf thanks for the updates.
Please bear with me just a little, I'll try to get back to reviewing this
PR ASAP after I finish with some ongoing tasks.
---
[
https://issues.apache.org/jira/browse/FLINK-8497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471616#comment-16471616
]
ASF GitHub Bot commented on FLINK-8497:
---
Github user tzulitai commented on the issue:
Juho Autio created FLINK-9334:
-
Summary: Docs to have a code snippet of Kafka partition discovery
Key: FLINK-9334
URL: https://issues.apache.org/jira/browse/FLINK-9334
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
blues zheng reassigned FLINK-8307:
--
Assignee: blues zheng
> org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging
[
https://issues.apache.org/jira/browse/FLINK-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471680#comment-16471680
]
Chesnay Schepler commented on FLINK-9335:
-
As i understand it he isn't using the UI to submit jobs
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5988#discussion_r187575678
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/CallGenerator.scala
---
@@ -64,17 +65,28 @@ object CallGenerator
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5988#discussion_r187577471
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala
---
@@ -686,6 +686,28 @@ class SqlITCase
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471729#comment-16471729
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471789#comment-16471789
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471795#comment-16471795
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471796#comment-16471796
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471612#comment-16471612
]
Aleksei Lesnov commented on FLINK-8497:
---
Colleagues, could you please review the updated changes?
>
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471766#comment-16471766
]
ASF GitHub Bot commented on FLINK-9138:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5860
Hi @glaksh100, thanks for the update!
---
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471794#comment-16471794
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5970#discussion_r187592909
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/sca/UdfAnalyzerTest.java ---
@@ -268,8 +274,8 @@ public void
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5970#discussion_r187591783
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/sca/UdfAnalyzerTest.java ---
@@ -109,7 +112,7 @@ public String map(MyPojo value) throws
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5970#discussion_r187589977
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/typeinfo/TypeInformationTest.java
---
@@ -61,7 +61,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471722#comment-16471722
]
ASF GitHub Bot commented on FLINK-9074:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5969
thanks for the PR @tzulitai.
The new e2e tests passed on my machine. The changes look good as well.
+1 to merge
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5987
Sorry, but can we take back a step and first agree on what we actually want
the behavior to be before jumping into an implementation?
---
[
https://issues.apache.org/jira/browse/FLINK-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471675#comment-16471675
]
Stephan Ewen commented on FLINK-9335:
-
We are trying to make the Web UI less necessary by adding some
[
https://issues.apache.org/jira/browse/FLINK-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9335:
Priority: Minor (was: Major)
> Expose client logs via Flink UI
>
[
https://issues.apache.org/jira/browse/FLINK-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9335:
Issue Type: New Feature (was: Improvement)
> Expose client logs via Flink UI
>
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5928
Hi guys, I think maybe the doc that related to the `Externalized
Checkpoint` should be updated for 1.5. Are there any other suggestions? And if
there is anyone who is willing to take over this plz
[
https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471749#comment-16471749
]
Fabian Hueske commented on FLINK-9329:
--
I checked the code and could not reproduce the issue.
The
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5958
If it turns out that we need to do a bit more design work on the
deserialization schema, we could incrementally fix the issue that triggered
this PR by actually extending the
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471756#comment-16471756
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471767#comment-16471767
]
ASF GitHub Bot commented on FLINK-9043:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471802#comment-16471802
]
ASF GitHub Bot commented on FLINK-9304:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5962
The comment to make at least one attempt sounds good.
If you refactor this a little bit, you can actually test it. Either make it
a static method to which you pass the timer service, or
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5988#discussion_r187568481
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/CallGenerator.scala
---
@@ -64,17 +65,28 @@ object CallGenerator
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5958
There are a few bigger design aspects that we need to agree upon:
- The `DeserializationSchema` is a shared common denominator of
serialization schemata. That's why it is in
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471754#comment-16471754
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user StephanEwen commented on the issue:
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187592761
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/MockStreamConfig.java
---
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471807#comment-16471807
]
Sihua Zhou commented on FLINK-9043:
---
Hi, [~StephanEwen] Sorry that I skipped the discussion period and
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471730#comment-16471730
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471728#comment-16471728
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471734#comment-16471734
]
Juho Autio commented on FLINK-9335:
---
I'm submitting jobs on command line with flink run, yarn-cluster
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471807#comment-16471807
]
Sihua Zhou edited comment on FLINK-9043 at 5/11/18 12:07 PM:
-
Hi,
Github user Xpray commented on a diff in the pull request:
https://github.com/apache/flink/pull/5988#discussion_r187636663
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/CallGenerator.scala
---
@@ -64,17 +65,28 @@ object CallGenerator {
Github user GJL closed the pull request at:
https://github.com/apache/flink/pull/5973
---
[
https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472049#comment-16472049
]
ASF GitHub Bot commented on FLINK-9261:
---
Github user GJL closed the pull request at:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5970
cc @StephanEwen refactored based on your suggestion, the travis build
failed because of yarn test, seems not about this PR's change.
---
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472078#comment-16472078
]
Sihua Zhou commented on FLINK-9336:
---
[~florianschmidt] Thanks for reporting this bug, in fact this is a
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472121#comment-16472121
]
ASF GitHub Bot commented on FLINK-9336:
---
GitHub user sihuazhou opened a pull request:
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5993
[FLINK-9336][state] fix deserialization problem for queryable MapState
## What is the purpose of the change
This PR fixes the deserialization problem for queryable MapState. Currently
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472123#comment-16472123
]
ASF GitHub Bot commented on FLINK-9336:
---
Github user sihuazhou commented on the issue:
Florian Schmidt created FLINK-9336:
--
Summary: Queryable state fails with Exception after task manager
restore
Key: FLINK-9336
URL: https://issues.apache.org/jira/browse/FLINK-9336
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472066#comment-16472066
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472083#comment-16472083
]
ASF GitHub Bot commented on FLINK-9036:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5735
@aljoscha Would be interested in your opinion here.
This is basically one of two ways to improve the handling of default values:
1. Add a default value supplier on the state
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9336:
--
Priority: Blocker (was: Major)
> Queryable state fails with Exception after task manager restore
>
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5993
cc @StefanRRichter, @kl0u you may also care about this...
---
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472023#comment-16472023
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user Xpray commented on a diff in the pull request:
Github user Xpray commented on a diff in the pull request:
https://github.com/apache/flink/pull/5988#discussion_r187636169
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/CallGenerator.scala
---
@@ -64,17 +65,28 @@ object CallGenerator {
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187640541
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -71,6 +71,17 @@
@PublicEvolving
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187639708
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472055#comment-16472055
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472056#comment-16472056
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472085#comment-16472085
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187646041
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -71,6 +71,17 @@
@PublicEvolving
[
https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472086#comment-16472086
]
ASF GitHub Bot commented on FLINK-9295:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187645022
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
---
@@ -837,7
[
https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472109#comment-16472109
]
ASF GitHub Bot commented on FLINK-8944:
---
Github user kailashhd commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472156#comment-16472156
]
Esteban Serrano commented on FLINK-8949:
Running into a similar problem with the REST API to
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt updated FLINK-9336:
---
Description:
The following steps can be used to reproduce the Exception:
# Run an app
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt updated FLINK-9336:
---
Description:
The following steps can be used to reproduce the Exception:
# Run an app
[
https://issues.apache.org/jira/browse/FLINK-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472026#comment-16472026
]
ASF GitHub Bot commented on FLINK-9332:
---
Github user Xpray commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9336:
-
Assignee: Sihua Zhou
> Queryable state fails with Exception after task manager restore
>
Github user kailashhd commented on the issue:
https://github.com/apache/flink/pull/5992
R: @tzulitai @tweise
---
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472108#comment-16472108
]
ASF GitHub Bot commented on FLINK-9303:
---
Github user tedyu commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472106#comment-16472106
]
ASF GitHub Bot commented on FLINK-9303:
---
Github user tedyu commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472107#comment-16472107
]
ASF GitHub Bot commented on FLINK-9303:
---
Github user tedyu commented on a diff in the pull request:
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/5991#discussion_r187647275
--- Diff:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@ -221,7 +221,8
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/5991#discussion_r187648458
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
---
@@
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/5991#discussion_r187647828
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
---
@@ -80,6
[
https://issues.apache.org/jira/browse/FLINK-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9334:
---
Assignee: vinoyang
> Docs to have a code snippet of Kafka partition discovery
>
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471894#comment-16471894
]
Sihua Zhou commented on FLINK-9043:
---
I think this is a more friendly way, that way we need to enable the
[
https://issues.apache.org/jira/browse/FLINK-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472001#comment-16472001
]
ASF GitHub Bot commented on FLINK-8944:
---
Github user tweise commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471843#comment-16471843
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user yanghua commented on a diff in the pull
1 - 100 of 175 matches
Mail list logo
