[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122141845 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator(

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122152659 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator(

[GitHub] flink pull request #:

Github user StefanRRichter commented on the pull request: https://github.com/apache/flink/commit/9141379f6d2654886d48154b453170cc23b89a87#commitcomment-22558757 In flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java: In

[jira] [Commented] (FLINK-6776) Use skip instead of seek for small forward repositioning in DFS streams

[ https://issues.apache.org/jira/browse/FLINK-6776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050180#comment-16050180 ] ASF GitHub Bot commented on FLINK-6776: --- Github user StefanRRichter closed the pull request at:

[jira] [Commented] (FLINK-6776) Use skip instead of seek for small forward repositioning in DFS streams

[ https://issues.apache.org/jira/browse/FLINK-6776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050179#comment-16050179 ] ASF GitHub Bot commented on FLINK-6776: --- Github user StefanRRichter commented on the issue:

[GitHub] flink pull request #:

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/9141379f6d2654886d48154b453170cc23b89a87#commitcomment-22558746 Good change, but I think this could use a guarding unit test. --- If your project is set up for it, you can reply to this

[GitHub] flink pull request #:

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/9141379f6d2654886d48154b453170cc23b89a87#commitcomment-22558742 In flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java: In

[GitHub] flink pull request #4019: [FLINK-6776] [runtime] Use skip instead of seek fo...

Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/4019 --- 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

[GitHub] flink issue #4019: [FLINK-6776] [runtime] Use skip instead of seek for small...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4019 Merged in 9141379f6d. --- 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

[jira] [Closed] (FLINK-6776) Use skip instead of seek for small forward repositioning in DFS streams

[ https://issues.apache.org/jira/browse/FLINK-6776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-6776. - Resolution: Implemented Fix Version/s: 1.4.0 Implemented in 9141379f6d > Use skip instead

[jira] [Commented] (FLINK-5659) FileBaseUtils#deleteFileOrDirectory not thread-safe on Windows

[ https://issues.apache.org/jira/browse/FLINK-5659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050158#comment-16050158 ] ASF GitHub Bot commented on FLINK-5659: --- Github user zentol closed the pull request at:

[GitHub] flink pull request #3219: [FLINK-5659] Harden FileBaseUtils#deleteFileOrDire...

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3219 --- 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

[jira] [Commented] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050157#comment-16050157 ] Tzu-Li (Gordon) Tai commented on FLINK-6928: I agree that the {{defaultTopic}} configuration

[jira] [Commented] (FLINK-6263) Leader error in Kafka producer on leader change (broker restart/failrue)

[ https://issues.apache.org/jira/browse/FLINK-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050152#comment-16050152 ] Tzu-Li (Gordon) Tai commented on FLINK-6263: Could you briefly describe how / when this error

[jira] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Description: When using a Kafka sink, the defaultTopic needs to exist even when it is never

[jira] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Description: When using a Kafka sink, the defaultTopic needs to exist even when it is never

[jira] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Summary: Kafka sink: default topic should not need to exist (was: Kafka source: default

[jira] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Description: When using a Kafka sink, the defaultTopic needs to exist even when it is never

[jira] [Assigned] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

[ https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-6773: - Assignee: Stefan Richter > Use compression (e.g. snappy) for full check/savepoints >

[jira] [Updated] (FLINK-6928) Kafka source: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Erik van Oosten updated FLINK-6928: --- Summary: Kafka source: default topic should not need to exist (was: Kafka source: default

[jira] [Created] (FLINK-6928) Kafka source: default topic needs to exist

Erik van Oosten created FLINK-6928: -- Summary: Kafka source: default topic needs to exist Key: FLINK-6928 URL: https://issues.apache.org/jira/browse/FLINK-6928 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6891) Add LOG supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6891: --- Description: LOG(X), LOG(B,X) If called with one parameter, this function returns the natural

[jira] [Updated] (FLINK-6891) Add LOG(X) supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6891: --- Summary: Add LOG(X) supported in SQL (was: Add LOG supported in SQL) > Add LOG(X) supported in SQL >

[jira] [Commented] (FLINK-6263) Leader error in Kafka producer on leader change (broker restart/failrue)

[ https://issues.apache.org/jira/browse/FLINK-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050148#comment-16050148 ] Konstantin Lalafaryan commented on FLINK-6263: -- What is the status of this bug ? We have the

[jira] [Commented] (FLINK-6836) Failing YARNSessionCapacitySchedulerITCase.testTaskManagerFailure

[ https://issues.apache.org/jira/browse/FLINK-6836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050134#comment-16050134 ] ASF GitHub Bot commented on FLINK-6836: --- Github user zentol commented on the issue:

[GitHub] flink issue #4120: [FLINK-6836] [tests] Fix YARNSessionCapacitySchedulerITCa...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4120 The PR descriptions says that you're downgrading the dependency versions, but with the second commit your actually upgrading them. Also, couldn't we move the dependency management into

[jira] [Created] (FLINK-6927) Support pattern group in CEP

Dian Fu created FLINK-6927: -- Summary: Support pattern group in CEP Key: FLINK-6927 URL: https://issues.apache.org/jira/browse/FLINK-6927 Project: Flink Issue Type: Bug Components: CEP

[jira] [Updated] (FLINK-6891) Add LOG supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6891: --- Description: LOG(X), LOG(B,X) If called with one parameter, this function returns the natural

[jira] [Created] (FLINK-6926) Add MD5/SHA1/SHA2 supported in SQL

sunjincheng created FLINK-6926: -- Summary: Add MD5/SHA1/SHA2 supported in SQL Key: FLINK-6926 URL: https://issues.apache.org/jira/browse/FLINK-6926 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6925) Add CONCAT/CONCAT_WS supported in SQL

sunjincheng created FLINK-6925: -- Summary: Add CONCAT/CONCAT_WS supported in SQL Key: FLINK-6925 URL: https://issues.apache.org/jira/browse/FLINK-6925 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #4129: [FLINK-6918] [tests] Harden AbstractOperatorRestoreTestBa...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4129 +1 to merge. --- 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

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050095#comment-16050095 ] ASF GitHub Bot commented on FLINK-6918: --- Github user zentol commented on the issue:

[jira] [Assigned] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-6918: Assignee: Till Rohrmann > Failing tests: ChainLengthDecreaseTest and

[GitHub] flink pull request #4129: [FLINK-6918] [tests] Harden AbstractOperatorRestor...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4129 [FLINK-6918] [tests] Harden AbstractOperatorRestoreTestBase by retrying CancelWithSavepoint messages The problem is that a StreamTask can be in state RUNNING without internally being running.

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050077#comment-16050077 ] ASF GitHub Bot commented on FLINK-6918: --- GitHub user tillrohrmann opened a pull request:

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050072#comment-16050072 ] Till Rohrmann commented on FLINK-6918: -- Once FLINK-4714 has been fixed, this issue should resolve as

[jira] [Commented] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

[ https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050068#comment-16050068 ] mingleizhang commented on FLINK-3387: - Hey, [~sbcd90] Are you still working on this yet ? > Replace

[jira] [Created] (FLINK-6924) ADD LOG/LPAD/RPAD/BIN supported in TableAPI

sunjincheng created FLINK-6924: -- Summary: ADD LOG/LPAD/RPAD/BIN supported in TableAPI Key: FLINK-6924 URL: https://issues.apache.org/jira/browse/FLINK-6924 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050066#comment-16050066 ] sunjincheng commented on FLINK-6895: Hi, [~wheat9] I noticed that you had opened a nice PR(4078).

[jira] [Assigned] (FLINK-6893) Add BIN supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6893: -- Assignee: sunjincheng > Add BIN supported in SQL > > >

[jira] [Updated] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6918: - Labels: test-stability (was: ) > Failing tests: ChainLengthDecreaseTest and

[jira] [Commented] (FLINK-6893) Add BIN supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050058#comment-16050058 ] ASF GitHub Bot commented on FLINK-6893: --- GitHub user sunjincheng121 opened a pull request:

[jira] [Commented] (FLINK-4602) Move RocksDB backend to proper package

[ https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050056#comment-16050056 ] mingleizhang commented on FLINK-4602: - [~Zentol] Oh. Thanks, I see. I will not do it until 2.0 should

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050057#comment-16050057 ] Till Rohrmann commented on FLINK-6918: -- Another instance: This time for the

[jira] [Updated] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6918: - Priority: Critical (was: Major) > Failing tests: ChainLengthDecreaseTest and

[GitHub] flink pull request #4128: [FLINK-6893][table]Add BIN supported in SQL

GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4128 [FLINK-6893][table]Add BIN supported in SQL In this PR. have Add BIN supported in SQL,e.g.: ``` BIN(12) -> "1100" BIN(10)-> "1010" ``` - [x] General - The pull

[jira] [Commented] (FLINK-4602) Move RocksDB backend to proper package

[ https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050045#comment-16050045 ] Chesnay Schepler commented on FLINK-4602: - [~mingleizhang] This issue is marked for 2.0 since it

[jira] [Commented] (FLINK-6602) Table source with defined time attributes allows empty string

[ https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050038#comment-16050038 ] Zhe Li commented on FLINK-6602: --- Fabian， I understand what you mean. So I modified the codes in

<    1   2