[jira] [Assigned] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID

2018-03-12 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei reassigned FLINK-4817: -- Assignee: (was: Wei-Che Wei) > Checkpoint Coordinator should be called to restore state wit

[jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work

2018-03-12 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396500#comment-16396500 ] aitozi commented on FLINK-8914: --- Yes, i run into this bug too, greedy only works when it has

[jira] [Commented] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396491#comment-16396491 ] ASF GitHub Bot commented on FLINK-8919: --- Github user liurenjie1024 commented on the

[GitHub] flink issue #5680: [FLINK-8919] Add KeyedProcessFunctionWithCleanupState.

2018-03-12 Thread liurenjie1024
Github user liurenjie1024 commented on the issue: https://github.com/apache/flink/pull/5680 @bowenli86 This is a trivial change and most the code is copied from the non keyed counterpart, so I don't think we need a test. ---

[jira] [Created] (FLINK-8933) Avoid calling Class#newInstance

2018-03-12 Thread Ted Yu (JIRA)
Ted Yu created FLINK-8933: - Summary: Avoid calling Class#newInstance Key: FLINK-8933 URL: https://issues.apache.org/jira/browse/FLINK-8933 Project: Flink Issue Type: Task Reporter: Ted Yu

[jira] [Commented] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396383#comment-16396383 ] ASF GitHub Bot commented on FLINK-8623: --- Github user zhangminglei commented on the i

[GitHub] flink issue #5449: [FLINK-8623] ConnectionUtilsTest.testReturnLocalHostAddre...

2018-03-12 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5449 Hi, @NicoK . I think ```InetAddress.getAllByName("localhost")``` wont work since we still give the specific hostname for that. And it will return a loopback address. ---

[jira] [Commented] (FLINK-8917) FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396373#comment-16396373 ] ASF GitHub Bot commented on FLINK-8917: --- GitHub user jianran opened a pull request:

[GitHub] flink pull request #5686: [FLINK-8917] [Job-Submission] FlinkMiniCluster def...

2018-03-12 Thread jianran
GitHub user jianran opened a pull request: https://github.com/apache/flink/pull/5686 [FLINK-8917] [Job-Submission] FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient ## What is the purpose of the change the FlinkMiniCluster used Hi

[jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes

2018-03-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16345955#comment-16345955 ] Ted Yu edited comment on FLINK-7795 at 3/13/18 1:27 AM: error-pron

[jira] [Updated] (FLINK-8708) Unintended integer division in StandaloneThreadedGenerator

2018-03-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8708: -- Description: In flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/state

[jira] [Commented] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396194#comment-16396194 ] ASF GitHub Bot commented on FLINK-7521: --- Github user GJL commented on the issue:

[GitHub] flink issue #5685: [FLINK-7521][flip6] Remove the 10MB limit from the curren...

2018-03-12 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5685 Maybe docs should be updated. ---

[jira] [Commented] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396188#comment-16396188 ] ASF GitHub Bot commented on FLINK-7521: --- GitHub user GJL opened a pull request:

[GitHub] flink pull request #5685: [FLINK-7521][flip6]

2018-03-12 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5685 [FLINK-7521][flip6] ## What is the purpose of the change *Make HTTP request and response limits configurable. A relatively high default value is chosen (100 mb) because Netty does not allocate

[jira] [Closed] (FLINK-8927) Eagerly release the checkpoint object created from RocksDB

2018-03-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8927. - Resolution: Fixed Merged in 3debf47e5d. > Eagerly release the checkpoint object created from Rock

[GitHub] flink pull request #5682: [FLINK-8927][state] Eagerly release the checkpoint...

2018-03-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5682 ---

[jira] [Commented] (FLINK-8927) Eagerly release the checkpoint object created from RocksDB

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16396103#comment-16396103 ] ASF GitHub Bot commented on FLINK-8927: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395867#comment-16395867 ] ASF GitHub Bot commented on FLINK-8919: --- Github user bowenli86 commented on the issu

[GitHub] flink issue #5680: [FLINK-8919] Add KeyedProcessFunctionWithCleanupState.

2018-03-12 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5680 shall we add a unit test? ---

[jira] [Updated] (FLINK-8932) Mesos taskmanager should reserve port for query server

2018-03-12 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jared Stehler updated FLINK-8932: - Description: Currently the LaunchableMesosWorker doesn't reserve a port for the query server, mak

[jira] [Created] (FLINK-8932) Mesos taskmanager should reserve port for query server

2018-03-12 Thread Jared Stehler (JIRA)
Jared Stehler created FLINK-8932: Summary: Mesos taskmanager should reserve port for query server Key: FLINK-8932 URL: https://issues.apache.org/jira/browse/FLINK-8932 Project: Flink Issue Ty

[jira] [Created] (FLINK-8931) TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled

2018-03-12 Thread Ted Yu (JIRA)
Ted Yu created FLINK-8931: - Summary: TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled Key: FLINK-8931 URL: https://issues.apache.org/jira/browse/FLINK-8931 Project: Flink Issue Type

[jira] [Comment Edited] (FLINK-7588) Document RocksDB tuning for spinning disks

2018-03-12 Thread Ted Yu (JIRA)
[ 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 3/12/18 7:26 PM: bq. Be car

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395641#comment-16395641 ] ASF GitHub Bot commented on FLINK-6924: --- Github user buptljy commented on a diff in

[GitHub] flink pull request #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAP...

2018-03-12 Thread buptljy
Github user buptljy commented on a diff in the pull request: https://github.com/apache/flink/pull/5638#discussion_r173897783 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala --- @@ -1130,4 +1130,13 @@ object concat_ws {

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395620#comment-16395620 ] ASF GitHub Bot commented on FLINK-6924: --- Github user buptljy commented on the issue:

[GitHub] flink issue #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAPI

2018-03-12 Thread buptljy
Github user buptljy commented on the issue: https://github.com/apache/flink/pull/5638 @walterddr I'm not able to add a validation test because I am blocked by [FLINK-8930](https://issues.apache.org/jira/browse/FLINK-8930). ---

[jira] [Created] (FLINK-8930) TableApi validation test in ScalarFunctionsValidationTest doesn't work

2018-03-12 Thread Wind (JIRA)
Wind created FLINK-8930: --- Summary: TableApi validation test in ScalarFunctionsValidationTest doesn't work Key: FLINK-8930 URL: https://issues.apache.org/jira/browse/FLINK-8930 Project: Flink Issue Typ

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395581#comment-16395581 ] ASF GitHub Bot commented on FLINK-8854: --- Github user xccui commented on a diff in th

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-12 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5662#discussion_r173888555 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java --- @

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395565#comment-16395565 ] ASF GitHub Bot commented on FLINK-6924: --- Github user buptljy commented on the issue:

[GitHub] flink issue #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAPI

2018-03-12 Thread buptljy
Github user buptljy commented on the issue: https://github.com/apache/flink/pull/5638 @suez1224 Docs are added in both java and scala. ---

[jira] [Commented] (FLINK-8537) Add a Kafka table source factory with Avro format support

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395562#comment-16395562 ] ASF GitHub Bot commented on FLINK-8537: --- Github user xccui commented on the issue:

[GitHub] flink issue #5610: [FLINK-8537][table]Add a Kafka table source factory with ...

2018-03-12 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5610 Hi @twalthr, I've rebased this PR and fixed some problems. ---

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395556#comment-16395556 ] ASF GitHub Bot commented on FLINK-8854: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-12 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/5662#discussion_r173881141 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java ---

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395545#comment-16395545 ] ASF GitHub Bot commented on FLINK-8854: --- Github user xccui commented on a diff in th

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-12 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5662#discussion_r173879267 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java --- @

[jira] [Commented] (FLINK-8783) Test instability SlotPoolRpcTest.testExtraSlotsAreKept

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395525#comment-16395525 ] ASF GitHub Bot commented on FLINK-8783: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5684: [FLINK-8783] [tests] Harden SlotPoolRpcTest

2018-03-12 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5684 [FLINK-8783] [tests] Harden SlotPoolRpcTest ## What is the purpose of the change Wait for releasing of timed out pending slot requests before checking the number of pending slots re

[jira] [Created] (FLINK-8929) "UnknownTaskExecutorException: No TaskExecutor registered" when having tab open for taskmanager that does not exist (anymore)

2018-03-12 Thread Florian Schmidt (JIRA)
Florian Schmidt created FLINK-8929: -- Summary: "UnknownTaskExecutorException: No TaskExecutor registered" when having tab open for taskmanager that does not exist (anymore) Key: FLINK-8929 URL: https://issues.apac

[jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536)

2018-03-12 Thread Steve Loughran (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395479#comment-16395479 ] Steve Loughran commented on FLINK-7589: --- We've been thinking of cutting a shaded ver

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-12 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/5662#discussion_r173863375 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java ---

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395476#comment-16395476 ] ASF GitHub Bot commented on FLINK-8854: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-8795) Scala shell broken for Flip6

2018-03-12 Thread Kedar Mhaswade (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395472#comment-16395472 ] Kedar Mhaswade commented on FLINK-8795: --- Thanks [~Zentol]! I can confirm that the wo

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395467#comment-16395467 ] ASF GitHub Bot commented on FLINK-8854: --- Github user xccui commented on a diff in th

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-12 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5662#discussion_r173860901 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java --- @

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395455#comment-16395455 ] ASF GitHub Bot commented on FLINK-8854: --- Github user xccui commented on a diff in th

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-12 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5662#discussion_r173857218 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala --- @@ -148,6 +148,13 @@ object SchemaValidator

[jira] [Closed] (FLINK-8853) SQL Client cannot emit query results that contain a rowtime attribute

2018-03-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-8853. --- Resolution: Duplicate Fix Version/s: (was: 1.5.0) Will be fixed as part of FLINK-8850. > S

[jira] [Reopened] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-8807: > ZookeeperCompleted checkpoint store can get stuck in infinite loop > -

[jira] [Closed] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8807. -- Resolution: Fixed Fix Version/s: (was: 1.3.4) 1.3.3 > Zook

[jira] [Reopened] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-8807: > ZookeeperCompleted checkpoint store can get stuck in infinite loop > -

[jira] [Reopened] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-8807: > ZookeeperCompleted checkpoint store can get stuck in infinite loop > -

[jira] [Closed] (FLINK-7382) Broken links in `Apache Flink Documentation` page

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7382. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Brok

[jira] [Closed] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8807. -- Resolution: Fixed Fix Version/s: 1.4.3 > ZookeeperCompleted checkpoint store can

[jira] [Closed] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8807. -- Resolution: Fixed Fix Version/s: 1.3.4 > ZookeeperCompleted checkpoint store can

[jira] [Reopened] (FLINK-7127) Remove unnecessary null check or add null check

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7127: > Remove unnecessary null check or add null check >

[jira] [Reopened] (FLINK-7382) Broken links in `Apache Flink Documentation` page

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7382: > Broken links in `Apache Flink Documentation` page > -

[jira] [Closed] (FLINK-7127) Remove unnecessary null check or add null check

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7127. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Remo

[jira] [Closed] (FLINK-7670) typo in docs runtime section

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7670. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > typo

[jira] [Closed] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7600. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > shor

[jira] [Closed] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7630. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Allo

[jira] [Reopened] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7630: > Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() > ---

[jira] [Reopened] (FLINK-7670) typo in docs runtime section

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7670: > typo in docs runtime section > > > Key: F

[jira] [Reopened] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7600: > shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to > avoid

[jira] [Closed] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7495. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Abst

[jira] [Resolved] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

2018-03-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8687. - Resolution: Fixed Fix Version/s: 1.6.0 1.5.0 Fixed in 1.6.0: 7d837a3e884

[jira] [Reopened] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7495: > AbstractUdfStreamOperator#initializeState() should be called in > AsyncWaitOperator#i

[jira] [Commented] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

2018-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16395412#comment-16395412 ] ASF GitHub Bot commented on FLINK-8687: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-7453) FlinkKinesisProducer logs empty aws region

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7453. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Flin

[jira] [Resolved] (FLINK-7405) Reduce spamming warning logging from DatadogHttpReporter

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7405. Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 >

[jira] [Closed] (FLINK-7454) update 'Monitoring Current Event Time' section of Flink doc

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7454. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > upda

[jira] [Reopened] (FLINK-7454) update 'Monitoring Current Event Time' section of Flink doc

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7454: > update 'Monitoring Current Event Time' section of Flink doc >

[jira] [Reopened] (FLINK-7453) FlinkKinesisProducer logs empty aws region

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7453: > FlinkKinesisProducer logs empty aws region > -

[GitHub] flink pull request #5647: [FLINK-8687] Make MaterializedCollectStreamResult#...

2018-03-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5647 ---

[jira] [Reopened] (FLINK-6549) Improve error message for type mismatches with side outputs

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-6549: > Improve error message for type mismatches with side outputs >

[jira] [Reopened] (FLINK-7405) Reduce spamming warning logging from DatadogHttpReporter

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7405: > Reduce spamming warning logging from DatadogHttpReporter > ---

[jira] [Reopened] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-6493: > Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals() > --

[jira] [Closed] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6493. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Inef

[jira] [Closed] (FLINK-6549) Improve error message for type mismatches with side outputs

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6549. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Impr

[jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8416: --- Fix Version/s: (was: 1.3.3) 1.3.4 > Kinesis consumer doc exampl

[jira] [Closed] (FLINK-7971) Fix potential NPE with inconsistent state

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7971. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Fix

[jira] [Updated] (FLINK-8410) Kafka consumer's commitedOffsets gauge metric is prematurely set

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8410: --- Fix Version/s: (was: 1.3.3) 1.3.4 > Kafka consumer's commitedOf

[jira] [Reopened] (FLINK-7971) Fix potential NPE with inconsistent state

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7971: > Fix potential NPE with inconsistent state > -

[jira] [Assigned] (FLINK-8783) Test instability SlotPoolRpcTest.testExtraSlotsAreKept

2018-03-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-8783: Assignee: Till Rohrmann > Test instability SlotPoolRpcTest.testExtraSlotsAreKept >

[jira] [Closed] (FLINK-7939) DataStream of atomic type cannot be converted to Table with time attributes

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7939. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Data

[jira] [Closed] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7922. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > leas

[jira] [Closed] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7764. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Flin

[jira] [Updated] (FLINK-7932) Best Practices docs recommend passing parameters through open(Configuration c)

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7932: --- Fix Version/s: (was: 1.3.3) 1.3.4 > Best Practices docs recomme

[jira] [Reopened] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7922: > leastRestrictive in FlinkTypeFactory does not resolve composite type correctly > -

[jira] [Reopened] (FLINK-7939) DataStream of atomic type cannot be converted to Table with time attributes

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7939: > DataStream of atomic type cannot be converted to Table with time attributes >

[jira] [Reopened] (FLINK-7742) Fix array access might be out of bounds

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7742: > Fix array access might be out of bounds > --- > >

[jira] [Reopened] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7764: > FlinkKafkaProducer010 does not accept name, uid, or parallelism >

[jira] [Closed] (FLINK-7656) Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7656. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Swit

[jira] [Reopened] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7659: > Unprotected access to inProgress in > JobCancellationWithSavepointHandlers#handleNewR

[jira] [Reopened] (FLINK-7656) Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7656: > Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster > ---

[jira] [Closed] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7659. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Unpr

[jira] [Closed] (FLINK-7742) Fix array access might be out of bounds

2018-03-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7742. -- Resolution: Fixed Fix Version/s: (was: 1.3.3) 1.3.4 > Fix

  1   2   3   4   >