Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r138889015
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkTypeFactory.scala
---
@@ -211,6 +218,14 @@ class
Hai Zhou created FLINK-7625:
---
Summary: typo in docs metrics sections
Key: FLINK-7625
URL: https://issues.apache.org/jira/browse/FLINK-7625
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166216#comment-16166216
]
ASF GitHub Bot commented on FLINK-5098:
---
Github user tillrohrmann closed the pull request at:
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2830
---
[
https://issues.apache.org/jira/browse/FLINK-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5098.
Resolution: Won't Fix
Fix Version/s: (was: 1.4.0)
No longer relevant.
> Detect network
[
https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166202#comment-16166202
]
Till Rohrmann edited comment on FLINK-7294 at 9/14/17 12:55 PM:
1.4.0:
[
https://issues.apache.org/jira/browse/FLINK-7624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166204#comment-16166204
]
Tzu-Li (Gordon) Tai commented on FLINK-7624:
I think changing an existing metric name would in
[
https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7294.
--
Resolution: Fixed
Fix Version/s: 1.3.3
1.4.0
1.4.0:
Hai Zhou created FLINK-7624:
---
Summary: Add kafka-topic for "KafkaProducer" metrics
Key: FLINK-7624
URL: https://issues.apache.org/jira/browse/FLINK-7624
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7623:
Attachment: StreamingJob.java
Attached example code.
> Detecting whether an operator is
Aljoscha Krettek created FLINK-7623:
---
Summary: Detecting whether an operator is restored doesn't work
with chained state
Key: FLINK-7623
URL: https://issues.apache.org/jira/browse/FLINK-7623
[
https://issues.apache.org/jira/browse/FLINK-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166183#comment-16166183
]
Tzu-Li (Gordon) Tai commented on FLINK-7622:
[~phoenixjiangnan] curious about how this ticket
[
https://issues.apache.org/jira/browse/FLINK-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7622:
---
Description:
This issue was brought to discussion by [~sthm] offline.
Currently,
Tzu-Li (Gordon) Tai created FLINK-7622:
--
Summary: Respect local KPL queue size in FlinkKinesisProducer when
adding records to KPL client
Key: FLINK-7622
URL: https://issues.apache.org/jira/browse/FLINK-7622
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4672
Hi @Xpray, please read and fill out the template in the pull request
description. Thank you!
---
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166162#comment-16166162
]
ASF GitHub Bot commented on FLINK-7617:
---
Github user fhueske commented on the issue:
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/4672
Flink 7621
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contribution in the best possible way,
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166161#comment-16166161
]
ASF GitHub Bot commented on FLINK-7617:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4668#discussion_r138876371
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/BitSet.java
---
@@ -56,8 +56,7 @@ public void setMemorySegment(MemorySegment
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4668
+1 to merge this
---
[
https://issues.apache.org/jira/browse/FLINK-7621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7621:
--
Summary: Fix Inconsistency of CaseSensitive Configuration (was: Fix
inconsistency of CaseSensitive
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166155#comment-16166155
]
ASF GitHub Bot commented on FLINK-7617:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4668#discussion_r138875420
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/BitSet.java
---
@@ -56,8 +56,7 @@ public void setMemorySegment(MemorySegment
Ruidong Li created FLINK-7621:
-
Summary: Fix inconsistency of CaseSensitive Configuration
Key: FLINK-7621
URL: https://issues.apache.org/jira/browse/FLINK-7621
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-7620:
--
Summary: Supports user defined optimization phase (was: Supports custom
optimization phase)
>
[
https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-7620:
--
Description: Currently, the optimization phases are hardcode in
{{BatchTableEnvironment}} and
[
https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-7620:
--
Environment: (was: Currently, the optimization phases are hardcode in
{{BatchTableEnvironment}} and
[
https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-7620:
--
Issue Type: Improvement (was: Bug)
> Supports custom optimization phase
>
godfrey he created FLINK-7620:
-
Summary: Supports custom optimization phase
Key: FLINK-7620
URL: https://issues.apache.org/jira/browse/FLINK-7620
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166109#comment-16166109
]
ASF GitHub Bot commented on FLINK-7294:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4622
---
Github user taizilongxu commented on the pull request:
https://github.com/apache/flink/commit/2437da6e54cb48c4e29116b8789fbe4782b17ea7#commitcomment-24300072
In docs/dev/connectors/elasticsearch.md:
In docs/dev/connectors/elasticsearch.md on line 358:
I thinks the code is
[
https://issues.apache.org/jira/browse/FLINK-7527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166032#comment-16166032
]
ASF GitHub Bot commented on FLINK-7527:
---
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/4597#discussion_r138849512
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RedirectHandler.java
---
@@ -0,0 +1,174 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-7446:
Assignee: Fabian Hueske
> Support to define an existing field as the rowtime field for
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3816
Hi @iduanyingjie, the replacement for fold has not been implemented yet. So
you have to stick with `fold()` for now.
`fold`'s replacement will correspond to
[
https://issues.apache.org/jira/browse/FLINK-5720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166024#comment-16166024
]
ASF GitHub Bot commented on FLINK-5720:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166018#comment-16166018
]
ASF GitHub Bot commented on FLINK-7619:
---
Github user StefanRRichter commented on the issue:
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4671
[FLINK-7619] Improve abstraction in AbstractAsyncIOCallable to better fit
## What is the purpose of the change
This PR improves the abstractions around resource management for async
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4671
CC @aljoscha
---
[
https://issues.apache.org/jira/browse/FLINK-7619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166017#comment-16166017
]
ASF GitHub Bot commented on FLINK-7619:
---
GitHub user StefanRRichter opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166015#comment-16166015
]
ASF GitHub Bot commented on FLINK-7527:
---
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/4597#discussion_r138845374
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RedirectHandler.java
---
@@ -0,0 +1,174 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166006#comment-16166006
]
ASF GitHub Bot commented on FLINK-6516:
---
Github user godfreyhe commented on a diff in the pull
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3860#discussion_r138843966
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/PhysicalTableSourceScan.scala
---
@@ -70,4 +73,18 @@ abstract
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166005#comment-16166005
]
ASF GitHub Bot commented on FLINK-2170:
---
GitHub user uybhatti opened a pull request:
GitHub user uybhatti opened a pull request:
https://github.com/apache/flink/pull/4670
[FLINK-2170] [connectors] Add ORC connector for TableSource
## What is the purpose of the change
Currently, we can't read data from ORC files. In this PR, we added the
support to load data
Stefan Richter created FLINK-7619:
-
Summary: Improve abstraction in AbstractAsyncIOCallable to better
fit
Key: FLINK-7619
URL: https://issues.apache.org/jira/browse/FLINK-7619
Project: Flink
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4669
[FLINK-7618][table] Add BINARY supported in FlinkTypeFactory
## What is the purpose of the change
*Add BINARY supported in FlinkTypeFactory*
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-7618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166000#comment-16166000
]
ASF GitHub Bot commented on FLINK-7618:
---
GitHub user sunjincheng121 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165987#comment-16165987
]
ASF GitHub Bot commented on FLINK-7294:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4622
Thanks for the contribution @bbayani and the review @EronWright. Changes
look good to me. Will merge the fix and backport it to the `1.3` release branch.
---
[
https://issues.apache.org/jira/browse/FLINK-7615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165985#comment-16165985
]
Till Rohrmann commented on FLINK-7615:
--
Thanks for reporting the issue [~addis...@gmail.com]. Will
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165979#comment-16165979
]
Jingsong Lee commented on FLINK-7617:
-
[~XKing] Good suggestion, this method is useful.
But I think
[
https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165975#comment-16165975
]
ASF GitHub Bot commented on FLINK-7508:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4656#discussion_r138837100
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -171,8
[
https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165976#comment-16165976
]
ASF GitHub Bot commented on FLINK-7508:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4656#discussion_r138836822
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtilTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165962#comment-16165962
]
Jin Xiaojun commented on FLINK-7617:
hi, [~lzljs3620320], I think a better is to call
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165952#comment-16165952
]
ASF GitHub Bot commented on FLINK-7617:
---
Github user KurtYoung commented on the issue:
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/4668
Thanks @JingsongLi for your contribution
LGTM, +1 to merge
cc @fhueske @StephanEwen
---
sunjincheng created FLINK-7618:
--
Summary: Add BINARY supported in FlinkTypeFactory
Key: FLINK-7618
URL: https://issues.apache.org/jira/browse/FLINK-7618
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165938#comment-16165938
]
Timo Walther commented on FLINK-7614:
-
I will work on improving the data types documentation soon.
>
[
https://issues.apache.org/jira/browse/FLINK-7614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-7614:
---
Assignee: Timo Walther
> Add a code snippet example of a valid POJO to "Data Types"
[
https://issues.apache.org/jira/browse/FLINK-7561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165875#comment-16165875
]
ASF GitHub Bot commented on FLINK-7561:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4626
@mproch you might be interested in this one :)
---
[
https://issues.apache.org/jira/browse/FLINK-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165849#comment-16165849
]
ASF GitHub Bot commented on FLINK-7062:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4502
@fhueske Could you help to take a look at this PR in case you missed? This
PR has been ready for more than one month. Very appreciated.
---
Github user JingsongLi commented on the issue:
https://github.com/apache/flink/pull/4668
## Performance
- HashVsSortMiniBenchmark: use buildSideOuterJoin
testBuildFirst: 16s 208ms(before)10s 98ms(after)
testBuildSecond:7s 793ms(before) 6s 67ms(after)
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165836#comment-16165836
]
ASF GitHub Bot commented on FLINK-7617:
---
Github user JingsongLi commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165830#comment-16165830
]
ASF GitHub Bot commented on FLINK-7617:
---
GitHub user JingsongLi opened a pull request:
GitHub user JingsongLi opened a pull request:
https://github.com/apache/flink/pull/4668
[FLINK-7617] Remove string format in BitSet to improve the performance of
BuildSideOuterjoin
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us
[
https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165823#comment-16165823
]
ASF GitHub Bot commented on FLINK-5859:
---
GitHub user godfreyhe opened a pull request:
GitHub user godfreyhe opened a pull request:
https://github.com/apache/flink/pull/4667
[FLINK-5859] [table] Add PartitionableTableSource for partition pruning
## What is the purpose of the change
This pull request adds PartitionableTableSource for partition pruning when
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165815#comment-16165815
]
Dian Fu commented on FLINK-7606:
Hi [~matteoferrario29],
{quote}
What we've seen is that for every key
101 - 175 of 175 matches
Mail list logo
