[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007657#comment-16007657
]
ramkrishna.s.vasudevan commented on FLINK-6284:
---
I can try to do this by end of today IST.
[
https://issues.apache.org/jira/browse/FLINK-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007656#comment-16007656
]
Fang Yong commented on FLINK-6564:
--
Thank you for your report, and also I meet this problem in windows. I
[
https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007598#comment-16007598
]
ASF GitHub Bot commented on FLINK-6504:
---
Github user shixiaogang commented on a diff in the pull
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3859#discussion_r116148624
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -911,9
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3806#discussion_r116146470
--- Diff: docs/dev/table_api.md ---
@@ -1099,14 +1099,14 @@ Temporal intervals can be represented as number of
months (`Types.INTERVAL_MONTH
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3806#discussion_r116146239
--- Diff: docs/dev/table_api.md ---
@@ -1485,14 +1485,14 @@ Joins, set operations, and non-windowed
aggregations are not supported yet.
{%
[
https://issues.apache.org/jira/browse/FLINK-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007577#comment-16007577
]
ASF GitHub Bot commented on FLINK-6426:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007580#comment-16007580
]
ASF GitHub Bot commented on FLINK-6426:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007513#comment-16007513
]
ASF GitHub Bot commented on FLINK-6457:
---
GitHub user Xpray opened a pull request:
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/3880
[FLINK-6457] Clean up ScalarFunction and TableFunction interface
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-6310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6310:
--
Description:
Here is related code:
{code}
public void endSession(JobID jobID) throws Exception {
Fabian Hueske created FLINK-6564:
Summary: Build fails on file systems that do not distinguish
between upper and lower case
Key: FLINK-6564
URL: https://issues.apache.org/jira/browse/FLINK-6564
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-6563:
--
Priority: Critical (was: Major)
Component/s: Table API & SQL
> Expose time indicator attributes
Haohui Mai created FLINK-6563:
-
Summary: Expose time indicator attributes in the KafkaTableSource
Key: FLINK-6563
URL: https://issues.apache.org/jira/browse/FLINK-6563
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007320#comment-16007320
]
ASF GitHub Bot commented on FLINK-6562:
---
GitHub user haohui opened a pull request:
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3879
[FLINK-6562] Support implicit table references for nested fields in SQL.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/haohui/flink FLINK-6562
[
https://issues.apache.org/jira/browse/FLINK-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007234#comment-16007234
]
ASF GitHub Bot commented on FLINK-6483:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3862
Thanks for the update @twalthr!
Looks very good. 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 well. If your project
[
https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007215#comment-16007215
]
ASF GitHub Bot commented on FLINK-6221:
---
Github user hadronzoo commented on the issue:
Github user hadronzoo commented on the issue:
https://github.com/apache/flink/pull/3833
@mbode thanks for working on this!
One thing that I've found useful when exporting Flink's statsd metrics to
Prometheus is to make several of the metric fields tags: like `job_name`,
Haohui Mai created FLINK-6562:
-
Summary: Support implicit table references for nested fields in SQL
Key: FLINK-6562
URL: https://issues.apache.org/jira/browse/FLINK-6562
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-6562:
--
Component/s: Table API & SQL
> Support implicit table references for nested fields in SQL
>
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r116092436
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007125#comment-16007125
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user haohui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007119#comment-16007119
]
Robert Metzger commented on FLINK-6284:
---
I think nobody is working on the issue right now.
How fast
[
https://issues.apache.org/jira/browse/FLINK-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007081#comment-16007081
]
ASF GitHub Bot commented on FLINK-6561:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007079#comment-16007079
]
ASF GitHub Bot commented on FLINK-6548:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3874
Merging.
---
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-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007080#comment-16007080
]
ASF GitHub Bot commented on FLINK-6558:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3878
Merging.
---
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-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007074#comment-16007074
]
ASF GitHub Bot commented on FLINK-6561:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3878
Looks good, +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 does not have this feature
enabled and
[
https://issues.apache.org/jira/browse/FLINK-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007068#comment-16007068
]
ASF GitHub Bot commented on FLINK-6561:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3878
[FLINK-6561] Disable glob test on Windows
This PR disables a test case in the `GlobFilePathFilterTest`. The test
verified that a file name containing asterisks `(*)` was properly filtered out;
this
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007050#comment-16007050
]
ASF GitHub Bot commented on FLINK-6514:
---
GitHub user StephanEwen opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3877
[backport] [FLINK-6514] [build] Create a proper separate Hadoop uber jar
for 'flink-dist' assembly
Backport of #3876 to `release-1.3`
This fixes the issue that Flink cannot be started
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007041#comment-16007041
]
ASF GitHub Bot commented on FLINK-6514:
---
GitHub user StephanEwen opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3876
[FLINK-6514] [build] Create a proper separate Hadoop uber jar for
'flink-dist' assembly
This fixes the issue that Flink cannot be started locally if built with
Maven 3.3+
There are
Chesnay Schepler created FLINK-6561:
---
Summary: GlobFilePathFilterTest#testExcludeFilenameWithStart fails
on Windows
Key: FLINK-6561
URL: https://issues.apache.org/jira/browse/FLINK-6561
Project:
[
https://issues.apache.org/jira/browse/FLINK-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007026#comment-16007026
]
Greg Hogan commented on FLINK-6560:
---
I had thought {{flink-tests}} was taking longer but noticed a build
[
https://issues.apache.org/jira/browse/FLINK-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007021#comment-16007021
]
ASF GitHub Bot commented on FLINK-6560:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6553.
---
Resolution: Not A Problem
Oh boy, i just forgot the generics on the original DataStream...
>
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3875
[FLINK-6560] [build] Restore maven parallelism in flink-tests
Configure a default value for Maven variable 'flink.forkCountTestPackage'.
You can merge this pull request into a Git repository by
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006995#comment-16006995
]
Stefan Richter commented on FLINK-5053:
---
I have opened this jira to track everything that should
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006987#comment-16006987
]
vishnu viswanath commented on FLINK-5053:
-
is this task complete, I see all the pull requests for
[
https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6414.
---
> Use scala.binary.version in place of change-scala-version.sh
>
[
https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6414.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed via 35c087129e2a27c2db47c5ed5ce3fb3523a7c719
[
https://issues.apache.org/jira/browse/FLINK-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006960#comment-16006960
]
ASF GitHub Bot commented on FLINK-6466:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3832
+1 for 1.4 - just spent some good time cleaning up dependencies (also from
Hadoop) and this will almost certainly require to do another such pass...
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006955#comment-16006955
]
ASF GitHub Bot commented on FLINK-6414:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3800
@rmetzger I have tried to put this into 1.3 as well - seems to work...
---
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
[
https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-6541:
Priority: Critical (was: Major)
> Jar upload directory not created
>
[
https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006952#comment-16006952
]
Stephan Ewen commented on FLINK-6541:
-
Good finds!
Do you want to provide a pull request for these?
[
https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006942#comment-16006942
]
Stephan Ewen commented on FLINK-6554:
-
+1, incompatibility is always possible and should lead to a
[
https://issues.apache.org/jira/browse/FLINK-6553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006947#comment-16006947
]
Stephan Ewen commented on FLINK-6553:
-
Is this simply a missing {{@SafeVarargs}} or more?
> Calls to
[
https://issues.apache.org/jira/browse/FLINK-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-6560:
Priority: Critical (was: Minor)
> Restore maven parallelism in flink-tests
>
[
https://issues.apache.org/jira/browse/FLINK-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006939#comment-16006939
]
Stephan Ewen commented on FLINK-6560:
-
+1, I also see longer build time locally
> Restore maven
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-6514:
---
Assignee: Stephan Ewen
> Cannot start Flink Cluster in standalone mode
>
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3873#discussion_r116062457
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -163,26 +165,31 @@ public static ConjunctFuture
[
https://issues.apache.org/jira/browse/FLINK-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006916#comment-16006916
]
ASF GitHub Bot commented on FLINK-6555:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006903#comment-16006903
]
Stephan Ewen commented on FLINK-6514:
-
There are more issues. The way this is set up right now also
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006889#comment-16006889
]
Stephan Ewen commented on FLINK-6116:
-
Ah, great! Yes, this definition of identity by the "StreamEdge"
Greg Hogan created FLINK-6560:
-
Summary: Restore maven parallelism in flink-tests
Key: FLINK-6560
URL: https://issues.apache.org/jira/browse/FLINK-6560
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-6393.
-
Resolution: Implemented
Fix Version/s: 1.4.0
1.3.0
master:
Stephan Ewen created FLINK-6559:
---
Summary: Rename 'slaves' to 'workers'
Key: FLINK-6559
URL: https://issues.apache.org/jira/browse/FLINK-6559
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006810#comment-16006810
]
ASF GitHub Bot commented on FLINK-6558:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3874
Looks good to me, +1 to merge 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-6548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006808#comment-16006808
]
ASF GitHub Bot commented on FLINK-6548:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3871
+1, looks good
---
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,
[
https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006685#comment-16006685
]
Kostas Kloudas edited comment on FLINK-5753 at 5/11/17 4:59 PM:
Hi
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3802
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3866
---
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-6501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6501.
-
Resolution: Fixed
Fixed in
- 1.3.0 via 95fd2d371eae43be1ea2534efe653af1a7095d0b
- 1.4.0 via
[
https://issues.apache.org/jira/browse/FLINK-6501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6501.
---
> Make sure NOTICE files are bundled into shaded JAR files
>
[
https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6515.
---
> KafkaConsumer checkpointing fails because of ClassLoader issues
>
[
https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6515.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed in
- 1.3.0 via
[
https://issues.apache.org/jira/browse/FLINK-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6508.
---
> Include license files of packaged dependencies
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6508.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed in
- 1.3.0 via
[
https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006720#comment-16006720
]
Xingcan Cui commented on FLINK-6542:
Hi [~twalthr], maybe we forget to call env.execute()...
>
[
https://issues.apache.org/jira/browse/FLINK-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006719#comment-16006719
]
Stephan Ewen commented on FLINK-5679:
-
{{PartitionedStateCheckpointingITCase}} refactored in
- 1.3
[
https://issues.apache.org/jira/browse/FLINK-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6531.
---
> Deserialize checkpoint hooks with user classloader
> --
[
https://issues.apache.org/jira/browse/FLINK-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6531.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed in
- 1.3.0 via
[
https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006709#comment-16006709
]
ASF GitHub Bot commented on FLINK-6414:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006708#comment-16006708
]
ASF GitHub Bot commented on FLINK-6532:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3868
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3800
---
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-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006685#comment-16006685
]
Kostas Kloudas commented on FLINK-5753:
---
Hi [~jurijuri]! Thanks for reporting this!
I assume that
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006684#comment-16006684
]
Aljoscha Krettek commented on FLINK-6116:
-
Got it! The problem is here
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006678#comment-16006678
]
ASF GitHub Bot commented on FLINK-4022:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006677#comment-16006677
]
ASF GitHub Bot commented on FLINK-4022:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006679#comment-16006679
]
ASF GitHub Bot commented on FLINK-4022:
---
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/3746#discussion_r115996970
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
---
@@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3746#discussion_r116000971
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@ -503,23
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3746#discussion_r115997026
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-6558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006662#comment-16006662
]
ASF GitHub Bot commented on FLINK-6558:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3874
[FLINK-6558] Disable yarn tests on Windows
This PR disabled a several YARN tests on Windows. They are failing since
they try to start an HDFS cluster.
You can merge this pull request into a Git
Chesnay Schepler created FLINK-6558:
---
Summary: Yarn tests fail on Windows
Key: FLINK-6558
URL: https://issues.apache.org/jira/browse/FLINK-6558
Project: Flink
Issue Type: Improvement
Chesnay Schepler created FLINK-6557:
---
Summary: RocksDbStateBackendTest fails on Windows
Key: FLINK-6557
URL: https://issues.apache.org/jira/browse/FLINK-6557
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006649#comment-16006649
]
ASF GitHub Bot commented on FLINK-6555:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3873
[FLINK-6555] [futures] Generalize ConjunctFuture to return results
The ConjunctFuture now returns the set of values of the individual futures
it is composed of once it is completed.
You can
1 - 100 of 263 matches
Mail list logo
