[
https://issues.apache.org/jira/browse/FLINK-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui closed FLINK-8316.
--
Resolution: Won't Do
> The CsvTableSink and the CsvInputFormat are not in sync
>
Sihua Zhou created FLINK-9351:
-
Summary: RM stop assigning slot to Job because the TM killed
before connecting to JM successfully
Key: FLINK-9351
URL: https://issues.apache.org/jira/browse/FLINK-9351
[
https://issues.apache.org/jira/browse/FLINK-9074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473758#comment-16473758
]
ASF GitHub Bot commented on FLINK-9074:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473757#comment-16473757
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user sihuazhou commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5969
Thanks a lot for the review @fhueske.
Will merge this!
---
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5879
Hi @tillrohrmann , thanks for your reply, @zentol proposed to introduce a
`normal-life-cycle exception` in his previous review, the `normal-left-cycle
exception` would only log the exception
[
https://issues.apache.org/jira/browse/FLINK-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473751#comment-16473751
]
ASF GitHub Bot commented on FLINK-8316:
---
Github user xccui closed the pull request at:
Github user xccui closed the pull request at:
https://github.com/apache/flink/pull/5210
---
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/6004
[FLINK-8977] [e2e] End-to-end test for manual job resume after terminal
failure
## What is the purpose of the change
This PR is based on new e2e features introduced by #5941, #5990, and
[
https://issues.apache.org/jira/browse/FLINK-8977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473749#comment-16473749
]
ASF GitHub Bot commented on FLINK-8977:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-9078:
--
Assignee: Florian Schmidt
> End-to-end test: Add test that verifies that a
[
https://issues.apache.org/jira/browse/FLINK-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9351:
--
Description:
The steps are the following(copied from Stephan's comments in
[
https://issues.apache.org/jira/browse/FLINK-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9351:
--
Description:
The steps are the following(copied from Stephan's comments in [5931
[
https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473438#comment-16473438
]
Fabian Hueske commented on FLINK-9234:
--
I tried to reproduce this issue for 1.5 but it seems to work.
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473446#comment-16473446
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473448#comment-16473448
]
ASF GitHub Bot commented on FLINK-9312:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5966
I agree, we need different key/truststores for the internal/external
connectivity. This PR was meant as a step in that direction, separating at
least within the SSL Utils the internal and
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5999
This is helpful, thanks.
Merging...
---
[
https://issues.apache.org/jira/browse/FLINK-9348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473452#comment-16473452
]
ASF GitHub Bot commented on FLINK-9348:
---
Github user StephanEwen commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6001
@StephanEwen does this has any problem need to change? it seems @medcv try
to fixed this issue before asking me.
---
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473466#comment-16473466
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473477#comment-16473477
]
ASF GitHub Bot commented on FLINK-9153:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473478#comment-16473478
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5897
Agreed, let's add it to master as well...
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5970
Looks good, thanks.
+1 to merge
---
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5982
Hi @StephanEwen I have update the PR according to the above comments, it's
ready for an another review.
---
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473421#comment-16473421
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473440#comment-16473440
]
Stephan Ewen commented on FLINK-9234:
-
[~fhueske] Sounds good, thanks for the heads up.
> Commons
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5834
hi @StephanEwen why the committers do not review those old PRs? I have
serval PRs which take so long time.
---
[
https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473450#comment-16473450
]
ASF GitHub Bot commented on FLINK-9234:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473451#comment-16473451
]
ASF GitHub Bot commented on FLINK-9153:
---
Github user yanghua commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5897
Thanks, @StephanEwen.
I will later merge this for `release-1.4` and `release-1.5`. Should we
merge it for `master` as well and create a JIRA to drop the deprecated code?
That would ensure
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473462#comment-16473462
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6000
Congrats on having PR number 6000!
This overlaps with #6001, which is a mit more comprehensive (but need some
improvements).
Would you be up to coordinate to make one joint PR?
---
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473489#comment-16473489
]
Yazdan Shirvany commented on FLINK-9299:
[~yanghua] Thanks for the fix. Will keep in mind to ask
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6001
cc @zentol @tillrohrmann
---
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473445#comment-16473445
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473444#comment-16473444
]
Stephan Ewen commented on FLINK-1044:
-
I think this can still be useful for users that have no
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5970#discussion_r187797400
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/sca/UdfAnalyzerTest.java ---
@@ -62,6 +62,10 @@
@SuppressWarnings("serial")
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5970
One minor style comment, otherwise this is good to go!
---
[
https://issues.apache.org/jira/browse/FLINK-9348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473464#comment-16473464
]
ASF GitHub Bot commented on FLINK-9348:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5999
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5834
Committers usually have a lot of different responsibilities (releases,
testing, helping users on mailing lists, working on roadmap features, etc.).
All that takes a lot of time. Reviewing PRs is
[
https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473487#comment-16473487
]
ASF GitHub Bot commented on FLINK-9325:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473491#comment-16473491
]
ASF GitHub Bot commented on FLINK-9174:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473495#comment-16473495
]
ASF GitHub Bot commented on FLINK-9153:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473441#comment-16473441
]
ASF GitHub Bot commented on FLINK-9234:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473442#comment-16473442
]
ASF GitHub Bot commented on FLINK-9234:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5897
From my side, +1 to merge this to `release-1.4` and `release-1.5`.
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5897
Forwarding some comment from @fhueske from JIRA:
> I tried to reproduce this issue for 1.5 but it seems to work.
>
> Flink 1.5 should be out soon (release candidate 2 was
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473449#comment-16473449
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5970
cc @StephanEwen refactored base on your suggestion.
---
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473461#comment-16473461
]
ASF GitHub Bot commented on FLINK-9299:
---
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/6000#discussion_r187798729
--- Diff: docs/dev/stream/operators/windows.md ---
@@ -730,9 +730,9 @@ input
/* ... */
-public class MyProcessWindowFunction
[
https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473479#comment-16473479
]
ASF GitHub Bot commented on FLINK-9234:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473488#comment-16473488
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5879
cc @StephanEwen
---
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473490#comment-16473490
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6001
@yanghua Thanks for the fix. I will close my PR as you addressed all the
issues in the ticket here.
---
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5847
Could anyone have a look at this...
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5834
Generally I would refrain from pinging specific committers. This can be
counter-productive as it discourages other committers, or even contributors,
from taking a look.
Similarly, pinging a
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473497#comment-16473497
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user medcv commented on a diff in the pull request:
Github user medcv commented on a diff in the pull request:
https://github.com/apache/flink/pull/6000#discussion_r187802397
--- Diff: docs/dev/stream/operators/windows.md ---
@@ -730,9 +730,9 @@ input
/* ... */
-public class MyProcessWindowFunction implements
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6000
@StephanEwen Thanks
Yes, I made this PR before asking about ticket status. my bad!
I will close it and will work on #6001
---
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473499#comment-16473499
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user medcv commented on the issue:
Github user medcv closed the pull request at:
https://github.com/apache/flink/pull/6000
---
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6001
[FLINK-9299] ProcessWindowFunction documentation Java examples have errors
## What is the purpose of the change
*This pull request fixed some document demo code error.*
##
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473406#comment-16473406
]
ASF GitHub Bot commented on FLINK-9299:
---
GitHub user yanghua opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473407#comment-16473407
]
vinoyang edited comment on FLINK-9299 at 5/13/18 8:33 AM:
--
[~yazdanjs] I have
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473407#comment-16473407
]
vinoyang commented on FLINK-9299:
-
[~yazdanjs] I have did the completed fix. thanks for your contribution!
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473381#comment-16473381
]
vinoyang commented on FLINK-9299:
-
[~yazdanjs] follow the issue's description it seems not completed fix.
[
https://issues.apache.org/jira/browse/FLINK-9347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473400#comment-16473400
]
vinoyang commented on FLINK-9347:
-
[~Zentol] which solution you prefer? I found the readLength method
[
https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-8511:
-
Affects Version/s: 1.6.0
> Remove legacy code for the TableType annotation
>
[
https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-8511:
-
Description:
We introduced the very generic TableSource factories that unify the definition
of
[
https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-8511:
-
Priority: Critical (was: Major)
> Remove legacy code for the TableType annotation
>
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/5989
@zentol please review
---
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/5996
@StephanEwen please review
---
[
https://issues.apache.org/jira/browse/FLINK-9333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473510#comment-16473510
]
ASF GitHub Bot commented on FLINK-9333:
---
Github user medcv commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473509#comment-16473509
]
ASF GitHub Bot commented on FLINK-9343:
---
Github user medcv commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473520#comment-16473520
]
Ted Yu commented on FLINK-9349:
---
It seems synchronization should be added for adding to
[
https://issues.apache.org/jira/browse/FLINK-9277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473501#comment-16473501
]
Sihua Zhou commented on FLINK-9277:
---
Hey guys, anyone against to mark this ticket as a duplicate of
Vishal Santoshi created FLINK-9349:
--
Summary: KafkaConnector Exception while fetching from multiple
kafka topics
Key: FLINK-9349
URL: https://issues.apache.org/jira/browse/FLINK-9349
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473526#comment-16473526
]
ASF GitHub Bot commented on FLINK-9153:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5834
@zentol thanks for your clarification. Actually, when I start join Flink
community, most of the PRs were reviewed by you and till. Both of you gave me a
lot of suggestion and technical opinion.
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473500#comment-16473500
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user medcv closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473543#comment-16473543
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6001
hi @medcv I think maybe it better to assign the issue to yourself before
working on that, this could help to avoid depulicate works(cause i notice that
you make the PRs without assigning to
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473518#comment-16473518
]
Ted Yu commented on FLINK-9349:
---
The root cause analysis, from me, was based on quick inspection of the
[
https://issues.apache.org/jira/browse/FLINK-9333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yazdan Shirvany reassigned FLINK-9333:
--
Assignee: Yazdan Shirvany
> QuickStart Docs Spelling fix and some info regarding
[
https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yazdan Shirvany reassigned FLINK-9343:
--
Assignee: Yazdan Shirvany
> Add Async Example with External Rest API call
>
[
https://issues.apache.org/jira/browse/FLINK-9348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yazdan Shirvany reassigned FLINK-9348:
--
Assignee: Yazdan Shirvany
> scalastyle documentation for IntelliJ IDE setup
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5897
---
[
https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473668#comment-16473668
]
ASF GitHub Bot commented on FLINK-9234:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-9234.
Resolution: Fixed
Fix Version/s: 1.4.3
1.5.0
Fixed for 1.6.0 with
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473624#comment-16473624
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5879
Thanks for the contribution @sihuazhou. You're right that the log output of
the `SlotPool` component is a bit too noisy and should not log the full stack
trace in the happy case. What about not
[
https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-8511:
---
Assignee: vinoyang
> Remove legacy code for the TableType annotation
>
[
https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9231:
--
Component/s: Webfrontend
> Enable SO_REUSEADDR on listen sockets
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9236:
--
Component/s: Build System
> Use Apache Parent POM 19
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16462530#comment-16462530
]
Ted Yu edited comment on FLINK-9088 at 5/14/18 2:01 AM:
+1
was (Author:
1 - 100 of 107 matches
Mail list logo
