| GitBox |
[GitHub] [flink] KurtYoung commented on a change in pull request #9981: [FLINK-13195][sql-client] Add create table support for SqlClient |
Fri, 08 Nov, 09:44 |
| GitBox |
[GitHub] [flink] xuyang1706 commented on a change in pull request #9355: [FLINK-13577][ml] Add an util class to build result row and generate … |
Fri, 08 Nov, 09:45 |
| GitBox |
[GitHub] [flink] tillrohrmann commented on a change in pull request #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner |
Fri, 08 Nov, 09:45 |
| Maximilian Michels (Jira) |
[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure |
Fri, 08 Nov, 09:46 |
| GitBox |
[GitHub] [flink] xuyang1706 commented on a change in pull request #9355: [FLINK-13577][ml] Add an util class to build result row and generate … |
Fri, 08 Nov, 09:46 |
| GitBox |
[GitHub] [flink] xuyang1706 commented on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … |
Fri, 08 Nov, 09:49 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner |
Fri, 08 Nov, 09:52 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner |
Fri, 08 Nov, 09:52 |
| Kurt Young (Jira) |
[jira] [Commented] (FLINK-14608) avoid using Java Streams in JsonRowDeserializationSchema |
Fri, 08 Nov, 09:52 |
| GitBox |
[GitHub] [flink] tillrohrmann closed pull request #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner |
Fri, 08 Nov, 09:52 |
| Dawid Wysakowicz (Jira) |
[jira] [Commented] (FLINK-14608) avoid using Java Streams in JsonRowDeserializationSchema |
Fri, 08 Nov, 09:54 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat |
Fri, 08 Nov, 09:55 |
| GitBox |
[GitHub] [flink] lamber-ken commented on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer |
Fri, 08 Nov, 09:56 |
| GitBox |
[GitHub] [flink] zentol merged pull request #10050: [FLINK-14530][coordination] Capture DataSetID for partitions on TaskExecutor |
Fri, 08 Nov, 09:56 |
| GitBox |
[GitHub] [flink] lamber-ken edited a comment on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer |
Fri, 08 Nov, 09:56 |
| GitBox |
[GitHub] [flink] xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations |
Fri, 08 Nov, 09:57 |
| GitBox |
[GitHub] [flink] xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations |
Fri, 08 Nov, 09:57 |
| Chesnay Schepler (Jira) |
[jira] [Closed] (FLINK-14530) Capture partition meta info on TaskExecutor |
Fri, 08 Nov, 09:58 |
| GitBox |
[GitHub] [flink] xuyang1706 commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations |
Fri, 08 Nov, 09:58 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn |
Fri, 08 Nov, 09:59 |
| ming li (Jira) |
[jira] [Commented] (FLINK-14481) Modify the Flink valid socket port check to 0 to 65535. |
Fri, 08 Nov, 10:00 |
| Till Rohrmann (Jira) |
[jira] [Resolved] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner |
Fri, 08 Nov, 10:01 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner |
Fri, 08 Nov, 10:02 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … |
Fri, 08 Nov, 10:04 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10132: [FLINK-14636][runtime] Enable scheduling for ScheduleMode.LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST |
Fri, 08 Nov, 10:05 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations |
Fri, 08 Nov, 10:06 |
| Yang Wang (Jira) |
[jira] [Commented] (FLINK-13938) Use yarn public distributed cache to speed up containers launch |
Fri, 08 Nov, 10:07 |
| GitBox |
[GitHub] [flink] xuyang1706 commented on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations |
Fri, 08 Nov, 10:08 |
| GitBox |
[GitHub] [flink] buptljy commented on issue #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner |
Fri, 08 Nov, 10:08 |
| GitBox |
[GitHub] [flink] dawidwys commented on a change in pull request #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator |
Fri, 08 Nov, 10:09 |
| Rui Li (Jira) |
[jira] [Created] (FLINK-14673) Shouldn't expect HMS client to throw NoSuchObjectException for non-existing function |
Fri, 08 Nov, 10:12 |
| Rui Li (Jira) |
[jira] [Commented] (FLINK-14673) Shouldn't expect HMS client to throw NoSuchObjectException for non-existing function |
Fri, 08 Nov, 10:20 |
| Leonard Xu (Jira) |
[jira] [Created] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time |
Fri, 08 Nov, 10:21 |
| Chesnay Schepler (Jira) |
[jira] [Closed] (FLINK-13934) HistoryServerStaticFileServerHandlerTest failed on Travis |
Fri, 08 Nov, 10:24 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-7550) Give names to REST client/server for clearer logging. |
Fri, 08 Nov, 10:26 |
| GitBox |
[GitHub] [flink] tillrohrmann commented on issue #4645: [FLINK-7582] [REST] Netty thread immediately parses responses |
Fri, 08 Nov, 10:26 |
| GitBox |
[GitHub] [flink] tillrohrmann closed pull request #4645: [FLINK-7582] [REST] Netty thread immediately parses responses |
Fri, 08 Nov, 10:26 |
| ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod |
Fri, 08 Nov, 10:27 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod |
Fri, 08 Nov, 10:28 |
| Leonard Xu (Jira) |
[jira] [Created] (FLINK-14675) output directory settings of tpc-ds dataGenerator have length limitation |
Fri, 08 Nov, 10:28 |
| GitBox |
[GitHub] [flink] wsry commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. |
Fri, 08 Nov, 10:28 |
| Chesnay Schepler (Jira) |
[jira] [Closed] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes |
Fri, 08 Nov, 10:29 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull |
Fri, 08 Nov, 10:29 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn |
Fri, 08 Nov, 10:30 |
| GitBox |
[GitHub] [flink] dawidwys commented on issue #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator |
Fri, 08 Nov, 10:30 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics |
Fri, 08 Nov, 10:31 |
| GitBox |
[GitHub] [flink] dawidwys edited a comment on issue #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator |
Fri, 08 Nov, 10:31 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-7634) Add option to create a savepoint while canceling a job in the dashboard |
Fri, 08 Nov, 10:32 |
| GitBox |
[GitHub] [flink] dawidwys edited a comment on issue #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator |
Fri, 08 Nov, 10:32 |
| Chesnay Schepler (Jira) |
[jira] [Commented] (FLINK-13929) Revisit REST & JM URL |
Fri, 08 Nov, 10:34 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … |
Fri, 08 Nov, 10:35 |
| Gary Yao (Jira) |
[jira] [Commented] (FLINK-13878) Flink CLI fails (TimeoutException) for unknown reason |
Fri, 08 Nov, 10:36 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10130: [FLINK-14642] [types] Add support for copying null values to the TupleSeriali… |
Fri, 08 Nov, 10:36 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations |
Fri, 08 Nov, 10:36 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7688) ContaineredTaskManagerParameters sets off heap memory size incorrectly unlimited |
Fri, 08 Nov, 10:37 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7642) Upgrade maven surefire plugin to 2.21.0 |
Fri, 08 Nov, 10:37 |
| GitBox |
[GitHub] [flink] flinkbot commented on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer |
Fri, 08 Nov, 10:37 |
| Chesnay Schepler (Jira) |
[jira] [Commented] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache |
Fri, 08 Nov, 10:38 |
| Jingsong Lee (Jira) |
[jira] [Created] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource |
Fri, 08 Nov, 10:38 |
| GitBox |
[GitHub] [flink] tillrohrmann closed pull request #4743: [FLINK-7727] [REST] Improve error logging in StaticFileServerHandlers |
Fri, 08 Nov, 10:38 |
| GitBox |
[GitHub] [flink] tillrohrmann commented on issue #4743: [FLINK-7727] [REST] Improve error logging in StaticFileServerHandlers |
Fri, 08 Nov, 10:38 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-7727) Extend logging in file server handlers |
Fri, 08 Nov, 10:39 |
| ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-7727) Extend logging in file server handlers |
Fri, 08 Nov, 10:39 |
| yuemeng (Jira) |
[jira] [Commented] (FLINK-14666) support multiple catalog in flink table sql |
Fri, 08 Nov, 10:41 |
| yuemeng (Jira) |
[jira] [Comment Edited] (FLINK-14666) support multiple catalog in flink table sql |
Fri, 08 Nov, 10:41 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor |
Fri, 08 Nov, 10:41 |
| Dawid Wysakowicz (Jira) |
[jira] [Commented] (FLINK-14666) support multiple catalog in flink table sql |
Fri, 08 Nov, 10:45 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7743) Remove the restriction of minimum memory of JM |
Fri, 08 Nov, 10:47 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7758) Fix bug Kafka09Fetcher add offset metrics |
Fri, 08 Nov, 10:50 |
| Andrey Zagrebin (Jira) |
[jira] [Commented] (FLINK-13510) Show fail attempt for subtask in timelime |
Fri, 08 Nov, 10:52 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7795) Utilize error-prone to discover common coding mistakes |
Fri, 08 Nov, 10:53 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-7786) JarActionHandler.tokenizeArguments removes all quotes from program arguments |
Fri, 08 Nov, 10:53 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7825) Change the `QueryableStateClient` to use a builder pattern. |
Fri, 08 Nov, 10:53 |
| Leonard Xu (Jira) |
[jira] [Created] (FLINK-14677) validate all tpc-ds query result with TPC Official reference answer set |
Fri, 08 Nov, 10:53 |
| Gary Yao (Jira) |
[jira] [Commented] (FLINK-13647) Allow default methods and static methods to be added to public interfaces |
Fri, 08 Nov, 10:56 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-7926) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. |
Fri, 08 Nov, 10:56 |
| Gary Yao (Jira) |
[jira] [Comment Edited] (FLINK-13647) Allow default methods and static methods to be added to public interfaces |
Fri, 08 Nov, 10:57 |
| Chesnay Schepler (Jira) |
[jira] [Commented] (FLINK-13554) ResourceManager should have a timeout on starting new TaskExecutors. |
Fri, 08 Nov, 10:59 |
| Gary Yao (Jira) |
[jira] [Commented] (FLINK-13640) Consider TaskDeploymentDescriptorFactory to be Execution specific |
Fri, 08 Nov, 10:59 |
| Kurt Young (Jira) |
[jira] [Commented] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time |
Fri, 08 Nov, 10:59 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn |
Fri, 08 Nov, 10:59 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-7937) Add pagination to Flink History view |
Fri, 08 Nov, 11:01 |
| Till Rohrmann (Jira) |
[jira] [Updated] (FLINK-7937) Add pagination to Flink History view |
Fri, 08 Nov, 11:01 |
| Jingsong Lee (Jira) |
[jira] [Commented] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time |
Fri, 08 Nov, 11:02 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator |
Fri, 08 Nov, 11:02 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7945) Per partition-lag metric lost in kafka connector |
Fri, 08 Nov, 11:03 |
| Andrey Zagrebin (Jira) |
[jira] [Updated] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode? |
Fri, 08 Nov, 11:04 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10132: [FLINK-14636][runtime] Enable scheduling for ScheduleMode.LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST |
Fri, 08 Nov, 11:04 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer |
Fri, 08 Nov, 11:06 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7961) Docker-Flink with Docker Swarm doesn't work when machines are in different clouds |
Fri, 08 Nov, 11:07 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7965) Docker-Flink: TaskManagers can't find JobManager when in different nodes in Docker Swarm |
Fri, 08 Nov, 11:08 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7969) Resource manager support batch request slots |
Fri, 08 Nov, 11:10 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor |
Fri, 08 Nov, 11:10 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-7970) SlotPool support batch allocating slots |
Fri, 08 Nov, 11:11 |
| Gary Yao (Jira) |
[jira] [Commented] (FLINK-13432) Set max polling interval threshold for job result polling |
Fri, 08 Nov, 11:12 |
| Gary Yao (Jira) |
[jira] [Closed] (FLINK-13432) Set max polling interval threshold for job result polling |
Fri, 08 Nov, 11:13 |
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-8035) Unable to submit job when HA is enabled |
Fri, 08 Nov, 11:14 |
| Andrey Zagrebin (Jira) |
[jira] [Commented] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode? |
Fri, 08 Nov, 11:15 |
| Andrey Zagrebin (Jira) |
[jira] [Comment Edited] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode? |
Fri, 08 Nov, 11:15 |
| Andrey Zagrebin (Jira) |
[jira] [Comment Edited] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode? |
Fri, 08 Nov, 11:15 |