[
https://issues.apache.org/jira/browse/FLINK-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5146.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15717488#comment-15717488
]
Kurt Young commented on FLINK-5185:
---
[~fhueske]Sure, i will open one.
> Decouple BatchTableSourceScan
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714835#comment-15714835
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714833#comment-15714833
]
Robert Metzger commented on FLINK-5017:
---
I'm wondering whether this is really a blocker issue.
I
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2917
Thanks for checking out the code!
>If different parts of the code or the JDK do a subtle change of behavior
(i.e. resolve the InetAddress), then some nodes may have a hostname in the URL,
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714869#comment-15714869
]
ASF GitHub Bot commented on FLINK-5218:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2920
Thanks for the review, merging this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714906#comment-15714906
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user NickolayVasilishin commented on the issue:
Github user NickolayVasilishin commented on the issue:
https://github.com/apache/flink/pull/2870
Hi, @fhueske.
I will update PR with fixed version soon.
But I have a question. Is deduplication at In#toRexNode really needed since
we are going to use hashset anyway? It's
Till Rohrmann created FLINK-5229:
Summary: Cleanup StreamTaskStates if a checkpoint operation of a
subsequent operator fails
Key: FLINK-5229
URL: https://issues.apache.org/jira/browse/FLINK-5229
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715196#comment-15715196
]
Stephan Ewen commented on FLINK-5227:
-
When adding/shading Calcite, is it possible to explicitly
[
https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715231#comment-15715231
]
Aljoscha Krettek commented on FLINK-5229:
-
[~srichter], please correct me if I'm wrong.
> Cleanup
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714816#comment-15714816
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r90627441
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1891,8 +1891,8 @@ object JobManager {
// parsing
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714931#comment-15714931
]
Robert Metzger commented on FLINK-4632:
---
If its okay for everybody, I'm setting the priority of this
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4632:
--
Priority: Major (was: Blocker)
> when yarn nodemanager lost, flink hung
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2921
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5185.
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed with 3eeb35d60438c86353304ad675b2e9304ba4f513
[
https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-4676.
Resolution: Done
Done with de4fe3b7392948807753d65d13f3da968e6c7de0
> Merge flink-batch-connectors
[
https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715228#comment-15715228
]
Aljoscha Krettek commented on FLINK-5229:
-
@Till, this is already covered in this PR:
Stephan Ewen created FLINK-5231:
---
Summary: JobManager should exit on "OutOfMemoryError"
Key: FLINK-5231
URL: https://issues.apache.org/jira/browse/FLINK-5231
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715225#comment-15715225
]
Stefan Richter commented on FLINK-4492:
---
Should be ok to close this.
> Cleanup files from canceled
[
https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714813#comment-15714813
]
Robert Metzger commented on FLINK-5048:
---
Do we want to backport the changes to 1.1.4 or can I close
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714839#comment-15714839
]
ASF GitHub Bot commented on FLINK-5185:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2921
Thanks for the PR @beyond1920!
Good refactoring.
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
[
https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714885#comment-15714885
]
ASF GitHub Bot commented on FLINK-5220:
---
GitHub user beyond1920 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714889#comment-15714889
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2917
I have to dig back a bit (long time since I worked on that), but I thought
the IPv6 addresses issue was quite tricky one and the normalization code for
address representations was necessary.
[
https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714923#comment-15714923
]
zhangjing commented on FLINK-5220:
--
Hi Fabian, this jira and FLINK-3848 both about projection pushdown. I
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5218.
---
> Eagerly close checkpoint streams on cancellation
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-4705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715010#comment-15715010
]
ASF GitHub Bot commented on FLINK-4705:
---
Github user StephanEwen commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2886
@rmetzger I've added a test case.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715186#comment-15715186
]
Stephan Ewen commented on FLINK-4632:
-
Is this something that needs re-tries to enhance stability?
To
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714844#comment-15714844
]
Fabian Hueske commented on FLINK-5185:
--
[~ykt836], [~jinyu.zj]: I think this refactoring makes sense
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714848#comment-15714848
]
ASF GitHub Bot commented on FLINK-5185:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714847#comment-15714847
]
Robert Metzger commented on FLINK-5011:
---
Thank you for reporting the issue. We'll look into it.
>
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714943#comment-15714943
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2870
Hi @NickolayVasilishin, the `HashSet` is a very good point. Forget what I
said about deduplication. :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714962#comment-15714962
]
zhangjing commented on FLINK-5226:
--
Hi Fabian, FlinkRuleSets already contains ProjectJoinTransposeRule,
[
https://issues.apache.org/jira/browse/FLINK-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714998#comment-15714998
]
ASF GitHub Bot commented on FLINK-5190:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2905
Ah, this refers only to `flip-6` - then it makes sense :-)
Will merge this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2897
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715163#comment-15715163
]
ASF GitHub Bot commented on FLINK-5163:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715161#comment-15715161
]
ASF GitHub Bot commented on FLINK-5163:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715164#comment-15715164
]
ASF GitHub Bot commented on FLINK-5163:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715165#comment-15715165
]
ASF GitHub Bot commented on FLINK-5163:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715162#comment-15715162
]
ASF GitHub Bot commented on FLINK-5163:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715166#comment-15715166
]
ASF GitHub Bot commented on FLINK-5163:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2871#discussion_r90639571
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -58,12 +63,14 @@
[
https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715217#comment-15715217
]
Robert Metzger commented on FLINK-4492:
---
[~srichter] do you know the status of the issue?
> Cleanup
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715220#comment-15715220
]
Fabian Hueske commented on FLINK-5227:
--
We cannot shade Calcite at the moment due to issues with the
Stephan Ewen created FLINK-5232:
---
Summary: Add a Thread default uncaught exception handler on the
JobManager
Key: FLINK-5232
URL: https://issues.apache.org/jira/browse/FLINK-5232
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5228.
--
Resolution: Fixed
Fixed in 388acbc (release-1.1), 3229dc0 (master).
> LocalInputChannel re-trigger
Ufuk Celebi created FLINK-5228:
--
Summary: LocalInputChannel re-trigger request and release deadlock
Key: FLINK-5228
URL: https://issues.apache.org/jira/browse/FLINK-5228
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4905:
-
Assignee: Andrew Efimov
> Kafka test instability IllegalStateException: Client is not started
>
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2893
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
[
https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714935#comment-15714935
]
ASF GitHub Bot commented on FLINK-5128:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714936#comment-15714936
]
Alexander Chermenin commented on FLINK-4303:
Hi all. And what about using this
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/2920
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2920
Manually merged in cc006ff18cc7032de3be3fdd9ef7ad383e88bba0
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
[
https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715034#comment-15715034
]
ASF GitHub Bot commented on FLINK-5179:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715048#comment-15715048
]
刘喆 commented on FLINK-4632:
---
Thank you Ufuk Celebi.
It depends on the strategy of restarting.
Here I use auto
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715047#comment-15715047
]
刘喆 commented on FLINK-4632:
---
Thank you Ufuk Celebi.
It depends on the strategy of restarting.
Here I use auto
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
刘喆 updated FLINK-4632:
--
Comment: was deleted
(was: Thank you Ufuk Celebi.
It depends on the strategy of restarting.
Here I use auto restarting
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2871#discussion_r90641362
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java
---
@@ -73,27 +76,31 @@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2871#discussion_r90639653
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
---
@@ -62,6 +73,9 @@
/**
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2871#discussion_r90641176
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java
---
@@ -18,25 +18,44 @@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2871#discussion_r90643076
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -104,21 +114,63
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2871#discussion_r90641264
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/SourceFunctionTest.java
---
@@ -52,12 +52,4 @@ public void fromCollectionTest()
[
https://issues.apache.org/jira/browse/FLINK-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714853#comment-15714853
]
Robert Metzger commented on FLINK-4859:
---
I see the value of refactoring this, but I wonder if its
[
https://issues.apache.org/jira/browse/FLINK-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714962#comment-15714962
]
zhangjing edited comment on FLINK-5226 at 12/2/16 12:12 PM:
Hi Fabian,
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714990#comment-15714990
]
ASF GitHub Bot commented on FLINK-5218:
---
Github user StephanEwen closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5218.
-
Resolution: Fixed
Fixed in
- 1.1.4 via 59f61bf6cb8351cec9369e2de39c6eeffbda10ea
- 1.2.0 via
[
https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714989#comment-15714989
]
ASF GitHub Bot commented on FLINK-5218:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2617
@greghogan I am quite deep into some large scale deployment and scalability
issues right now. I plan to write a mail to the mailing list on that, actually.
If possible, I'd like to defer
[
https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715141#comment-15715141
]
ASF GitHub Bot commented on FLINK-5185:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715142#comment-15715142
]
ASF GitHub Bot commented on FLINK-4676:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715212#comment-15715212
]
Aljoscha Krettek commented on FLINK-4859:
-
I downgraded.
> Clearly Separate Responsibilities of
[
https://issues.apache.org/jira/browse/FLINK-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4859:
Priority: Critical (was: Blocker)
> Clearly Separate Responsibilities of StreamOperator
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714881#comment-15714881
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user mxm commented on a diff in the pull request:
Stephan Ewen created FLINK-5230:
---
Summary: Safety nets against leaving dysfunctional JobManagers
Key: FLINK-5230
URL: https://issues.apache.org/jira/browse/FLINK-5230
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715218#comment-15715218
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2917
>Can we try and preserve both in some way? When a logical hostname is
specified, we use that one in the Akka URLs. When an IP address is specified,
we normalize it and use it.
Detecting whether
GitHub user mindprince opened a pull request:
https://github.com/apache/flink/pull/2927
[docs] Replace broken link.
This variable was removed in dc5062557a55
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mindprince/flink
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15717166#comment-15717166
]
Chen Qin commented on FLINK-4460:
-
Ongoing implementation reflecting feedbacks, missing window stream impl
[
https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714523#comment-15714523
]
ASF GitHub Bot commented on FLINK-5128:
---
Github user tzulitai commented on the issue:
Github user vipul1409 commented on the issue:
https://github.com/apache/flink/pull/2922
Closing pull request as this is not needed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2893
Merging this by the end of the day if there's no other objections!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
Fabian Hueske created FLINK-5226:
Summary: Eagerly project unused attributes
Key: FLINK-5226
URL: https://issues.apache.org/jira/browse/FLINK-5226
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714544#comment-15714544
]
ASF GitHub Bot commented on FLINK-4523:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2916#discussion_r90607632
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714684#comment-15714684
]
刘喆 edited comment on FLINK-4632 at 12/2/16 10:10 AM:
-
It appears again. This time,
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714684#comment-15714684
]
刘喆 edited comment on FLINK-4632 at 12/2/16 10:11 AM:
-
This time, there is no container
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714774#comment-15714774
]
ASF GitHub Bot commented on FLINK-2821:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2917#discussion_r90621937
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -2729,11 +2727,11 @@ object JobManager {
def
[
https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714809#comment-15714809
]
Robert Metzger commented on FLINK-5108:
---
Cool, thank you. When do you think the pull request will be
[
https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714804#comment-15714804
]
ASF GitHub Bot commented on FLINK-5179:
---
Github user rmetzger commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2897
Thanks for the review @zentol
Will merge this PR later today.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714550#comment-15714550
]
ASF GitHub Bot commented on FLINK-4928:
---
Github user shuai-xu commented on a diff in the pull
Github user tony810430 commented on the issue:
https://github.com/apache/flink/pull/2916
I'm not familiar how to update document. I will be grateful if you can take
over this work. Thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on
1 - 100 of 255 matches
Mail list logo
