Github user HuangWHWHW commented on the issue:
https://github.com/apache/flink/pull/1157
@mjsax Hi, very sorry to hang you out. I just did some other jobs last year
because of some special circumstances.
How is the progress been recently?
Please let me know if you need some he
GitHub user docete opened a pull request:
https://github.com/apache/flink/pull/3111
[FLINK-3475] [Table] DISTINCT aggregate function support for SQL queries
Copy calcite's AggregateExpandDistinctAggregatesRule to Flink project, and
do a quick fix to avoid some bad case mentioned in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821404#comment-15821404
]
ASF GitHub Bot commented on FLINK-4988:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3112
[FLINK-4988] [elasticsearch] Add Elasticsearch 5.x Connector
This PR is based on @mikedias's work in #2767 (1st commit), with additional
work to restructure the Elasticsearch connectors (2nd commit
GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/3113
[FLINK-4912] Introduce RECONCILIATING state in ExecutionGraph and Exeâ¦
This is part of the non-disruptive JobManager failure recovery.
Add a JobStatus and ExecutionState {{RECONCIL
[
https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821421#comment-15821421
]
ASF GitHub Bot commented on FLINK-4912:
---
GitHub user wangzhijiang999 opened a pull r
[
https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821443#comment-15821443
]
ASF GitHub Bot commented on FLINK-5135:
---
Github user wangzhijiang999 closed the pull
Github user wangzhijiang999 closed the pull request at:
https://github.com/apache/flink/pull/2907
---
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 featur
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/3113#discussion_r95960106
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/execution/ExecutionState.java
---
@@ -25,16 +25,23 @@
* {@code
*
* CREATED
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3113
Thanks for the PR. This looks good to me. I'm not too familiar with the
FLIP-6 plans though. I would wait for someone who is in on that to merge this.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821466#comment-15821466
]
ASF GitHub Bot commented on FLINK-4912:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821468#comment-15821468
]
ASF GitHub Bot commented on FLINK-4912:
---
Github user uce commented on the issue:
Ufuk Celebi created FLINK-5477:
--
Summary: Summary columns not aligned correctly
Key: FLINK-5477
URL: https://issues.apache.org/jira/browse/FLINK-5477
Project: Flink
Issue Type: Bug
Com
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3088
Merged, could you please close this PR?
---
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
ena
[
https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821482#comment-15821482
]
ASF GitHub Bot commented on FLINK-5407:
---
Github user aljoscha commented on the issue
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/3088
---
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 StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3088
Thanks for reviewing and merging @aljoscha !
---
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
[
https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821488#comment-15821488
]
ASF GitHub Bot commented on FLINK-5407:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5407.
---
Resolution: Fixed
Fixed on master in:
9c6eb5793258de15a83f4cf7b13180d370062531
82ed79e3f05
[
https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821489#comment-15821489
]
ASF GitHub Bot commented on FLINK-5407:
---
Github user StefanRRichter closed the pull
[
https://issues.apache.org/jira/browse/FLINK-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5296.
---
Resolution: Fixed
Implemented on master in:
fc343e0c390991d1d647df89041b4d872e29b6d3
Implemen
[
https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821498#comment-15821498
]
Aljoscha Krettek commented on FLINK-5155:
-
PR in https://github.com/apache/flink/p
[
https://issues.apache.org/jira/browse/FLINK-5421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5421.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented on release-1.2 in:
39fc07f87edd33ee7
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3102
I modified a test to catch this problem, as suggested.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821507#comment-15821507
]
ASF GitHub Bot commented on FLINK-5467:
---
Github user StefanRRichter commented on the
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3108
I think this is good, +1
What would be good is to add a line in the comment of the constructor that
says that the state returns `null` if there is no value present, yet, for the
current
[
https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821522#comment-15821522
]
ASF GitHub Bot commented on FLINK-5155:
---
Github user StephanEwen commented on the is
Github user senorcarbone commented on the issue:
https://github.com/apache/flink/pull/3088
Hey! In this upcoming [PR ](https://github.com/apache/flink/pull/1668)
there is a custom operator responsible for the logging at the iteration head.
Hope this does not break your tests in case t
[
https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821531#comment-15821531
]
ASF GitHub Bot commented on FLINK-5407:
---
Github user senorcarbone commented on the i
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3058#discussion_r95967156
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSort.scala
---
@@ -71,6 +72,21 @@ class DataSetSort(
[
https://issues.apache.org/jira/browse/FLINK-5394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821535#comment-15821535
]
ASF GitHub Bot commented on FLINK-5394:
---
Github user beyond1920 commented on a diff
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3108
Should we maybe add such a comment in the Javadoc of `ValueState` or
`ValueStateDescriptor`? That way we don't have to duplicate it for every
constructor. Or we could add it in all places.
---
If
Github user wangzhijiang999 closed the pull request at:
https://github.com/apache/flink/pull/2906
---
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 featur
[
https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821536#comment-15821536
]
ASF GitHub Bot commented on FLINK-5155:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821537#comment-15821537
]
ASF GitHub Bot commented on FLINK-5132:
---
Github user wangzhijiang999 closed the pull
[
https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821538#comment-15821538
]
ASF GitHub Bot commented on FLINK-5150:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3104
This seems crucial, +1 to add it to 1.2 and master
---
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 th
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3037#discussion_r95967912
--- Diff:
flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java
---
@@ -186,15 +186,15 @@ public void testC
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3108
Fine by me. A warning at the top to not rely on default values is 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 pro
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821544#comment-15821544
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821543#comment-15821543
]
ASF GitHub Bot commented on FLINK-5155:
---
Github user StephanEwen commented on the is
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3112
Thanks a lot for opening a pull request for this.
It looks like some of the tests are failing on travis. Does ES5 support
Java 7 ?
---
If your project is set up for it, you can reply to this em
[
https://issues.apache.org/jira/browse/FLINK-5394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821550#comment-15821550
]
ASF GitHub Bot commented on FLINK-5394:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3058#discussion_r95968750
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSort.scala
---
@@ -71,6 +72,21 @@ class DataSetSort(
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3108
Thanks for reviewing. I'll change and then 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 f
[
https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821551#comment-15821551
]
ASF GitHub Bot commented on FLINK-5155:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821553#comment-15821553
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3112
@rmetzger
Ah ... seems like ES 5.x requires at least Java 8.
-
https://www.elastic.co/guide/en/elasticsearch/reference/master/_installation.html#_installation
- https://github.com/elasti
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3112
Using maven build profiles, you can probably include the es5 connector in
java8 builds only.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3102
Thanks! I verified that the adjusted test fails before this fix and runs
fine after the fix. I'm going to merge this to master and release-1.2.
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821558#comment-15821558
]
ASF GitHub Bot commented on FLINK-5467:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821556#comment-15821556
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on the issue
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3104
Merging with the next batch.
---
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 wish
[
https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821561#comment-15821561
]
ASF GitHub Bot commented on FLINK-5150:
---
Github user zentol commented on the issue:
Atharva Inamdar created FLINK-5478:
--
Summary: Redis Sink Connector should allow update of command
without reinstatiation
Key: FLINK-5478
URL: https://issues.apache.org/jira/browse/FLINK-5478
Project:
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821566#comment-15821566
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3021
Looks good, thanks, 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 does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-5478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Atharva Inamdar updated FLINK-5478:
---
Description:
`getCommandDescription()` gets called when RedisSink is instantiated. This
happe
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3102
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5467.
--
Resolution: Fixed
Fix Version/s: 1.3.0
1.2.0
Fixed in
af244aa (release-1.2)
5
[
https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821568#comment-15821568
]
ASF GitHub Bot commented on FLINK-5467:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821574#comment-15821574
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3112
Thanks for the pointers. We'll include the profile `include-elasticsearch5`
for Java 8 builds only.
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3113
I would like to take a look at this soon...
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821576#comment-15821576
]
ASF GitHub Bot commented on FLINK-4912:
---
Github user StephanEwen commented on the is
GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/3114
[FLINK-5132]Introduce the ResourceSpec for grouping different resourcâ¦
This is part of the fine-grained resource configuration.
The current resource factors include cpu cores, heap
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821585#comment-15821585
]
ASF GitHub Bot commented on FLINK-5132:
---
GitHub user wangzhijiang999 opened a pull r
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3108
Manually 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 feature
enabled and wishes so, or
[
https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5155.
---
Resolution: Fixed
Assignee: Aljoscha Krettek
Fix Version/s: 1.2.0
Implemented
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/3108
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821595#comment-15821595
]
ASF GitHub Bot commented on FLINK-5155:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821596#comment-15821596
]
ASF GitHub Bot commented on FLINK-5155:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5479:
---
Description:
Reported in ML:
http://apache-flink-user-mailing-list-archive.2336050.n4
Tzu-Li (Gordon) Tai created FLINK-5479:
--
Summary: Per-partition watermarks in FlinkKafkaConsumer should
consider idle partitions
Key: FLINK-5479
URL: https://issues.apache.org/jira/browse/FLINK-5479
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95969879
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95969123
--- Diff: docs/dev/connectors/elasticsearch2.md ---
@@ -1,173 +0,0 @@
-title: "Elasticsearch 2.x Connector"
-nav-title: Elasticsearch 2.x
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95972131
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/EmbeddedElasticsearchNodeEnvironm
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95972955
--- Diff:
flink-connectors/flink-connector-elasticsearch5/src/test/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSinkITCase.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95972691
--- Diff:
flink-connectors/flink-connector-elasticsearch5/src/test/resources/log4j2.properties
---
@@ -0,0 +1,27 @@
+##
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95969031
--- Diff: docs/dev/connectors/elasticsearch2.md ---
@@ -1,173 +0,0 @@
--- End diff --
Can you replace the es2 page with a redirect to th
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95974130
--- Diff:
flink-connectors/flink-connector-elasticsearch2/src/test/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSinkITCase.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95973065
--- Diff:
flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchClientFactoryImpl.java
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95973995
--- Diff: flink-connectors/flink-connector-elasticsearch5/pom.xml ---
@@ -0,0 +1,121 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3112#discussion_r95968855
--- Diff: docs/dev/connectors/elasticsearch.md ---
@@ -23,158 +23,284 @@ specific language governing permissions and
limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821600#comment-15821600
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821603#comment-15821603
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821606#comment-15821606
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821601#comment-15821601
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821609#comment-15821609
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821604#comment-15821604
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821602#comment-15821602
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821605#comment-15821605
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821607#comment-15821607
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821608#comment-15821608
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user rmetzger commented on a diff in
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3113#discussion_r95975088
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/execution/ExecutionState.java
---
@@ -25,16 +25,23 @@
* {@code
*
*
[
https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821613#comment-15821613
]
ASF GitHub Bot commented on FLINK-4912:
---
Github user wangzhijiang999 commented on a
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3094
Thanks for your work! ð Could you please close this PR, I merged it.
---
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 projec
[
https://issues.apache.org/jira/browse/FLINK-5443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821616#comment-15821616
]
ASF GitHub Bot commented on FLINK-5443:
---
Github user aljoscha commented on the issue
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r95975427
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetCalc.scala
---
@@ -129,8 +131,35 @@ class DataSetCalc
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/3094
---
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 enable
1 - 100 of 237 matches
Mail list logo
