[
https://issues.apache.org/jira/browse/FLINK-5281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823098#comment-15823098
]
ASF GitHub Bot commented on FLINK-5281:
---
GitHub user mushketyk opened a pull request
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3124
[FLINK-5281] Extend KafkaJsonTableSources to support nested data
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-5475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann deleted FLINK-5475:
-
> Extend DC/OS documentation
> --
>
> Key: FLINK-5475
>
Till Rohrmann created FLINK-5491:
Summary: Document default settings for yarn cluster mode
Key: FLINK-5491
URL: https://issues.apache.org/jira/browse/FLINK-5491
Project: Flink
Issue Type: Sub
Till Rohrmann created FLINK-5492:
Summary: BootstrapTools log wrong address of started ActorSystem
Key: FLINK-5492
URL: https://issues.apache.org/jira/browse/FLINK-5492
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-5491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5491:
-
Description:
When starting a per job cluster with {{flink run -m yarn-cluster}}, then it is
possi
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3068
+1 to merge
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823165#comment-15823165
]
ASF GitHub Bot commented on FLINK-5380:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3123
Good change. Thank you.
I'll merge it right away
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-5489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823168#comment-15823168
]
ASF GitHub Bot commented on FLINK-5489:
---
Github user rmetzger commented on the issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3123
---
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-5489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823170#comment-15823170
]
ASF GitHub Bot commented on FLINK-5489:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-5489.
---
Resolution: Fixed
Fix Version/s: 1.3.0
Thank you for fixing this!
Resolved in master w
[
https://issues.apache.org/jira/browse/FLINK-5489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-5489:
--
Component/s: Build System
> maven release:prepare fails due to invalid JDOM comments in pom.xml
Till Rohrmann created FLINK-5493:
Summary: FlinkDistributionOverlay does not properly display
missing environment variables
Key: FLINK-5493
URL: https://issues.apache.org/jira/browse/FLINK-5493
Projec
Till Rohrmann created FLINK-5494:
Summary: Improve Mesos documentation
Key: FLINK-5494
URL: https://issues.apache.org/jira/browse/FLINK-5494
Project: Flink
Issue Type: Sub-task
Comp
Till Rohrmann created FLINK-5495:
Summary: ZooKeeperMesosWorkerStore cannot be instantiated
Key: FLINK-5495
URL: https://issues.apache.org/jira/browse/FLINK-5495
Project: Flink
Issue Type: Bu
Till Rohrmann created FLINK-5496:
Summary: ClassCastException when using Mesos HA mode
Key: FLINK-5496
URL: https://issues.apache.org/jira/browse/FLINK-5496
Project: Flink
Issue Type: Bug
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3078#discussion_r96145771
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java
---
@@ -0,0 +1,63
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3078#discussion_r96145754
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@ -253,6 +262,35
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3078#discussion_r96145761
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@ -253,6 +262,35
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3078#discussion_r96145784
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java
---
@@ -0,0 +1,63
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3078#discussion_r96145735
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@ -253,6 +262,35
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3078#discussion_r96145793
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyTest.java
---
@@ -0,0 +1,63
[
https://issues.apache.org/jira/browse/FLINK-5355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823234#comment-15823234
]
ASF GitHub Bot commented on FLINK-5355:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823231#comment-15823231
]
ASF GitHub Bot commented on FLINK-5355:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823232#comment-15823232
]
ASF GitHub Bot commented on FLINK-5355:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823235#comment-15823235
]
ASF GitHub Bot commented on FLINK-5355:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823236#comment-15823236
]
ASF GitHub Bot commented on FLINK-5355:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823233#comment-15823233
]
ASF GitHub Bot commented on FLINK-5355:
---
Github user tzulitai commented on a diff in
Github user xhumanoid commented on the issue:
https://github.com/apache/flink/pull/3106
@zentol
what do you think about remove
if (numBytesOut != null) {
and replace
numBytesOut = metrics.getNumBytesOutCounter();
with
+ if (metrics.getNumBytesOu
[
https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823250#comment-15823250
]
ASF GitHub Bot commented on FLINK-5118:
---
Github user xhumanoid commented on the issu
Alexey Diomin created FLINK-5497:
Summary: remove duplicated tests
Key: FLINK-5497
URL: https://issues.apache.org/jira/browse/FLINK-5497
Project: Flink
Issue Type: Improvement
Compo
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3106
@xhumanoid The metrics returned by the TaskIOMetricGroup can't actually be
null, so I wouldn't put too much thought into dealing with that case.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823265#comment-15823265
]
ASF GitHub Bot commented on FLINK-5118:
---
Github user zentol commented on the issue:
Github user xhumanoid commented on the issue:
https://github.com/apache/flink/pull/3106
@zentol I asked because you always check on null when you try writing to
Counter
or is it prevent uninitialized state?
---
If your project is set up for it, you can reply to this email and ha
[
https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823272#comment-15823272
]
ASF GitHub Bot commented on FLINK-5118:
---
Github user xhumanoid commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823352#comment-15823352
]
Zhenghua Gao commented on FLINK-3475:
-
I have created a pr for this issue: https://git
[
https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823395#comment-15823395
]
Jark Wu commented on FLINK-5414:
Calcite 1.11 has been released. I will start to work on t
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/2935
---
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-4930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823397#comment-15823397
]
ASF GitHub Bot commented on FLINK-4930:
---
Github user shuai-xu closed the pull reques
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3111#discussion_r96160082
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/AggregationTest.scala
---
@@ -165,9 +165,13 @@ class AggregationTest extends Tabl
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3111#discussion_r96160329
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/FlinkAggregateExpandDistinctAggregatesRule.java
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823450#comment-15823450
]
ASF GitHub Bot commented on FLINK-3475:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823451#comment-15823451
]
ASF GitHub Bot commented on FLINK-3475:
---
Github user wuchong commented on a diff in
lincoln.lee created FLINK-5498:
--
Summary: Fix JoinITCase and add support for filter expressions on
the On clause in left/right outer joins
Key: FLINK-5498
URL: https://issues.apache.org/jira/browse/FLINK-5498
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-5498:
---
Description:
I found the expected result of a unit test case incorrect compare to that in a
RDMBS,
s
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-5498:
---
Description:
I found the expected result of a unit test case incorrect compare to that in a
RDMBS,
s
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-5498:
---
Description:
I found the expected result of a unit test case incorrect compare to that in a
RDMBS,
s
Zhijiang Wang created FLINK-5499:
Summary: Try to reuse the resource location of previous execution
attempt when allocate slot
Key: FLINK-5499
URL: https://issues.apache.org/jira/browse/FLINK-5499
Pro
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5499:
-
Summary: Try to reuse the resource location of prior execution attempt when
allocate slot (was: T
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5499:
-
Summary: Try to reuse the resource location of prior execution attempt in
allocating slot (was: T
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-5498:
---
Description:
I found the expected result of a unit test case incorrect compare to that in a
RDMBS,
s
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5499:
-
Description: Currently when schedule execution to request to allocate slot
from {{SlotPool}}, the
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5499:
-
Description: Currently when schedule execution to request to allocate slot
from {{SlotPool}}, the
[
https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5499:
Assignee: Zhijiang Wang
> Try to reuse the resource location of prior execution attempt in
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3081
Hi @tillrohrmann, did you find any time to check #3077 and 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
[
https://issues.apache.org/jira/browse/FLINK-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823577#comment-15823577
]
ASF GitHub Bot commented on FLINK-5426:
---
Github user Fokko commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-5498:
---
Description:
I found the expected result of a unit test case incorrect compare to that in a
RDMBS,
s
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3081
I've rebased both branches with 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
enable
[
https://issues.apache.org/jira/browse/FLINK-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823579#comment-15823579
]
ASF GitHub Bot commented on FLINK-5426:
---
Github user Fokko commented on the issue:
61 matches
Mail list logo
