[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561008#comment-16561008
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull re
hequn8128 commented on a change in pull request #6432: [FLINK-9970] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205960985
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Scalar
[
https://issues.apache.org/jira/browse/FLINK-9943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560997#comment-16560997
]
ASF GitHub Bot commented on FLINK-9943:
---
chuanlei commented on issue #6429: [FLINK-
chuanlei commented on issue #6429: [FLINK-9943] Support
TaskManagerMetricQueryServicePaths msg in JobManager Actor
URL: https://github.com/apache/flink/pull/6429#issuecomment-408650270
@twalthr could you please have a look for this pr?
we think flink should expose its metrics directl
[
https://issues.apache.org/jira/browse/FLINK-9988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560996#comment-16560996
]
ASF GitHub Bot commented on FLINK-9988:
---
yanghua commented on issue #6441: [FLINK-9
yanghua commented on issue #6441: [FLINK-9988][rest] Add deprecated keys for
server bind address
URL: https://github.com/apache/flink/pull/6441#issuecomment-408650246
+1
This is an automated message from the Apache Git Servic
[
https://issues.apache.org/jira/browse/FLINK-9993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560995#comment-16560995
]
vinoyang commented on FLINK-9993:
-
cc [~till.rohrmann]
> Wordcount end-to-end test in do
vinoyang created FLINK-9993:
---
Summary: Wordcount end-to-end test in docker failed
Key: FLINK-9993
URL: https://issues.apache.org/jira/browse/FLINK-9993
Project: Flink
Issue Type: Bug
Re
[
https://issues.apache.org/jira/browse/FLINK-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-9984:
-
Assignee: Ruidong Li
> Add a byte array table format factory
> -
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560994#comment-16560994
]
ASF GitHub Bot commented on FLINK-9963:
---
Xpray commented on issue #6447: [FLINK-996
Xpray commented on issue #6447: [FLINK-9963][TableAPI & SQL] Add a string table
format factory
URL: https://github.com/apache/flink/pull/6447#issuecomment-408649986
@twalthr, It seems that this pr can be more generic to
`SingleColumnRowFormat`, so FLINK-9984 can be a concrete implementatio
[
https://issues.apache.org/jira/browse/FLINK-9958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560993#comment-16560993
]
ASF GitHub Bot commented on FLINK-9958:
---
Xpray commented on issue #6426: [FLINK-995
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560992#comment-16560992
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on a change in pull requ
Xpray commented on issue #6426: [FLINK-9958][DataSet] Fix potential NPE for
delta iteration of DataSet
URL: https://github.com/apache/flink/pull/6426#issuecomment-408649629
hi @yanghua thanks for you advice. I've updated the PR.
Best
yanghua commented on a change in pull request #6432: [FLINK-9970] Add ASCII/CHR
function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205959875
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFu
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560991#comment-16560991
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull re
hequn8128 commented on a change in pull request #6432: [FLINK-9970] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205959747
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Scalar
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560990#comment-16560990
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull re
hequn8128 commented on a change in pull request #6432: [FLINK-9970] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205959687
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Scalar
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560989#comment-16560989
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on a change in pull requ
yanghua commented on a change in pull request #6432: [FLINK-9970] Add ASCII/CHR
function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205959654
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFu
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560988#comment-16560988
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull re
hequn8128 commented on a change in pull request #6432: [FLINK-9970] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205959590
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Scalar
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560987#comment-16560987
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560986#comment-16560986
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull re
hequn8128 commented on a change in pull request #6432: [FLINK-9970] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205959590
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Scalar
hequn8128 commented on a change in pull request #6432: [FLINK-9970] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205959590
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Scalar
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9982:
---
Assignee: zhangminglei (was: dalongliu)
> NPE in EnumValueSerializer#copy
> ---
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9963:
--
Labels: pull-request-available (was: )
> Add a string table format factory
> -
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560982#comment-16560982
]
ASF GitHub Bot commented on FLINK-9963:
---
Xpray opened a new pull request #6447: [FL
[
https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9985:
---
Assignee: zhangminglei (was: dalongliu)
> Incorrect parameter order in document
> -
Xpray opened a new pull request #6447: [FLINK-9963][TableAPI & SQL] Add a
string table format factory
URL: https://github.com/apache/flink/pull/6447
## What is the purpose of the change
Add a string table format factory
## Brief change log
- *add StringRowFormatFa
vinoyang created FLINK-9992:
---
Summary: FsStorageLocationReferenceTest#testEncodeAndDecode failed
in Travis CI
Key: FLINK-9992
URL: https://issues.apache.org/jira/browse/FLINK-9992
Project: Flink
I
vinoyang created FLINK-9991:
---
Summary: Add regex_replace supported in TableAPI and SQL
Key: FLINK-9991
URL: https://issues.apache.org/jira/browse/FLINK-9991
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9990:
Description:
regex_extract is a very useful function, it returns a string based on a regex
pattern and a i
vinoyang created FLINK-9990:
---
Summary: Add regex_extract supported in TableAPI and SQL
Key: FLINK-9990
URL: https://issues.apache.org/jira/browse/FLINK-9990
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560975#comment-16560975
]
ASF GitHub Bot commented on FLINK-8302:
---
yanghua commented on a change in pull requ
[
https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560977#comment-16560977
]
ASF GitHub Bot commented on FLINK-8302:
---
yanghua commented on a change in pull requ
[
https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560976#comment-16560976
]
ASF GitHub Bot commented on FLINK-8302:
---
yanghua commented on a change in pull requ
[
https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560978#comment-16560978
]
ASF GitHub Bot commented on FLINK-8302:
---
yanghua commented on a change in pull requ
yanghua commented on a change in pull request #6445: [FLINK-8302][Table API &
SQL] Add SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r205958595
##
File path: docs/dev/table/tableApi.md
##
@@ -3598,6 +3598,28 @@ numeric1 % numeric2
yanghua commented on a change in pull request #6445: [FLINK-8302][Table API &
SQL] Add SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r205958632
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressio
yanghua commented on a change in pull request #6445: [FLINK-8302][Table API &
SQL] Add SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r205958635
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressio
yanghua commented on a change in pull request #6445: [FLINK-8302][Table API &
SQL] Add SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r205958599
##
File path: docs/dev/table/tableApi.md
##
@@ -3598,6 +3598,28 @@ numeric1 % numeric2
[
https://issues.apache.org/jira/browse/FLINK-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16258309#comment-16258309
]
Ted Yu edited comment on FLINK-7588 at 7/29/18 1:33 AM:
bq. Be ca
[
https://issues.apache.org/jira/browse/FLINK-9877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560935#comment-16560935
]
ASF GitHub Bot commented on FLINK-9877:
---
eliaslevy commented on issue #6407: [FLINK
eliaslevy commented on issue #6407: [FLINK-9877][docs] Add documentation page
for different datastream joins
URL: https://github.com/apache/flink/pull/6407#issuecomment-408643197
The documentation needs to discuss how the watermarks are delayed if they
are.
---
TisonKun commented on a change in pull request #6446: [FLINK-9240] Avoid
deprecated Akka methods
URL: https://github.com/apache/flink/pull/6446#discussion_r205956054
##
File path:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner
[
https://issues.apache.org/jira/browse/FLINK-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560923#comment-16560923
]
ASF GitHub Bot commented on FLINK-9240:
---
TisonKun commented on a change in pull req
[
https://issues.apache.org/jira/browse/FLINK-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560922#comment-16560922
]
ASF GitHub Bot commented on FLINK-9240:
---
TisonKun commented on a change in pull req
TisonKun commented on a change in pull request #6446: [FLINK-9240] Avoid
deprecated Akka methods
URL: https://github.com/apache/flink/pull/6446#discussion_r205956013
##
File path:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
##
@@ -186
TisonKun commented on a change in pull request #6446: [FLINK-9240] Avoid
deprecated Akka methods
URL: https://github.com/apache/flink/pull/6446#discussion_r205955993
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationMasterRunner.java
##
@@ -401,1
TisonKun commented on a change in pull request #6446: [FLINK-9240] Avoid
deprecated Akka methods
URL: https://github.com/apache/flink/pull/6446#discussion_r205956009
##
File path:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
##
@@ -228
[
https://issues.apache.org/jira/browse/FLINK-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560924#comment-16560924
]
ASF GitHub Bot commented on FLINK-9240:
---
TisonKun commented on a change in pull req
[
https://issues.apache.org/jira/browse/FLINK-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560921#comment-16560921
]
ASF GitHub Bot commented on FLINK-9240:
---
TisonKun commented on a change in pull req
[
https://issues.apache.org/jira/browse/FLINK-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560920#comment-16560920
]
ASF GitHub Bot commented on FLINK-9240:
---
TisonKun commented on a change in pull req
TisonKun commented on a change in pull request #6446: [FLINK-9240] Avoid
deprecated Akka methods
URL: https://github.com/apache/flink/pull/6446#discussion_r205956045
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/akka/DefaultQuarantineHandler.java
##
@
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560803#comment-16560803
]
Rong Rong edited comment on FLINK-5315 at 7/28/18 9:38 PM:
---
Hmm
[
https://issues.apache.org/jira/browse/FLINK-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560853#comment-16560853
]
ASF GitHub Bot commented on FLINK-9240:
---
chunjef opened a new pull request #6446: [
[
https://issues.apache.org/jira/browse/FLINK-9240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9240:
--
Labels: pull-request-available (was: )
> Avoid deprecated akka methods
> -
chunjef opened a new pull request #6446: [FLINK-9240] Avoid deprecated Akka
methods
URL: https://github.com/apache/flink/pull/6446
## What is the purpose of the change
This PR replaces the Akka methods that were deprecated in Akka 2.4 with
their respective non-deprecated alternative
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560803#comment-16560803
]
Rong Rong commented on FLINK-5315:
--
Hmm. Yes that's true we cannot have {{a.distinct}} b
[
https://issues.apache.org/jira/browse/FLINK-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560779#comment-16560779
]
xueyu commented on FLINK-9984:
--
I would like to work on this issue, it looks that I can't ch
[
https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560778#comment-16560778
]
dalongliu commented on FLINK-9825:
--
[~Zentol], [~mingleizhang],Thank you very much, I wi
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560764#comment-16560764
]
Hequn Cheng commented on FLINK-5315:
[~walterddr] Hi, I think the truth is we can nev
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560751#comment-16560751
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on a change in pull requ
yanghua commented on a change in pull request #6432: [FLINK-9970] Add ASCII/CHR
function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205942899
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFu
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-9970:
---
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-6810
> Add ASCII/CHR function for tabl
[
https://issues.apache.org/jira/browse/FLINK-8901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560739#comment-16560739
]
ASF GitHub Bot commented on FLINK-8901:
---
GJL commented on issue #5754: [FLINK-8901]
GJL commented on issue #5754: [FLINK-8901] [yarn] Set proper Yarn application
name
URL: https://github.com/apache/flink/pull/5754#issuecomment-408604547
@arukavytsia Can you open a new issue in JIRA? FLINK-8901 is already
resolved.
-
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560683#comment-16560683
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull re
hequn8128 commented on a change in pull request #6432: [FLINK-9970] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205938013
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Scalar
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560672#comment-16560672
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull re
hequn8128 commented on a change in pull request #6432: [FLINK-9970] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r205938013
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Scalar
[
https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560671#comment-16560671
]
ASF GitHub Bot commented on FLINK-8302:
---
xueyumusic opened a new pull request #6445
[
https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8302:
--
Labels: features pull-request-available (was: features)
> Support shift_left and shift_right i
xueyumusic opened a new pull request #6445: [FLINK-8302][Table API & SQL] Add
SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445
## What is the purpose of the change
This PR is based on the previous closed and unfinished work
https://github.com/apache/flink/pull/5
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560665#comment-16560665
]
Hequn Cheng commented on FLINK-6810:
Hi all, I added an instruction about how to cont
[
https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-6810:
---
Description:
In this JIRA, will create some sub-task for add specific scalar function, such
as mathe
79 matches
Mail list logo
