[
https://issues.apache.org/jira/browse/FLINK-10271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603872#comment-16603872
]
ting commented on FLINK-10271:
--
It is duplicate of FLINK-10269. I solve it via FLINK-10269
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603867#comment-16603867
]
ASF GitHub Bot commented on FLINK-10205:
isunjin opened a new pull request #6657
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10205:
---
Labels: pull-request-available (was: )
> Batch Job: InputSplit Fault tolerant for DataSourc
isunjin opened a new pull request #6657: [FLINK-10205] [JobManager] Batch
Job: InputSplit Fault tolerant for DataSource…
URL: https://github.com/apache/flink/pull/6657
…Task
Today DataSource Task pull InputSplits from JobManager to achieve better
performance, however,
[
https://issues.apache.org/jira/browse/FLINK-10281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-10281:
-
Description:
for example, regular expression matches text ("\w") or number ("\d") :
{code:java}
testAll
vinoyang created FLINK-10281:
Summary: Table function parse regular expression contains
backslash failed
Key: FLINK-10281
URL: https://issues.apache.org/jira/browse/FLINK-10281
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-10280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sean.miao updated FLINK-10280:
--
Description:
h3. *problem*
data like ：
{"key":"\\{\"key\":1}
"}
can be parsed correctly;
but d
[
https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603855#comment-16603855
]
ASF GitHub Bot commented on FLINK-7964:
---
yanghua commented on issue #6577: [FLINK-7
yanghua commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1
connectors
URL: https://github.com/apache/flink/pull/6577#issuecomment-418584658
It sounds like @eliaslevy ‘s idea is valid and feasible.I think we can
verify this with kafka 2.0 while keeping the existing connector un
[
https://issues.apache.org/jira/browse/FLINK-10280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sean.miao updated FLINK-10280:
--
Summary: json that contains an object can not be parsed (was: json that
contains an object can not be
sean.miao created FLINK-10280:
-
Summary: json that contains an object can not be parse
Key: FLINK-10280
URL: https://issues.apache.org/jira/browse/FLINK-10280
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603764#comment-16603764
]
Chao-Han Tsai commented on FLINK-9752:
--
[~kkl0u] what is the timeline on shipping th
[
https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603582#comment-16603582
]
ASF GitHub Bot commented on FLINK-9126:
---
Jicaar commented on a change in pull reque
[
https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603580#comment-16603580
]
ASF GitHub Bot commented on FLINK-9126:
---
Jicaar commented on a change in pull reque
Jicaar commented on a change in pull request #5876: [FLINK-9126] New
CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo
URL: https://github.com/apache/flink/pull/5876#discussion_r215059658
##
File path:
flink-connectors/flink-connector-cassandra/src/main/j
Jicaar commented on a change in pull request #5876: [FLINK-9126] New
CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo
URL: https://github.com/apache/flink/pull/5876#discussion_r215059322
##
File path:
flink-connectors/flink-connector-cassandra/src/test/j
Jicaar commented on a change in pull request #5876: [FLINK-9126] New
CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo
URL: https://github.com/apache/flink/pull/5876#discussion_r215059281
##
File path:
flink-connectors/flink-connector-cassandra/src/test/j
Jicaar commented on a change in pull request #5876: [FLINK-9126] New
CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo
URL: https://github.com/apache/flink/pull/5876#discussion_r215059262
##
File path:
flink-connectors/flink-connector-cassandra/src/test/j
[
https://issues.apache.org/jira/browse/FLINK-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9048:
--
Labels: (was: local-job-runner)
> LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManage
[
https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603301#comment-16603301
]
ASF GitHub Bot commented on FLINK-7964:
---
eliaslevy commented on issue #6577: [FLINK
eliaslevy commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1
connectors
URL: https://github.com/apache/flink/pull/6577#issuecomment-418436718
If you need to determine that a broker does not support transactions before
trying to make use of them, it may be possible to do so via
[
https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507192#comment-16507192
]
Ted Yu edited comment on FLINK-8554 at 9/4/18 4:35 PM:
---
Or use this
[
https://issues.apache.org/jira/browse/FLINK-10228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-10228:
---
Component/s: Metrics
> Add metrics for netty direct memory consumption
> ---
[
https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603262#comment-16603262
]
ASF GitHub Bot commented on FLINK-7964:
---
eliaslevy commented on issue #6577: [FLINK
eliaslevy commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1
connectors
URL: https://github.com/apache/flink/pull/6577#issuecomment-418429475
@pnowojski I mean that the Flink Kafka connector need not embedded the Kafka
version into the connector artifact name. Obviously, the
[
https://issues.apache.org/jira/browse/FLINK-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603238#comment-16603238
]
ASF GitHub Bot commented on FLINK-10229:
yanghua commented on issue #6631: [FLIN
yanghua commented on issue #6631: [FLINK-10229] [sql-client] Support listing of
views
URL: https://github.com/apache/flink/pull/6631#issuecomment-418423933
@hequn8128 thanks for your suggestion, I have refactored this PR, can you
review it again?
--
[
https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603049#comment-16603049
]
ASF GitHub Bot commented on FLINK-7964:
---
pnowojski commented on issue #6577: [FLINK
pnowojski commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1
connectors
URL: https://github.com/apache/flink/pull/6577#issuecomment-418367186
@eliaslevy what do you mean by:
> @pnowojski rather than releasing flink-connector-kafka-1.0, I would just
release flink-connector-k
[
https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603024#comment-16603024
]
ASF GitHub Bot commented on FLINK-10261:
xueyumusic commented on a change in pul
xueyumusic commented on a change in pull request #6648: [FLINK-10261][table]
fix insert into with order by
URL: https://github.com/apache/flink/pull/6648#discussion_r214907206
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCa
[
https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16603020#comment-16603020
]
ASF GitHub Bot commented on FLINK-10261:
xueyumusic commented on a change in pul
xueyumusic commented on a change in pull request #6648: [FLINK-10261][table]
fix insert into with order by
URL: https://github.com/apache/flink/pull/6648#discussion_r214906564
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/validation/
[
https://issues.apache.org/jira/browse/FLINK-10234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602973#comment-16602973
]
ASF GitHub Bot commented on FLINK-10234:
yanghua commented on issue #6652: [FLIN
yanghua commented on issue #6652: [FLINK-10234][runtime] Fix ambiguous lambda
usage
URL: https://github.com/apache/flink/pull/6652#issuecomment-418344741
+1
This is an automated message from the Apache Git Service.
To respond
yanghua commented on issue #6649: [hotfix][flink-connector-filesystem] modify
typo in BucketingSink
URL: https://github.com/apache/flink/pull/6649#issuecomment-418344342
+1, cc @zentol
This is an automated message from the A
yanghua commented on issue #6647: [hotfix][docs] Fix error html tag in batch
index documentatition
URL: https://github.com/apache/flink/pull/6647#issuecomment-418343928
+1
This is an automated message from the Apache Git Serv
[
https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-10279:
-
Summary: Make jython limitations more obvious in documentation (was:
Better clarificati
[
https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise reassigned FLINK-10279:
Assignee: Thomas Weise
> Better clarification for status
> --
[
https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602886#comment-16602886
]
Thomas Weise commented on FLINK-10279:
--
The implication isn't obvious and it can be
[
https://issues.apache.org/jira/browse/FLINK-10242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602881#comment-16602881
]
ASF GitHub Bot commented on FLINK-10242:
zentol opened a new pull request #6656:
zentol opened a new pull request #6656: [FLINK-10242][metrics] Disable latency
metrics by default
URL: https://github.com/apache/flink/pull/6656
## What is the purpose of the change
This PR disables latency tracking by default, and adds a config option for
configuring the default la
[
https://issues.apache.org/jira/browse/FLINK-10242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10242:
---
Labels: pull-request-available (was: )
> Disable latency metrics by default
> -
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602810#comment-16602810
]
Egon Brix Pedersen commented on FLINK-10114:
Thank you very much [~yanghua]
[
https://issues.apache.org/jira/browse/FLINK-4175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602806#comment-16602806
]
zhijiang commented on FLINK-4175:
-
I am interested in this improvement and want to know w
[
https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602793#comment-16602793
]
ASF GitHub Bot commented on FLINK-10074:
yanghua commented on issue #6567: [FLIN
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-418295546
@azagrebin thanks for your suggestion, I have refactored this PR, please
review again~
[
https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-10279:
-
Component/s: Python API
> Better clarification for status
>
[
https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602742#comment-16602742
]
Chesnay Schepler commented on FLINK-10279:
--
It says right at the top that it's
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602721#comment-16602721
]
zhangminglei commented on FLINK-10114:
--
Thank you so much @vinoyang. Lots of users
[
https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602677#comment-16602677
]
ASF GitHub Bot commented on FLINK-10150:
zentol closed pull request #6655: [1.6]
[
https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602676#comment-16602676
]
ASF GitHub Bot commented on FLINK-10150:
zentol closed pull request #6654: [1.5]
zentol closed pull request #6655: [1.6][FLINK-10150][metrics] Fix
OperatorMetricGroup creation for Batch
URL: https://github.com/apache/flink/pull/6655
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenanc
zentol closed pull request #6654: [1.5][FLINK-10150][metrics] Fix
OperatorMetricGroup creation for Batch
URL: https://github.com/apache/flink/pull/6654
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenanc
[
https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602674#comment-16602674
]
vinoyang commented on FLINK-10279:
--
cc [~Zentol]
> Better clarification for status
> -
55 matches
Mail list logo
