[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948460#comment-15948460
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948459#comment-15948459
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948458#comment-15948458
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948483#comment-15948483
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tony810430 commented on a diff
Github user tony810430 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3651#discussion_r108848859
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
---
@@ -222,19
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948484#comment-15948484
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tony810430 commented on a diff
Github user tony810430 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3651#discussion_r108848825
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -115,1
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948482#comment-15948482
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tony810430 commented on a diff
Github user tony810430 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3651#discussion_r108848761
--- Diff: docs/dev/connectors/kinesis.md ---
@@ -121,9 +121,11 @@ one of the following values in the provided
configuration properties (the naming
-
[
https://issues.apache.org/jira/browse/FLINK-6172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6172:
--
Description:
{code}
try {
raf = new RandomAccessFile(file, "r");
} catch (FileNotFoundException e)
Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/3595
@greghogan Thanks for the review. I have add non-negative check and update
the test with ExpectedException. But I don't think we need to call toString in
the test since we have check the position i
[
https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6143:
--
Description:
{code}
public void endSession(JobID jobID) throws Exception {
LocalFlinkMiniCluster flink = t
[
https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948441#comment-15948441
]
ASF GitHub Bot commented on FLINK-6162:
---
Github user wenlong88 commented on the issu
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3651#discussion_r108845132
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
---
@@ -222,19 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3651#discussion_r108844803
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -115,10
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3651#discussion_r108844299
--- Diff: docs/dev/connectors/kinesis.md ---
@@ -121,9 +121,11 @@ one of the following values in the provided
configuration properties (the naming
- `L
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948457#comment-15948457
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3651#discussion_r108845204
--- Diff: docs/dev/connectors/kinesis.md ---
@@ -121,9 +121,11 @@ one of the following values in the provided
configuration properties (the naming
- `L
[
https://issues.apache.org/jira/browse/FLINK-4577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948436#comment-15948436
]
ASF GitHub Bot commented on FLINK-4577:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3458
@skidder Thanks a lot for the testing and the details! This is really
helpful.
The logs and behaviour is as expected. I personally think this is good to
merge then.
@rmetzger do you hav
naveen holla U created FLINK-6218:
-
Summary: Not able to access the rows in table after converting
dataset to table after using registerdataset
Key: FLINK-6218
URL: https://issues.apache.org/jira/browse/FLINK-6
[
https://issues.apache.org/jira/browse/FLINK-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948423#comment-15948423
]
ASF GitHub Bot commented on FLINK-6014:
---
Github user shixiaogang commented on the is
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3524
@StephanEwen Thanks very much for your valuable comments. The following
are some of my thoughts.
* Now the registration of shared states is put in `CheckpointCoordinator`
because it's n
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948412#comment-15948412
]
Luke Hutchison commented on FLINK-6115:
---
[~greghogan]: fang yong's comment exactly i
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948410#comment-15948410
]
shijinkui commented on FLINK-5860:
--
[~yaroslav.mykhaylov] Thank for your work. Wait for y
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948396#comment-15948396
]
fang yong commented on FLINK-6115:
--
OMG, null value not be supported in tuple really supr
[
https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948373#comment-15948373
]
sunjincheng commented on FLINK-6204:
Hi [~Yuhong_kyo], I once again considered LinkedL
[
https://issues.apache.org/jira/browse/FLINK-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948362#comment-15948362
]
ASF GitHub Bot commented on FLINK-6210:
---
GitHub user fanyon opened a pull request:
GitHub user fanyon opened a pull request:
https://github.com/apache/flink/pull/3652
[FLINK-6210] close RocksDB in ListViaMergeSpeedMiniBenchmark && ListVâ¦
close RocksDB in ListViaMergeSpeedMiniBenchmark &&
ListViaRangeSpeedMiniBenchmark
You can merge this pull request into a Gi
[
https://issues.apache.org/jira/browse/FLINK-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fang yong reassigned FLINK-6210:
Assignee: fang yong
> RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark
> ---
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948339#comment-15948339
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tony810430 commented on the iss
Github user tony810430 commented on the issue:
https://github.com/apache/flink/pull/3650
Make a mistake again because I am not familiar with JIRA. Sorry for that.
orz
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948331#comment-15948331
]
ASF GitHub Bot commented on FLINK-5625:
---
GitHub user tony810430 opened a pull reques
GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/3651
[FLINK-5625] [kinesis] Let Date format for timestamp-based start position
in Kinesis consumer be configurable
The patch let user define their own pattern for parsing date string.
If `Consumer
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948330#comment-15948330
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tony810430 closed the pull requ
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948329#comment-15948329
]
ASF GitHub Bot commented on FLINK-5625:
---
Github user tony810430 commented on the iss
Github user tony810430 closed the pull request at:
https://github.com/apache/flink/pull/3650
---
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 tony810430 commented on the issue:
https://github.com/apache/flink/pull/3650
Typo on the task id. > <
Close and open another one to make ASF GitHub Bot can track this PR
correctly.
---
If your project is set up for it, you can reply to this email and have your
reply a
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948326#comment-15948326
]
Wei-Che Wei commented on FLINK-5624:
Sorry for putting the wrong JIRA task id. > <
>
GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/3650
[FLINK-5624] [kinesis] Let Date format for timestamp-based start position
in Kinesis consumer be configurable
The patch let user define their own pattern for parsing date string.
If `Consumer
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948312#comment-15948312
]
ASF GitHub Bot commented on FLINK-5624:
---
GitHub user tony810430 opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948283#comment-15948283
]
sunjincheng commented on FLINK-6200:
[~Yuhong_kyo] cool, I had assign this JIRA. to yo
[
https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6200:
--
Assignee: sunjincheng
> Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQ
[
https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6200:
--
Assignee: hongyuhong (was: sunjincheng)
> Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDIN
[
https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948279#comment-15948279
]
ASF GitHub Bot commented on FLINK-6200:
---
GitHub user hongyuhong opened a pull reques
GitHub user hongyuhong opened a pull request:
https://github.com/apache/flink/pull/3649
[FLINK-6200][SQL] support unbounded event time range window
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-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948276#comment-15948276
]
ASF GitHub Bot commented on FLINK-5903:
---
Github user WangTaoTheTonic commented on th
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3408
@tillrohrmann
After changing code the test results(both session and single mode) is like:
| Configurations | #vcores of container(TM) |
#slots of TM |
[
https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948273#comment-15948273
]
hongyuhong commented on FLINK-6200:
---
Hi [~sunjincheng121] i have implemented it based on
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3524#discussion_r108826346
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
---
@@ -0,0 +1,192 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948257#comment-15948257
]
ASF GitHub Bot commented on FLINK-6014:
---
Github user shixiaogang commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-5625:
--
Assignee: Wei-Che Wei
> Let Date format for timestamp-based start position in Kinesis consumer
[
https://issues.apache.org/jira/browse/FLINK-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948252#comment-15948252
]
ASF GitHub Bot commented on FLINK-6014:
---
Github user shixiaogang commented on a diff
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3524#discussion_r108826017
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
---
@@ -0,0 +1,192 @@
+/*
+ * Licensed to the Apac
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/3645
@tillrohrmann , I have submitted the heartbeats between `JobManager` and
`ResourceManager`, wish your reviews! Sorry for a little delay because of our
team outing last week.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-6120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948246#comment-15948246
]
ASF GitHub Bot commented on FLINK-6120:
---
Github user zhijiangW commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948226#comment-15948226
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3641#discussion_r108824185
--- Diff: flink-libraries/flink-table/pom.xml ---
@@ -140,6 +140,20 @@ under the License.
${project.version}
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948225#comment-15948225
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3641#discussion_r108824115
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SqlITCase.scala
---
@@ -696,6 +716,205 @@ class SqlI
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948223#comment-15948223
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3641#discussion_r108823957
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SqlITCase.scala
---
@@ -696,6 +713,205 @@ class SqlI
[
https://issues.apache.org/jira/browse/FLINK-6213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948213#comment-15948213
]
ASF GitHub Bot commented on FLINK-6213:
---
Github user barcahead commented on the issu
Github user barcahead commented on the issue:
https://github.com/apache/flink/pull/3640
@StephanEwen Thanks for the review, I tested in my environment and
`ProcessReaper` receives msg `Terminated` successfully. Because msg
`PosionPill` is not a instance of `RequiredLeaderSessionID`,
[
https://issues.apache.org/jira/browse/FLINK-6217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948128#comment-15948128
]
ASF GitHub Bot commented on FLINK-6217:
---
GitHub user haohui opened a pull request:
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3648
[FLINK-6217] ContaineredTaskManagerParameters sets off-heap memory size
incorrectly
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/haohui/flink
[
https://issues.apache.org/jira/browse/FLINK-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948097#comment-15948097
]
sunjincheng commented on FLINK-6200:
Hi [~Yuhong_kyo] do you want take this JIRA.? If
Haohui Mai created FLINK-6217:
-
Summary: ContaineredTaskManagerParameters sets off heap memory
size incorrectly
Key: FLINK-6217
URL: https://issues.apache.org/jira/browse/FLINK-6217
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reopened FLINK-5340:
-
Apologies, docs need to be added still...
> Add a metric exposing jobs uptimes
>
[
https://issues.apache.org/jira/browse/FLINK-5340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5340.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fix Version/s: 1.3.0
Added new metrics "u
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948007#comment-15948007
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3574
Hi @stefanobortoli, I wanted to merge your PR but found that there is still
a merge commit included.
Could you please remove that commit and update the PR branch (force push).
Thanks, Fab
[
https://issues.apache.org/jira/browse/FLINK-4577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947987#comment-15947987
]
ASF GitHub Bot commented on FLINK-4577:
---
Github user skidder commented on the issue:
Github user skidder commented on the issue:
https://github.com/apache/flink/pull/3458
@tzulitai I was able to scale up the number of shards on a Kinesis stream
without any interruption in processing. Looks good!
# Configuration
## Flink Cluster
Single Job Manager runni
[
https://issues.apache.org/jira/browse/FLINK-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947981#comment-15947981
]
ASF GitHub Bot commented on FLINK-2342:
---
Github user coveralls commented on the issu
Github user coveralls commented on the issue:
https://github.com/apache/flink/pull/899
[](https://coveralls.io/builds/10837706)
Changes Unknown when pulling **aa18b3dc82475c179f56fad25363184a47c36c2f on
thvasi
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947950#comment-15947950
]
ASF GitHub Bot commented on FLINK-5047:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947951#comment-15947951
]
ASF GitHub Bot commented on FLINK-5047:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947949#comment-15947949
]
ASF GitHub Bot commented on FLINK-5047:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947948#comment-15947948
]
ASF GitHub Bot commented on FLINK-5047:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947952#comment-15947952
]
ASF GitHub Bot commented on FLINK-5047:
---
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/3589#discussion_r108787775
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSlideCountWindowAggReduceGroupFunction.scala
---
@@ -0,
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3589#discussion_r108791475
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetWindowAggregateITCase.scala
---
@@ -354,4 +354,94 @@ clas
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3589#discussion_r108786995
--- Diff: docs/dev/table_api.md ---
@@ -1274,11 +1274,159 @@ A session window is defined by using the `Session`
class as follows:
Limitations
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3589#discussion_r108794347
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetWindowAggregateITCase.scala
---
@@ -354,4 +354,94 @@ clas
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3589#discussion_r108792441
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetWindowAggregateITCase.scala
---
@@ -354,4 +354,94 @@ clas
[
https://issues.apache.org/jira/browse/FLINK-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947944#comment-15947944
]
ASF GitHub Bot commented on FLINK-5975:
---
Github user addisonj commented on the issue
Github user addisonj commented on the issue:
https://github.com/apache/flink/pull/3481
@EronWright good suggestion in regards to containerInfo without an image
name, I confirmed in the mesos docs that it should work that way.
Lemme know if there is anything else!
---
If you
[
https://issues.apache.org/jira/browse/FLINK-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947920#comment-15947920
]
ASF GitHub Bot commented on FLINK-5975:
---
Github user addisonj commented on a diff in
Github user addisonj commented on a diff in the pull request:
https://github.com/apache/flink/pull/3481#discussion_r108790880
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
---
@@ -162,11 +182,65 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947887#comment-15947887
]
Aljoscha Krettek commented on FLINK-6214:
-
I think this might be "working as inten
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947867#comment-15947867
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user coveralls commented on the issu
Github user coveralls commented on the issue:
https://github.com/apache/flink/pull/896
[](https://coveralls.io/builds/10836077)
Changes Unknown when pulling **8cab6d95babf7cd4d3881df7dfba88bf9ef86270 on
mxm:li
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3647
[FLINK-5915] [table] forward the entire aggregate ArgList to aggregate
runtime functions
This PR partially solved "FLINK-5915 Add support for the aggregate on multi
fields".
The roadmap o
[
https://issues.apache.org/jira/browse/FLINK-5915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947863#comment-15947863
]
ASF GitHub Bot commented on FLINK-5915:
---
GitHub user shaoxuan-wang opened a pull req
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947842#comment-15947842
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3574
Thanks for the quick update @stefanobortoli
No worries about the extra commit. I'll squash those before merging.
Thanks, Fabian
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947800#comment-15947800
]
ASF GitHub Bot commented on FLINK-6216:
---
GitHub user shaoxuan-wang opened a pull req
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3646
[FLINK-6216] [table] DataStream unbounded groupby aggregate with early
firing
1. Implemented an unbounded groupby aggregate with early firing (period is
1, emit per every record)
2. Refac
[
https://issues.apache.org/jira/browse/FLINK-5339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947772#comment-15947772
]
Matt Sicker commented on FLINK-5339:
Any help wanted from Log4j here? I was looking in
1 - 100 of 443 matches
Mail list logo
