GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4507
[FLINK-7404] [table] Generate code for non-equi join conditions only.
## What is the purpose of the change
Generate code only for non-equi join conditions for Table API / SQL batch
joins.
[
https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7395:
Priority: Major (was: Blocker)
> NumBytesOut metric in RecordWriter call synchronized
[
https://issues.apache.org/jira/browse/FLINK-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120143#comment-16120143
]
ASF GitHub Bot commented on FLINK-7372:
---
Github user zentol commented on the issue:
Fabian Hueske created FLINK-7404:
Summary: Table API batch join code-gen's equi-join conditions
Key: FLINK-7404
URL: https://issues.apache.org/jira/browse/FLINK-7404
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120102#comment-16120102
]
ASF GitHub Bot commented on FLINK-7404:
---
GitHub user fhueske opened a pull request:
Github user rangadi commented on the issue:
https://github.com/apache/flink/pull/4239
May be an extra shuffle to make small batches could help. Another option is
to buffer all the records in state and write them all inside commit(). But not
sure how costly it is to save all the
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4473
@tzulitai @aljoscha Let me know if this PR looks good. Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120483#comment-16120483
]
Rong Rong commented on FLINK-7357:
--
Seems like the logical plan generated from Having inserts another
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121106#comment-16121106
]
ASF GitHub Bot commented on FLINK-7406:
---
GitHub user zhijiangW opened a pull request:
GitHub user zhijiangW opened a pull request:
https://github.com/apache/flink/pull/4509
[FLINK-7406][network] Implement Netty receiver incoming pipeline for
credit-based
## What is the purpose of the change
Currently `PartitionRequestClientHandler` receives and reads
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121094#comment-16121094
]
Aljoscha Krettek commented on FLINK-7407:
-
[~tzulitai] Should we make this a blocker, because it
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121011#comment-16121011
]
ASF GitHub Bot commented on FLINK-7368:
---
Github user asdf2014 commented on a diff in the pull
zhijiang created FLINK-7406:
---
Summary: Implement Netty receiver incoming pipeline for
credit-based
Key: FLINK-7406
URL: https://issues.apache.org/jira/browse/FLINK-7406
Project: Flink
Issue Type:
Github user asdf2014 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4472#discussion_r132358492
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java
---
@@ -24,8 +24,8 @@
import org.slf4j.Logger;
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Priority: Critical (was: Major)
> Assumption of partition id strict contiguity is
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Affects Version/s: 1.4.0
> Assumption of partition id strict contiguity is too naive
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Description:
In the Kafka Consumer's {{AbstractPartitionDiscoverer}}, for partition
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-7407:
--
Assignee: Tzu-Li (Gordon) Tai
> Assumption of partition id strict contiguity
Tzu-Li (Gordon) Tai created FLINK-7407:
--
Summary: Assumption of partition id strict contiguity is too naive
in Kafka consumer's AbstractPartitionDiscoverer
Key: FLINK-7407
URL:
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Priority: Blocker (was: Critical)
> Assumption of partition id strict contiguity is
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121099#comment-16121099
]
Tzu-Li (Gordon) Tai commented on FLINK-7407:
[~aljoscha] this information isn't independently
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119498#comment-16119498
]
ASF GitHub Bot commented on FLINK-7394:
---
GitHub user zhijiangW opened a pull request:
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4500
[FLINK-6787] Fix Job-/StoppingException extend FlinkException
## What is the purpose of the change
Fix Job-/StoppingException extend FlinkException
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-6787:
Assignee: Fang Yong
> Job-/StoppableException should extend FlinkException
>
Chesnay Schepler created FLINK-7395:
---
Summary: NumBytesOut metric in RecordWriter call synchronized
method
Key: FLINK-7395
URL: https://issues.apache.org/jira/browse/FLINK-7395
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119556#comment-16119556
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4239
I think there is no way we can to handle it in any different way then to
increase the timeout to some very large value. Or is it?
---
If your project is set up for it, you can reply to this email
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/4404
@fhueske
Can you take a look at #4493 ?
---
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-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119575#comment-16119575
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user tzulitai commented on the issue:
GitHub user zhijiangW opened a pull request:
https://github.com/apache/flink/pull/4499
[FLINK-7394][core] Implement basic InputChannel for credit-based logic
## What is the purpose of the change
This pull request prepares the basic works for credit-based interaction
with
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4501
[FLINK-7352] [tests] Stabilize ExecutionGraphRestartTest
## What is the purpose of the change
Introduce an explicit waiting for the deployment of tasks. This replaces
the loose
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4473
@bowenli86 no, they're provided via a `Properties` when creating a
`FlinkKinesisProducer`
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119492#comment-16119492
]
Till Rohrmann commented on FLINK-7352:
--
I think [~StephanEwen] is right and the problem is
[
https://issues.apache.org/jira/browse/FLINK-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119510#comment-16119510
]
ASF GitHub Bot commented on FLINK-6787:
---
GitHub user zjureel opened a pull request:
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4454#discussion_r132112682
--- Diff: docs/dev/testing.md ---
@@ -0,0 +1,189 @@
+---
+title: "Testing"
+nav-parent_id: dev
+nav-id: testing
+nav-pos: 99
+---
[
https://issues.apache.org/jira/browse/FLINK-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7352:
Assignee: Till Rohrmann
> ExecutionGraphRestartTest timeouts
>
[
https://issues.apache.org/jira/browse/FLINK-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119545#comment-16119545
]
ASF GitHub Bot commented on FLINK-7352:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119576#comment-16119576
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user tedyu commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4493
Thanks @tedyu. I will merge this in my 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
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119582#comment-16119582
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-7363.
Resolution: Fixed
Fixed by
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4494
Thank your for the review @greghogan . I made 2 more changes to the
kinesis/shaded-curator poms; they were including/relocating asm in their
shade-plugin configuration even though neither appears to
Aljoscha Krettek created FLINK-7396:
---
Summary: Don't put multiple directories in HADOOP_CONF_DIR in
config.sh
Key: FLINK-7396
URL: https://issues.apache.org/jira/browse/FLINK-7396
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7396:
Priority: Blocker (was: Major)
> Don't put multiple directories in HADOOP_CONF_DIR in
[
https://issues.apache.org/jira/browse/FLINK-7107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119640#comment-16119640
]
ASF GitHub Bot commented on FLINK-7107:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4489
Thanks for the review @aljoscha. Merging 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
[
https://issues.apache.org/jira/browse/FLINK-7375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119656#comment-16119656
]
ASF GitHub Bot commented on FLINK-7375:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119662#comment-16119662
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119660#comment-16119660
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4492#discussion_r132141995
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java
---
@@ -101,127 +98,112 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119668#comment-16119668
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119633#comment-16119633
]
ASF GitHub Bot commented on FLINK-7026:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4494
@zentol I think it should be safe to remove that asm relocation (for
Kinesis, as far as I'm aware of).
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4465
Thanks for the review @zentol. Merging 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
[
https://issues.apache.org/jira/browse/FLINK-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119642#comment-16119642
]
ASF GitHub Bot commented on FLINK-7383:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119653#comment-16119653
]
ASF GitHub Bot commented on FLINK-7372:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4486
Rebased onto the latest 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 this feature
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4492#discussion_r132141613
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/WebMonitorOptions.java
---
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119659#comment-16119659
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4492#discussion_r132141830
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/WebMonitorOptions.java
---
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119667#comment-16119667
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119666#comment-16119666
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4492#discussion_r132142466
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerGateway.java
---
@@ -63,4 +70,103 @@
* @return Future
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4492#discussion_r132142385
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java
---
@@ -101,127 +98,112 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4492#discussion_r132142562
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -247,6 +262,8 @@ public static Path
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119682#comment-16119682
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119631#comment-16119631
]
ASF GitHub Bot commented on FLINK-7026:
---
Github user zentol commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4489
---
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-7107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7107.
Resolution: Fixed
Fix Version/s: 1.4.0
Added via a570aa5c0c7d9a18e6cdcb689dcad9ff173dc2ac
>
[
https://issues.apache.org/jira/browse/FLINK-7107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119648#comment-16119648
]
ASF GitHub Bot commented on FLINK-7107:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119649#comment-16119649
]
ASF GitHub Bot commented on FLINK-7383:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7383.
Resolution: Fixed
Fix Version/s: 1.4.0
Removed via ff70cc3afd004aad4016f94485b95a3ced1639c9
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4465
---
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-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119651#comment-16119651
]
ASF GitHub Bot commented on FLINK-7372:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4483
Rebased this PR onto the latest 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 this
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4483#discussion_r132140409
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/client/JobClientActorTest.java
---
@@ -388,7 +391,9 @@ else if (message instanceof
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119657#comment-16119657
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4492#discussion_r132141346
--- Diff: docs/setup/config.md ---
@@ -389,6 +389,10 @@ These parameters allow for advanced tuning. The
default values are sufficient wh
-
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119675#comment-16119675
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4492#discussion_r132143993
--- Diff: docs/setup/config.md ---
@@ -389,6 +389,10 @@ These parameters allow for advanced tuning. The
default values are sufficient wh
-
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4492
Thanks for the review @zentol. I've addressed most of your comments modulo
the web frontend configuration options and rebased the PR onto the latest
master.
I've tested the web
[
https://issues.apache.org/jira/browse/FLINK-7397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7397.
---
Resolution: Not A Problem
Please ask questions on the {{u...@flink.apache.org}} or
[
https://issues.apache.org/jira/browse/FLINK-7397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119722#comment-16119722
]
saif.aljumaili commented on FLINK-7397:
---
iam send it
> Which scheduling mechanism and algorithm
[
https://issues.apache.org/jira/browse/FLINK-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119728#comment-16119728
]
ASF GitHub Bot commented on FLINK-7062:
---
GitHub user dianfu opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119732#comment-16119732
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119741#comment-16119741
]
ASF GitHub Bot commented on FLINK-6982:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4503
[FLINK-6982] [guava] Integrate flink-shaded-guava-18
## What is the purpose of the change
This PR integrates the shaded guava dependency from flink-shaded.
Basically, replace all usages of
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4477
Thanks @NicoK. I will relocate the files according to the new structure and
merge this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119760#comment-16119760
]
ASF GitHub Bot commented on FLINK-7021:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4214#discussion_r132162054
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
---
@@ -196,4 +198,12 @@ protected
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4477
---
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-7370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119764#comment-16119764
]
ASF GitHub Bot commented on FLINK-7370:
---
Github user asfgit closed the pull request at:
saif.aljumaili created FLINK-7397:
-
Summary: Which scheduling mechanism and algorithm used for
scheduling Jobs
Key: FLINK-7397
URL: https://issues.apache.org/jira/browse/FLINK-7397
Project: Flink
GitHub user dianfu opened a pull request:
https://github.com/apache/flink/pull/4502
[FLINK-7062] [table, cep] Support the basic functionality of MATCH_RECOGNIZE
## What is the purpose of the change
*This pull request adds the basic support of MATCH_RECOGNIZE.*
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4492#discussion_r132155748
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java
---
@@ -101,127 +98,112 @@ public void update() {
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4494
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-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119747#comment-16119747
]
ASF GitHub Bot commented on FLINK-7026:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119757#comment-16119757
]
ASF GitHub Bot commented on FLINK-7370:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4488
@wuchong No problem. Thursday is fine.
---
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-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119770#comment-16119770
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user twalthr commented on the issue:
1 - 100 of 239 matches
Mail list logo