[GitHub] flink pull request #5619: [FLINK-8838] [table] Add Support for UNNEST a Mult...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/5619#discussion_r189914232 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala --- @@ -18,74 +18,143 @@ package

[jira] [Commented] (FLINK-8838) Add Support for UNNEST a MultiSet type field

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

[GitHub] flink issue #5619: [FLINK-8838] [table] Add Support for UNNEST a MultiSet ty...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5619 Thanks for updating the PR @lincoln-lil. I found one minor issue. I think this PR is ok for merging I will fix my comment while merging. ---

[jira] [Commented] (FLINK-9408) Retry JM-RM connection in case of explicit disconnect

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

[GitHub] flink pull request #6056: [FLINK-9408] Let JM try to reconnect to RM

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6056 [FLINK-9408] Let JM try to reconnect to RM ## What is the purpose of the change This commit changes the behaviour of the JM to always try to reconnect to the latest known RM address.

[jira] [Created] (FLINK-9408) Retry JM-RM connection in case of explicit disconnect

Till Rohrmann created FLINK-9408: Summary: Retry JM-RM connection in case of explicit disconnect Key: FLINK-9408 URL: https://issues.apache.org/jira/browse/FLINK-9408 Project: Flink Issue

[jira] [Commented] (FLINK-8511) Remove legacy code for the TableType annotation

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

[GitHub] flink pull request #6055: [FLINK-8511][table] Remove legacy code for the Tab...

GitHub user kisimple opened a pull request: https://github.com/apache/flink/pull/6055 [FLINK-8511][table] Remove legacy code for the TableType annotation ## What is the purpose of the change TableSource factories had already been used to unify the definition of table

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483965#comment-16483965 ] Timo Walther commented on FLINK-9219: - What I meant was something like: {code} public class

[jira] [Commented] (FLINK-8986) End-to-end test: REST

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

[jira] [Commented] (FLINK-8986) End-to-end test: REST

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

[GitHub] flink issue #5849: [FLINK-8986][e2e-test][WIP] Flink end to end test REST AP...

Github user walterddr commented on the issue: https://github.com/apache/flink/pull/5849 Thanks @tzulitai for the suggestion. I will close this and continue with the new PR in #6054 . ---

[GitHub] flink pull request #5849: [FLINK-8986][e2e-test][WIP] Flink end to end test ...

Github user walterddr closed the pull request at: https://github.com/apache/flink/pull/5849 ---

[jira] [Commented] (FLINK-8986) End-to-end test: REST

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

[jira] [Created] (FLINK-9407) Support orc rolling sink writer

mingleizhang created FLINK-9407: --- Summary: Support orc rolling sink writer Key: FLINK-9407 URL: https://issues.apache.org/jira/browse/FLINK-9407 Project: Flink Issue Type: New Feature

[GitHub] flink pull request #6054: [FLINK-8986][e2e-test] Flink end to end test REST ...

GitHub user walterddr opened a pull request: https://github.com/apache/flink/pull/6054 [FLINK-8986][e2e-test] Flink end to end test REST API ## What is the purpose of the change Adding end to end test for REST APIs for FLIP-6 generated endpoints. *This is a follow

[jira] [Commented] (FLINK-7814) Add BETWEEN and NOT BETWEEN expression to Table API

[ https://issues.apache.org/jira/browse/FLINK-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483930#comment-16483930 ] ASF GitHub Bot commented on FLINK-7814: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-7814) Add BETWEEN and NOT BETWEEN expression to Table API

[ https://issues.apache.org/jira/browse/FLINK-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483929#comment-16483929 ] ASF GitHub Bot commented on FLINK-7814: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-7814) Add BETWEEN and NOT BETWEEN expression to Table API

[ https://issues.apache.org/jira/browse/FLINK-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483931#comment-16483931 ] ASF GitHub Bot commented on FLINK-7814: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6027: [FLINK-7814][TableAPI && SQL] Add BETWEEN and NOT ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6027#discussion_r189896704 --- Diff: docs/dev/table/tableApi.md --- @@ -1885,6 +1885,32 @@ BOOLEAN.isNotFalse + + +{%

[GitHub] flink pull request #6027: [FLINK-7814][TableAPI && SQL] Add BETWEEN and NOT ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6027#discussion_r189895702 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/logic.scala --- @@ -105,3 +105,75 @@ case class If( }

[GitHub] flink pull request #6027: [FLINK-7814][TableAPI && SQL] Add BETWEEN and NOT ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6027#discussion_r189895031 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/ExpressionParser.scala --- @@ -210,6 +212,14 @@ object

[jira] [Commented] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

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

[GitHub] flink issue #6049: [FLINK-9398][Client] Fix CLI list running job returns all...

Github user walterddr commented on the issue: https://github.com/apache/flink/pull/6049 @zentol yeah, I totally agree with the naming issue and just updated with a more clear `ListOptions` definitions. Please take another look. Thanks ---

[jira] [Commented] (FLINK-9378) Improve TableException message with TypeName usage

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

[GitHub] flink issue #6032: [FLINK-9378][Table API & SQL] Improve TableException mess...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6032 Thanks for the PR @snuyanzin. However, I think we should not change the exception string but should improve the `org.apache.flink.api.common.typeinfo.SqlTimeTypeInfo#toString` method instead.

[jira] [Commented] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

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

[GitHub] flink issue #6053: [FLINK-9257][E2E Tests] Fix wrong "All tests pass" messag...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6053 I'll take a look tomorrow. ---

[GitHub] flink pull request #6036: [hotfix] [types] Expose type extraction error for ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6036 ---

[GitHub] flink issue #6036: [hotfix] [types] Expose type extraction error for fromEle...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6036 Merging... ---

[jira] [Resolved] (FLINK-6909) Fix error message in CsvReader for wrong type class

[ https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6909. - Resolution: Fixed Fix Version/s: 1.4.3 1.5.0 Fixed in 1.6.0:

[jira] [Commented] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

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

[GitHub] flink issue #6053: [FLINK-9257][E2E Tests] Fix wrong "All tests pass" messag...

Github user florianschmidt1994 commented on the issue: https://github.com/apache/flink/pull/6053 @zentol Maybe you could have a look at this? ---

[jira] [Updated] (FLINK-6909) Fix error message in CsvReader for wrong type class

[ https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6909: Summary: Fix error message in CsvReader for wrong type class (was: Flink should support Lombok

[jira] [Commented] (FLINK-6909) Flink should support Lombok POJO

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

[GitHub] flink pull request #6037: [FLINK-6909] [types] Fix error message in CsvReade...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6037 ---

[jira] [Commented] (FLINK-6909) Flink should support Lombok POJO

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

[GitHub] flink issue #6037: [FLINK-6909] [types] Fix error message in CsvReader for w...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6037 Merging... ---

[jira] [Commented] (FLINK-6909) Flink should support Lombok POJO

[ https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483887#comment-16483887 ] ASF GitHub Bot commented on FLINK-6909: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6037: [FLINK-6909] [types] Fix error message in CsvReade...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6037#discussion_r189885082 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/io/CsvReader.java --- @@ -316,14 +317,18 @@ public CsvReader ignoreInvalidLines(){

[jira] [Commented] (FLINK-6909) Flink should support Lombok POJO

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

[jira] [Commented] (FLINK-6909) Flink should support Lombok POJO

[ https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483868#comment-16483868 ] Timo Walther commented on FLINK-6909: - Tests for Lombok POJOs have been added in 1.6.0:

[GitHub] flink pull request #6033: [FLINK-6909] [types] Add tests for Lombok POJOs

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6033 ---

[jira] [Commented] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

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

[GitHub] flink pull request #6053: [FLINK-9257][E2E Tests] Fix wrong "All tests pass"...

GitHub user florianschmidt1994 opened a pull request: https://github.com/apache/flink/pull/6053 [FLINK-9257][E2E Tests] Fix wrong "All tests pass" message ## What is the purpose of the change Fix a wrongly printed "All tests PASS" message when they actually don't"

[jira] [Commented] (FLINK-6909) Flink should support Lombok POJO

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

[GitHub] flink issue #6033: [FLINK-6909] [types] Add tests for Lombok POJOs

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6033 Thank you @zentol. Merging... ---

[jira] [Commented] (FLINK-8429) Implement stream-stream non-window right outer join

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

[GitHub] flink pull request #6046: [FLINK-8429] Implement stream-stream non-window ri...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6046 ---

[jira] [Resolved] (FLINK-8429) Implement stream-stream non-window right outer join

[ https://issues.apache.org/jira/browse/FLINK-8429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8429. - Resolution: Fixed Fix Version/s: 1.6.0 Fixed in 1.6.0:

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

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

[GitHub] flink issue #5991: [FLINK-9303] [kafka] Adding support for unassign dynamica...

Github user EAlexRojas commented on the issue: https://github.com/apache/flink/pull/5991 PR updated taking into account comments ---

[jira] [Commented] (FLINK-8429) Implement stream-stream non-window right outer join

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

[GitHub] flink issue #6046: [FLINK-8429] Implement stream-stream non-window right out...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6046 Thank you @hequn8128 for the good test coverage. The changes look good to me. I will merge this... ---

[jira] [Closed] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-9295. - Resolution: Fixed [~facboy] I'm closing the issue. Once 1.5.0 is released, you can make sure that

[jira] [Updated] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9295: -- Fix Version/s: (was: 1.5.1) 1.5.0 > FlinkKafkaProducer011 sometimes

[jira] [Updated] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9295: -- Fix Version/s: (was: 1.6.0) > FlinkKafkaProducer011 sometimes throws

[jira] [Reopened] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-9295: --- > FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in > EXACTLY_ONCE mode >

[jira] [Closed] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-9295. - > FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in > EXACTLY_ONCE mode >

[jira] [Commented] (FLINK-9387) Several log message errors in queryable-state module

[ https://issues.apache.org/jira/browse/FLINK-9387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483784#comment-16483784 ] ASF GitHub Bot commented on FLINK-9387: --- Github user yanghua commented on a diff in the pull

[GitHub] flink pull request #6029: [FLINK-9387] Several log message errors in queryab...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6029#discussion_r189858273 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java --- @@

[jira] [Commented] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

[ https://issues.apache.org/jira/browse/FLINK-9326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483779#comment-16483779 ] ASF GitHub Bot commented on FLINK-9326: --- Github user yanghua commented on a diff in the pull

[GitHub] flink pull request #6041: [FLINK-9326] TaskManagerOptions.NUM_TASK_SLOTS doe...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6041#discussion_r189856924 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java --- @@ -103,9 +103,16 @@ public

[jira] [Created] (FLINK-9406) Request finished partition state fails due to referential equality comparison

Till Rohrmann created FLINK-9406: Summary: Request finished partition state fails due to referential equality comparison Key: FLINK-9406 URL: https://issues.apache.org/jira/browse/FLINK-9406 Project:

[jira] [Resolved] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9295. Resolution: Fixed Fix Version/s: (was: 1.5.0) 1.5.1

[jira] [Assigned] (FLINK-8225) Use JsonRowDeserializationSchema without Kafka connector dependency

[ https://issues.apache.org/jira/browse/FLINK-8225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] blues zheng reassigned FLINK-8225: -- Assignee: blues zheng > Use JsonRowDeserializationSchema without Kafka connector dependency >

[jira] [Assigned] (FLINK-8379) Improve type checking for DataView

[ https://issues.apache.org/jira/browse/FLINK-8379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] blues zheng reassigned FLINK-8379: -- Assignee: blues zheng > Improve type checking for DataView >

[GitHub] flink pull request #6051: [hotfix][DateTimeBucketer] modify the bucket path ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6051 ---

[GitHub] flink issue #6051: [hotfix][DateTimeBucketer] modify the bucket path in the ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6051 ah right, my bad. merging. ---

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483724#comment-16483724 ] Timo Walther commented on FLINK-8863: - Hi [~xccui], 1. scalar functions have no generic type

[jira] [Assigned] (FLINK-8954) Escape control characters when outputting on SQL Client CLI

[ https://issues.apache.org/jira/browse/FLINK-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] blues zheng reassigned FLINK-8954: -- Assignee: blues zheng > Escape control characters when outputting on SQL Client CLI >

[GitHub] flink issue #6050: [FLINK-9404][flink-connector-filesystem] Adapter viewfs i...

Github user maqingxiang commented on the issue: https://github.com/apache/flink/pull/6050 cc @tzulitai ---

[jira] [Commented] (FLINK-9404) Adapter viewfs in BucketingSink when verify that truncate actually works

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

[jira] [Commented] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

[ https://issues.apache.org/jira/browse/FLINK-9326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16483716#comment-16483716 ] ASF GitHub Bot commented on FLINK-9326: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #6041: [FLINK-9326] TaskManagerOptions.NUM_TASK_SLOTS doe...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6041#discussion_r189836110 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java --- @@ -103,9 +103,16 @@ public

[GitHub] flink issue #6051: [hotfix][DateTimeBucketer] modify the bucket path in the ...

Github user maqingxiang commented on the issue: https://github.com/apache/flink/pull/6051 The schema on this page:[https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/filesystem_sink.html](

[jira] [Resolved] (FLINK-9316) Expose operator unique ID to the user defined functions in DataStream .

[ https://issues.apache.org/jira/browse/FLINK-9316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9316. Resolution: Fixed Fix Version/s: (was: 1.5.0) 1.5.1

[jira] [Resolved] (FLINK-9372) Typo on Elasticsearch website link (elastic.io --> elastic.co)

[ https://issues.apache.org/jira/browse/FLINK-9372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9372. Resolution: Fixed Fix Version/s: 1.5.1 1.6.0 Merged, via

[jira] [Closed] (FLINK-9008) End-to-end test: Quickstarts

[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9008. -- > End-to-end test: Quickstarts > > > Key:

[jira] [Resolved] (FLINK-9008) End-to-end test: Quickstarts

[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9008. Resolution: Fixed Merged, via 1.6.0 - 5093122804f481021f3b33d9d5b4da2144c8cc61

[jira] [Closed] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8989. -- > End-to-end test: ElasticSearch connector > > >

[jira] [Updated] (FLINK-9008) End-to-end test: Quickstarts

[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9008: --- Fix Version/s: 1.5.1 > End-to-end test: Quickstarts > >

[jira] [Resolved] (FLINK-8989) End-to-end test: ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8989. Resolution: Fixed Fix Version/s: 1.5.1 1.6.0 Merged, via

[jira] [Resolved] (FLINK-8977) End-to-end test: Manually resume job after terminal failure

[ https://issues.apache.org/jira/browse/FLINK-8977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8977. Resolution: Fixed Merged, via 1.6.0 - 97a66388522db25ef03655c25311a05f92204d35

[jira] [Closed] (FLINK-8977) End-to-end test: Manually resume job after terminal failure

[ https://issues.apache.org/jira/browse/FLINK-8977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8977. -- > End-to-end test: Manually resume job after terminal failure >

[jira] [Closed] (FLINK-9320) Update `test-ha.sh` end-to-end test to use general purpose DataStream job

[ https://issues.apache.org/jira/browse/FLINK-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9320. -- > Update `test-ha.sh` end-to-end test to use general purpose DataStream job >

[jira] [Closed] (FLINK-9322) Add exception throwing map function that simulates failures to the general purpose DataStream job

[ https://issues.apache.org/jira/browse/FLINK-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9322. -- > Add exception throwing map function that simulates failures to the general > purpose

[jira] [Resolved] (FLINK-9320) Update `test-ha.sh` end-to-end test to use general purpose DataStream job

[ https://issues.apache.org/jira/browse/FLINK-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9320. Resolution: Fixed Merged, via 1.6.0 - 5ee9100c613e0639787aa3da7e6ef2bcadce0932

[jira] [Closed] (FLINK-8996) Include an operator with broadcast and union state

[ https://issues.apache.org/jira/browse/FLINK-8996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8996. -- > Include an operator with broadcast and union state >

[jira] [Updated] (FLINK-8996) Include an operator with broadcast and union state

[ https://issues.apache.org/jira/browse/FLINK-8996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8996: --- Fix Version/s: 1.6.0 > Include an operator with broadcast and union state >

[jira] [Resolved] (FLINK-9322) Add exception throwing map function that simulates failures to the general purpose DataStream job

[ https://issues.apache.org/jira/browse/FLINK-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9322. Resolution: Fixed Fix Version/s: 1.5.1 1.6.0 Merged, via:

[jira] [Updated] (FLINK-8996) Include an operator with broadcast and union state

[ https://issues.apache.org/jira/browse/FLINK-8996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8996: --- Fix Version/s: 1.5.1 > Include an operator with broadcast and union state >

[jira] [Resolved] (FLINK-8996) Include an operator with broadcast and union state

[ https://issues.apache.org/jira/browse/FLINK-8996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8996. Resolution: Fixed Merged, via: 1.6.0 - 135b32951a02a80ec785ede7cf245b61a5ee891a

[GitHub] flink pull request #5761: [FLINK-8989] [e2eTests] Elasticsearch1&2&5 end to ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5761 ---

[GitHub] flink pull request #6018: [FLINK-9372] Typo on Elasticsearch website link (e...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6018 ---

[GitHub] flink pull request #6004: [FLINK-8977] [e2e] End-to-end test for manual job ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6004 ---

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

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

[jira] [Commented] (FLINK-8971) Create general purpose testing job

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

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

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

[jira] [Commented] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

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

<    1   2   3   >