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.
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.
{%
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
[
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
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
[
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
[
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
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
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-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 {
[
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:
[
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
[
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-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-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006016#comment-16006016
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user hongyuhong commented on the issue:
Github user hongyuhong commented on the issue:
https://github.com/apache/flink/pull/3715
Hi @fhueske , Thanks very much for the review! I have update the pr use
JoinFunction instead of FilterFunction, and i will add more test later.
Thanks very much.
Yuhong
---
If your
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115927398
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,23 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-6514:
-
[~Zentol] You're right, re-opening.
> Cannot start Flink Cluster in standalone mode
>
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006053#comment-16006053
]
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-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006106#comment-16006106
]
Robert Metzger commented on FLINK-6514:
---
We could use the maven enforcer plugin to enforce maven
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115934327
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,23 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6527:
Priority: Blocker (was: Major)
> OperatorSubtaskState has empty implementations of
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006101#comment-16006101
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
Stefan Richter created FLINK-6534:
-
Summary: SharedStateRegistry is disposing state handles from main
thread
Key: FLINK-6534
URL: https://issues.apache.org/jira/browse/FLINK-6534
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6527:
Fix Version/s: 1.3.0
> OperatorSubtaskState has empty implementations of
[
https://issues.apache.org/jira/browse/FLINK-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006102#comment-16006102
]
Aljoscha Krettek commented on FLINK-6527:
-
[~srichter] I imagine this should be blocking? Please
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115935549
--- 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=16005953#comment-16005953
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006004#comment-16006004
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user hongyuhong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6284:
Fix Version/s: 1.3.0
> Incorrect sorting of completed checkpoints in
>
[
https://issues.apache.org/jira/browse/FLINK-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6508:
Fix Version/s: 1.3.0
> Include license files of packaged dependencies
>
[
https://issues.apache.org/jira/browse/FLINK-6533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6533:
Fix Version/s: 1.3.0
> Duplicated registration of new shared state when checkpoint
Github user fanzhidongyzby commented on the issue:
https://github.com/apache/flink/pull/3802
@greghogan , when would this pr be merged ?
---
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 hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115919578
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ *
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115919570
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006003#comment-16006003
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user hongyuhong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006002#comment-16006002
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user hongyuhong commented on a diff in the pull
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r115919604
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,323 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006033#comment-16006033
]
mingleizhang commented on FLINK-6381:
-
[~kkl0u] Thanks. I guess sometimes it is a tricky problem when
[
https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006033#comment-16006033
]
mingleizhang edited comment on FLINK-6381 at 5/11/17 7:47 AM:
--
[~kkl0u]
[
https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006045#comment-16006045
]
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
@greghogan I think we should keep the `force-shading` approach to have
every project pass through the shade plugin, for various reasons. Resolving
variables (as required here) is one of them,
Stefan Richter created FLINK-6533:
-
Summary: Duplicated registration of new shared state when
checkpoint confirmations are still pending
Key: FLINK-6533
URL: https://issues.apache.org/jira/browse/FLINK-6533
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006108#comment-16006108
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user haohui commented on a diff in the pull request:
Stephan Ewen created FLINK-6546:
---
Summary: Fix dependencies of flink-mesos
Key: FLINK-6546
URL: https://issues.apache.org/jira/browse/FLINK-6546
Project: Flink
Issue Type: Bug
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3800
I think it should be fine to merge this (for 1.4 only please :)). The
problem was that in some fields the variable substitution did not work. Maven
was still able to resolve it, but sbt was failing
[
https://issues.apache.org/jira/browse/FLINK-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006590#comment-16006590
]
Chesnay Schepler commented on FLINK-6510:
-
I wanna play around with it a bit more. Sometimes a
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006591#comment-16006591
]
Stephan Ewen commented on FLINK-6116:
-
Is this a bug in the translation in the
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006592#comment-16006592
]
Stephan Ewen commented on FLINK-6116:
-
Does not quite look like a runtime bug at first glance...
>
[
https://issues.apache.org/jira/browse/FLINK-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006609#comment-16006609
]
ASF GitHub Bot commented on FLINK-6536:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3872
[FLINK-6536] [cep] Improve error message in SharedBuffer::put().
There are two commits that address both FLINK-6536 and FLINK-6255.
You can merge this pull request into a Git repository by running:
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
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-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006488#comment-16006488
]
Timo Walther commented on FLINK-6542:
-
This might be a problem of my IDE. I have to check it again
[
https://issues.apache.org/jira/browse/FLINK-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006520#comment-16006520
]
Xingcan Cui commented on FLINK-6542:
Hi [~twalthr], it also produces an empty result in my IDE.
>
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006539#comment-16006539
]
ASF GitHub Bot commented on FLINK-5998:
---
Github user rmetzger commented on the issue:
Chesnay Schepler created FLINK-6548:
---
Summary: AvroOutputFormatTest fails on Windows
Key: FLINK-6548
URL: https://issues.apache.org/jira/browse/FLINK-6548
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006566#comment-16006566
]
Kostas Kloudas edited comment on FLINK-6297 at 5/11/17 2:54 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-6297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006566#comment-16006566
]
Kostas Kloudas commented on FLINK-6297:
---
Hi [~vijayakumarpl]. Thanks for reporting this.
I tried
[
https://issues.apache.org/jira/browse/FLINK-6297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006566#comment-16006566
]
Kostas Kloudas edited comment on FLINK-6297 at 5/11/17 2:53 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006582#comment-16006582
]
Aljoscha Krettek commented on FLINK-6116:
-
It seems that the downstream operator has two input
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3832
@rmetzger +1, agree that these changes are best made at the beginning of
the release cycle.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006604#comment-16006604
]
ASF GitHub Bot commented on FLINK-6466:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6549:
Component/s: Streaming
> Improve error message for type mismatches with side outputs
>
[
https://issues.apache.org/jira/browse/FLINK-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006616#comment-16006616
]
ASF GitHub Bot commented on FLINK-6536:
---
Github user aljoscha commented on a diff in the pull
Chesnay Schepler created FLINK-6552:
---
Summary: Ambiguous error message when retrieving multiple
side-outputs
Key: FLINK-6552
URL: https://issues.apache.org/jira/browse/FLINK-6552
Project: Flink
Chesnay Schepler created FLINK-6554:
---
Summary: CompatibilityResult should contain a notCompatible()
option
Key: FLINK-6554
URL: https://issues.apache.org/jira/browse/FLINK-6554
Project: Flink
Timo Walther created FLINK-6547:
---
Summary: Improve toString methods of Table API expressions
Key: FLINK-6547
URL: https://issues.apache.org/jira/browse/FLINK-6547
Project: Flink
Issue Type:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3871
[FLINK-6548] Fix AvroOutputFormatTest#testCompression on Windows
This PR fixes `AvroOutputFormatTest#testCompression` The problem was once
again that Flink paths were directly passed to the java
[
https://issues.apache.org/jira/browse/FLINK-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006597#comment-16006597
]
Robert Metzger commented on FLINK-6510:
---
Cool, sounds good.
> Add CI integration for Windows
>
Chesnay Schepler created FLINK-6549:
---
Summary: Improve error message for type mismatches with side
outputs
Key: FLINK-6549
URL: https://issues.apache.org/jira/browse/FLINK-6549
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6554:
Description:
The {{CompatibilityResult}} allows a {{TypeSerializer}} to specify whether it
Stefan Richter created FLINK-6556:
-
Summary: Include and expose Flink version in the savepoint data
Key: FLINK-6556
URL: https://issues.apache.org/jira/browse/FLINK-6556
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-6297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006566#comment-16006566
]
Kostas Kloudas edited comment on FLINK-6297 at 5/11/17 3:38 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006557#comment-16006557
]
Robert Metzger commented on FLINK-6510:
---
Okay, then I would do a staged approach.
First we enable
[
https://issues.apache.org/jira/browse/FLINK-6297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006566#comment-16006566
]
Kostas Kloudas edited comment on FLINK-6297 at 5/11/17 2:54 PM:
Hi
Chesnay Schepler created FLINK-6550:
---
Summary: Calling ctx.collect with a null OutputTag should log a
warning or throw an exception
Key: FLINK-6550
URL: https://issues.apache.org/jira/browse/FLINK-6550
Chesnay Schepler created FLINK-6551:
---
Summary: OutputTag name should not be empty
Key: FLINK-6551
URL: https://issues.apache.org/jira/browse/FLINK-6551
Project: Flink
Issue Type:
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3872#discussion_r116017704
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java
---
@@ -96,10 +96,11 @@ public void put(
Chesnay Schepler created FLINK-6553:
---
Summary: Calls to getSideOutput() result in warnings regarding
unchecked assignments
Key: FLINK-6553
URL: https://issues.apache.org/jira/browse/FLINK-6553
[
https://issues.apache.org/jira/browse/FLINK-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-6555:
-
Issue Type: Improvement (was: Bug)
> Generalize ConjunctFuture
> -
>
>
Till Rohrmann created FLINK-6555:
Summary: Generalize ConjunctFuture
Key: FLINK-6555
URL: https://issues.apache.org/jira/browse/FLINK-6555
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5165.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.0
It appears this was
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3856
I think Stephan is working on fixing this properly for all Maven versions.
---
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-6166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006552#comment-16006552
]
Robert Metzger commented on FLINK-6166:
---
I would then suggest to update the documentation to include
[
https://issues.apache.org/jira/browse/FLINK-6548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006551#comment-16006551
]
ASF GitHub Bot commented on FLINK-6548:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006561#comment-16006561
]
ASF GitHub Bot commented on FLINK-6466:
---
Github user rmetzger commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3832
I personally think we should not include this into the 1.3 release.
Hadoop 2.8 most likely has new or changed dependencies, with different
transitive deps and so on. This can cause issues with
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3866
@rbonifacio thanks for this contribution! 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
[
https://issues.apache.org/jira/browse/FLINK-6414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006580#comment-16006580
]
ASF GitHub Bot commented on FLINK-6414:
---
Github user rmetzger commented on the issue:
[
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:
Stefan Richter created FLINK-6535:
-
Summary: JobID should not be part of the registration key to the
SharedStateRegistry
Key: FLINK-6535
URL: https://issues.apache.org/jira/browse/FLINK-6535
Project:
[
https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006137#comment-16006137
]
Kostas Kloudas commented on FLINK-6321:
---
Hi [~shashank734], I am trying to reproduce your problem
[
https://issues.apache.org/jira/browse/FLINK-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-6535:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-6537
> JobID should not be part
[
https://issues.apache.org/jira/browse/FLINK-6534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-6534:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-6537
> SharedStateRegistry is
Kostas Kloudas created FLINK-6538:
-
Summary: Emit late elements as Side Outputs
Key: FLINK-6538
URL: https://issues.apache.org/jira/browse/FLINK-6538
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006182#comment-16006182
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006218#comment-16006218
]
ASF GitHub Bot commented on FLINK-6535:
---
GitHub user StefanRRichter opened a pull request:
1 - 100 of 263 matches
Mail list logo
