[GitHub] [flink] WeiZhong94 commented on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

WeiZhong94 commented on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-532529973 @dianfu Thanks a lot for the update.

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552 ## CI report: *

[jira] [Commented] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932080#comment-16932080 ] lining commented on FLINK-13987: Could you show your JIAR about it? > add new logs api, see more log

[jira] [Comment Edited] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931971#comment-16931971 ] lining edited comment on FLINK-13987 at 9/18/19 5:42 AM: - I have disscussed with

[jira] [Comment Edited] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931971#comment-16931971 ] lining edited comment on FLINK-13987 at 9/18/19 5:40 AM: - I hava disscussed with

[jira] [Comment Edited] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931971#comment-16931971 ] lining edited comment on FLINK-13987 at 9/18/19 5:39 AM: - I hava disscussed with

[jira] [Commented] (FLINK-13656) Upgrade Calcite dependency to 1.21

[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932076#comment-16932076 ] Kurt Young commented on FLINK-13656: [~danny0405] Would you like to take this issue? > Upgrade

[jira] [Commented] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932074#comment-16932074 ] Kurt Young commented on FLINK-14092: I think we should stick to FLINK-13656, I will close this one.

[jira] [Closed] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14092. -- Resolution: Duplicate > Upgrade Calcite version to 1.21 for Flink SQL >

[jira] [Comment Edited] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932070#comment-16932070 ] Zhu Zhu edited comment on FLINK-14037 at 9/18/19 5:26 AM: -- [~liupengcheng] I

[GitHub] [flink] dianfu commented on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

dianfu commented on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-532524299 @WeiZhong94 Thanks for the review. Make

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932070#comment-16932070 ] Zhu Zhu commented on FLINK-14037: - [~liupengcheng] I mocked this case by creating 2 jars. Jar1 contains

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[jira] [Commented] (FLINK-14093) Java8 lambdas and exceptions lead to compile error

[ https://issues.apache.org/jira/browse/FLINK-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932061#comment-16932061 ] TisonKun commented on FLINK-14093: -- [~zhaoshijie] We cannot just introduce the workaround without any

[jira] [Commented] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down

[ https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932059#comment-16932059 ] TisonKun commented on FLINK-14111: -- Yes I think it is a duplication of FLINK-10052. Could you check it

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[jira] [Comment Edited] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932058#comment-16932058 ] TisonKun edited comment on FLINK-14112 at 9/18/19 4:56 AM: --- Hi [~aaronlevin]

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932058#comment-16932058 ] TisonKun commented on FLINK-14112: -- Hi [~aaronlevin] thanks for creating this JIRA. Generally I think

[jira] [Commented] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932053#comment-16932053 ] TisonKun commented on FLINK-14109: -- Hi [~bremac] thanks for reporting this! There are two topics under

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932048#comment-16932048 ] Canbin Zheng commented on FLINK-14078: -- Thanks [~ykt836] ! > Introduce more JDBCDialect

[GitHub] [flink] flinkbot edited a comment on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor

flinkbot edited a comment on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor URL: https://github.com/apache/flink/pull/8546#issuecomment-532503099 ## CI report: * d3beb329bc438c726b0906ab8c97e02c084409b7 : FAILURE

[jira] [Commented] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932043#comment-16932043 ] Danny Chan commented on FLINK-14092: Thanks for the reminder [~twalthr], there indeed is a issue

[GitHub] [flink] zhijiangW commented on a change in pull request #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus

zhijiangW commented on a change in pull request #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus URL: https://github.com/apache/flink/pull/9483#discussion_r325477987 ## File path:

[jira] [Issue Comment Deleted] (FLINK-13708) transformations should be cleared because a table environment could execute multiple job

[ https://issues.apache.org/jira/browse/FLINK-13708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-13708: --- Comment: was deleted (was: Do you have sample code to reproduce this issue ? Because I don't see

[GitHub] [flink] flinkbot edited a comment on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor

flinkbot edited a comment on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor URL: https://github.com/apache/flink/pull/8546#issuecomment-532503099 ## CI report: * d3beb329bc438c726b0906ab8c97e02c084409b7 : PENDING

[GitHub] [flink] zhijiangW edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

zhijiangW edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-532503656 Sorry for missing the following comments. I agree with the general

[GitHub] [flink] zhijiangW commented on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

zhijiangW commented on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-532503656 Sorry for missing the following comments. I agree with the general above

[jira] [Commented] (FLINK-14037) Deserializing the input/output formats failed: unread block data

[ https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932012#comment-16932012 ] liupengcheng commented on FLINK-14037: -- [~zhuzh] Can you share your test code? Do you include

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932011#comment-16932011 ] Zijie Lu edited comment on FLINK-14099 at 9/18/19 3:30 AM: --- Maybe we can add a

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932011#comment-16932011 ] Zijie Lu edited comment on FLINK-14099 at 9/18/19 3:30 AM: --- Maybe we can add a

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932011#comment-16932011 ] Zijie Lu commented on FLINK-14099: -- Maybe we can add a parameter in the function timestampFromField

[GitHub] [flink] flinkbot commented on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor

flinkbot commented on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor URL: https://github.com/apache/flink/pull/8546#issuecomment-532503099 ## CI report: * d3beb329bc438c726b0906ab8c97e02c084409b7 : UNKNOWN

[GitHub] [flink] zhuzhurk edited a comment on issue #9688: [FLINK-13056] [runtime] Introduce FastRestartPipelinedRegionStrategy which has better failover handling performance at the cost of slower reg

zhuzhurk edited a comment on issue #9688: [FLINK-13056] [runtime] Introduce FastRestartPipelinedRegionStrategy which has better failover handling performance at the cost of slower region building and more memory used URL: https://github.com/apache/flink/pull/9688#issuecomment-532262379 >

[GitHub] [flink] TisonKun commented on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor

TisonKun commented on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor URL: https://github.com/apache/flink/pull/8546#issuecomment-532500733 ref #9643 and [FLINK-13961](https://issues.apache.org/jira/browse/FLINK-13961).

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932007#comment-16932007 ] Zijie Lu commented on FLINK-14099: -- I agree with [~felixzheng], So does the rowtime field only support

[jira] [Commented] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932004#comment-16932004 ] vinoyang commented on FLINK-13987: -- [~lining] Right, IMO, the existed implementation is not

[GitHub] [flink] flinkbot edited a comment on issue #9025: [FLINK-13149][Web Frontend] support configuration and update Angular to 8.0 version

flinkbot edited a comment on issue #9025: [FLINK-13149][Web Frontend] support configuration and update Angular to 8.0 version URL: https://github.com/apache/flink/pull/9025#issuecomment-512173118 ## CI report: * e2ae53781367b527fd4d77a4a63ae3b8f354a810 : FAILURE

[jira] [Commented] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932003#comment-16932003 ] Zijie Lu commented on FLINK-13746: -- Is  [Terror] logged in the $FLINK_DIR/log? In the travis log, *Test

[jira] [Updated] (FLINK-13149) improve flink ui to make it easier to be used by other projects

[ https://issues.apache.org/jira/browse/FLINK-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie TANG updated FLINK-13149: - Description: The new web UI looks nice, but there are still some problems when I try to integrate it

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931999#comment-16931999 ] Canbin Zheng edited comment on FLINK-14099 at 9/18/19 3:09 AM: --- I think

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931999#comment-16931999 ] Canbin Zheng edited comment on FLINK-14099 at 9/18/19 3:08 AM: --- I think

[jira] [Updated] (FLINK-13149) improve flink ui to make it easier to be used by other projects

[ https://issues.apache.org/jira/browse/FLINK-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jie TANG updated FLINK-13149: - Description: The new web UI looks nice, but there are still some problems when I try to integrate it

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931999#comment-16931999 ] Canbin Zheng commented on FLINK-14099: -- +1.  I think Computed column is a more general and better

[jira] [Assigned] (FLINK-14100) Introduce OracleDialect

[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14100: -- Assignee: Canbin Zheng > Introduce OracleDialect > --- > >

[jira] [Assigned] (FLINK-14102) Introduce DB2Dialect

[ https://issues.apache.org/jira/browse/FLINK-14102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14102: -- Assignee: Canbin Zheng > Introduce DB2Dialect > > >

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931993#comment-16931993 ] Kurt Young commented on FLINK-14078: Thanks [~felixzheng], I will assign these jiras to you. >

[jira] [Assigned] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14078: -- Assignee: Canbin Zheng > Introduce more JDBCDialect implementations >

[jira] [Assigned] (FLINK-14101) Introduce SqlServerDialect

[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14101: -- Assignee: Canbin Zheng > Introduce SqlServerDialect > -- > >

[GitHub] [flink] flinkbot edited a comment on issue #9025: [FLINK-13149][Web Frontend] support configuration and update Angular to 8.0 version

flinkbot edited a comment on issue #9025: [FLINK-13149][Web Frontend] support configuration and update Angular to 8.0 version URL: https://github.com/apache/flink/pull/9025#issuecomment-512173118 ## CI report: * e2ae53781367b527fd4d77a4a63ae3b8f354a810 : FAILURE

[GitHub] [flink] WeiZhong94 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunc

WeiZhong94 commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r325458729 ## File path:

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931980#comment-16931980 ] Canbin Zheng commented on FLINK-14078: -- Thanks for the quick response [~ykt836] ! I will add

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931977#comment-16931977 ] Zijie Lu commented on FLINK-14099: -- I use a kafka connector and describe a schema as rowtime which is

[GitHub] [flink] jinglining edited a comment on issue #9699: [FLINK-13949][rest]Delete deduplicating JobVertexDetailsInfo.VertexTa…

jinglining edited a comment on issue #9699: [FLINK-13949][rest]Delete deduplicating JobVertexDetailsInfo.VertexTa… URL: https://github.com/apache/flink/pull/9699#issuecomment-532483390 > Thanks for this PR @jinglining. LGTM. Have you tried whether the web UI is still displaying all

[jira] [Commented] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931971#comment-16931971 ] lining commented on FLINK-13987: I hava disscussed with till about that pr. It has updated for a long

[jira] [Issue Comment Deleted] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] apus66 updated FLINK-13856: --- Comment: was deleted (was: Hi [~StephanEwen] Can you help me review the code and assign this task to me?  

[GitHub] [flink] KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#discussion_r325453512 ## File path:

[jira] [Commented] (FLINK-14096) Merge NewClusterClient into ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931962#comment-16931962 ] TisonKun commented on FLINK-14096: -- FYI

[GitHub] [flink] jinglining commented on issue #9699: [FLINK-13949][rest]Delete deduplicating JobVertexDetailsInfo.VertexTa…

jinglining commented on issue #9699: [FLINK-13949][rest]Delete deduplicating JobVertexDetailsInfo.VertexTa… URL: https://github.com/apache/flink/pull/9699#issuecomment-532483390 > Thanks for this PR @jinglining. LGTM. Have you tried whether the web UI is still displaying all subtask

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931960#comment-16931960 ] Kurt Young commented on FLINK-14078: I think split into some subtasks is a good idea. Even if there

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931959#comment-16931959 ] Canbin Zheng commented on FLINK-14078: -- [~ykt836]  [~lzljs3620320] Yes, so there's no need to split

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931955#comment-16931955 ] Jingsong Lee commented on FLINK-14078: -- > Just want to clarify, does this only take effect to JDBC

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931954#comment-16931954 ] Jingsong Lee commented on FLINK-14099: -- The problem I've encountered is that I want to mark a

[jira] [Created] (FLINK-14113) Remove class JobWithJars

TisonKun created FLINK-14113: Summary: Remove class JobWithJars Key: FLINK-14113 URL: https://issues.apache.org/jira/browse/FLINK-14113 Project: Flink Issue Type: Sub-task Components:

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931944#comment-16931944 ] Kurt Young commented on FLINK-14078: Just want to clarify, does this only take effect to JDBC

[jira] [Commented] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931917#comment-16931917 ] Timo Walther commented on FLINK-14092: -- [~danny0405] can you check if this is a duplicate issue?

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931915#comment-16931915 ] Timo Walther commented on FLINK-14099: -- Could you share a use case/example with us? Actually, we

[jira] [Commented] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down

[ https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931901#comment-16931901 ] Elias Levy commented on FLINK-14111: Probable related to FLINK-10052. > Flink should be robust to

[jira] [Created] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

Aaron Levin created FLINK-14112: --- Summary: Removing zookeeper state should cause the task manager and job managers to restart Key: FLINK-14112 URL: https://issues.apache.org/jira/browse/FLINK-14112

[jira] [Created] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down

Aaron Levin created FLINK-14111: --- Summary: Flink should be robust to a non-leader Zookeeper host going down Key: FLINK-14111 URL: https://issues.apache.org/jira/browse/FLINK-14111 Project: Flink

[jira] [Updated] (FLINK-14110) Deleting state.backend.rocksdb.localdir causes silent failure

[ https://issues.apache.org/jira/browse/FLINK-14110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aaron Levin updated FLINK-14110: Description: Suppose {{state.backend.rocksdb.localdir}} is configured as: {noformat}

[jira] [Created] (FLINK-14110) Deleting state.backend.rocksdb.localdir causes silent failure

Aaron Levin created FLINK-14110: --- Summary: Deleting state.backend.rocksdb.localdir causes silent failure Key: FLINK-14110 URL: https://issues.apache.org/jira/browse/FLINK-14110 Project: Flink

[jira] [Updated] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brendan MacDonell updated FLINK-14109: -- Description: My team at Sight Machine just finished building a custom HA backend for

[jira] [Created] (FLINK-14109) Improve javadocs and tests for high-availability backend

Brendan MacDonell created FLINK-14109: - Summary: Improve javadocs and tests for high-availability backend Key: FLINK-14109 URL: https://issues.apache.org/jira/browse/FLINK-14109 Project: Flink

[jira] [Updated] (FLINK-14107) Kinesis consumer record emitter deadlock under event time alignment

[ https://issues.apache.org/jira/browse/FLINK-14107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-14107: - Summary: Kinesis consumer record emitter deadlock under event time alignment (was: Kinesis

[jira] [Commented] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931775#comment-16931775 ] Jeffrey Martin commented on FLINK-14076: Confirmed: the issue is that

[GitHub] [flink] flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702#issuecomment-532344762 ## CI report: * b5d14cefce1ec689f991fcc0e02bb229195f4418 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702#issuecomment-532344762 ## CI report: * b5d14cefce1ec689f991fcc0e02bb229195f4418 : PENDING

[GitHub] [flink] yxu-valleytider commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

yxu-valleytider commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-532348389 @kl0u Agree with most of the review comments. Just

[GitHub] [flink] jgrier commented on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

jgrier commented on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702#issuecomment-532347487 @flinkbot approve all This is

[GitHub] [flink] flinkbot commented on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702#issuecomment-532344762 ## CI report: * b5d14cefce1ec689f991fcc0e02bb229195f4418 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation URL: https://github.com/apache/flink/pull/9691#issuecomment-531758345 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9673: [FLINK-14031][examples][table]Added the blink planner dependency and …

flinkbot edited a comment on issue #9673: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9673#issuecomment-530444375 ## CI report: * e7868053366c8881900ae4740519c8d1487d0e91 : SUCCESS

[jira] [Commented] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931732#comment-16931732 ] Zhenqiu Huang commented on FLINK-14033: --- Agree. It is not for a jar. The issue happens on another

[GitHub] [flink] tweise commented on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise commented on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702#issuecomment-532339408 @haltwise PTAL. I added a unit test on top of the changes we tested yesterday.

[GitHub] [flink] flinkbot commented on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702#issuecomment-532338878 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-14107) Kinesis consumer record emitter may deadlock under event time alignment

[ https://issues.apache.org/jira/browse/FLINK-14107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14107: --- Labels: pull-request-available (was: ) > Kinesis consumer record emitter may deadlock

[GitHub] [flink] tweise opened a new pull request #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise opened a new pull request #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702 ## What is the purpose of the change When the emitter reaches the max timestamp for the current queue, it

[jira] [Commented] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931704#comment-16931704 ] Jeffrey Martin commented on FLINK-14076: It looks like this is due to a KafkaException getting

[jira] [Created] (FLINK-14108) Support for Confluent Kafka schema registry for Avro serialisation

Lasse Nedergaard created FLINK-14108: - Summary: Support for Confluent Kafka schema registry for Avro serialisation Key: FLINK-14108 URL: https://issues.apache.org/jira/browse/FLINK-14108

[jira] [Assigned] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-14055: -- Assignee: Zhenqiu Huang > Add advanced function DDL syntax "USING JAR/FILE/ACHIVE" >

[GitHub] [flink] flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation URL: https://github.com/apache/flink/pull/9691#issuecomment-531758345 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#issuecomment-530686777 ## CI report: * d15f9751632d4c7897f68a0f8829d5facbdfe14e : SUCCESS

[jira] [Comment Edited] (FLINK-14098) Support multiple sql statements splitting by semicolon for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931685#comment-16931685 ] Xuefu Zhang edited comment on FLINK-14098 at 9/17/19 5:34 PM: -- Yeah, this

[GitHub] [flink] flinkbot edited a comment on issue #9673: [FLINK-14031][examples][table]Added the blink planner dependency and …

flinkbot edited a comment on issue #9673: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9673#issuecomment-530444375 ## CI report: * e7868053366c8881900ae4740519c8d1487d0e91 : SUCCESS

[jira] [Commented] (FLINK-14098) Support multiple sql statements splitting by semicolon for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931685#comment-16931685 ] Xuefu Zhang commented on FLINK-14098: - Yeah, this is indeed a dupe of FLINK-12845, but thanks for

[GitHub] [flink] zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#discussion_r325292832 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#discussion_r325292832 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus

pnowojski commented on a change in pull request #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus URL: https://github.com/apache/flink/pull/9483#discussion_r325290219 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation

flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation URL: https://github.com/apache/flink/pull/9691#issuecomment-531758345 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9673: [FLINK-14031][examples][table]Added the blink planner dependency and …

flinkbot edited a comment on issue #9673: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9673#issuecomment-530444375 ## CI report: * e7868053366c8881900ae4740519c8d1487d0e91 : SUCCESS

  1   2   3   4   >